redis缓存存入mysql

在Redis缓存中存入MySQL数据的方案有两种：

方案1：通过MySQL自动同步刷新Redis
这种方案使用MySQL的触发器和UDF函数来实现。当MySQL中的数据发生变化时，触发器会将变化的数据通过UDF函数写入到Redis中，从而实现数据的同步。

方案2：解析MySQL的binlog实现
这种方案通过解析MySQL的binlog来获取数据库中的数据变化，并将解析出来的数据写入到Redis中。当MySQL中有数据写入时，我们可以解析binlog文件，提取出数据变化的信息，然后将这些信息写入到Redis中，从而实现数据的同步。

以下是方案2的示例代码：

import pymysql
import redis
from pymysqlreplication import BinLogStreamReader

# MySQL连接配置
mysql_config = {
    'host': 'localhost',
    'port': 3306,
    'user': 'root',
    'password': 'password',
    'db': 'mydatabase'
}

# Redis连接配置
redis_config = {
    'host': 'localhost',
    'port': 6379,
    'db': 0
}

# 创建MySQL连接
mysql_conn = pymysql.connect(**mysql_config)

# 创建Redis连接
redis_conn = redis.Redis(**redis_config)

# 创建binlog解析器
stream = BinLogStreamReader(connection_settings=mysql_config, server_id=100)

# 监听binlog事件
for binlog_event in stream:
    if binlog_event.event_type == 'write_rows':
        for row in binlog_event.rows:
            # 将数据写入Redis
            redis_conn.set(row['values']['key'], row['values']['value'])
    elif binlog_event.event_type == 'delete_rows':
        for row in binlog_event.rows:
            # 从Redis中删除数据
            redis_conn.delete(row['values']['key'])

# 关闭连接
stream.close()
mysql_conn.close()
redis_conn.close()

请注意，以上代码仅为示例，实际使用时需要根据具体情况进行配置和修改。