redis导出数据mysql

import redis
import pymysql

# 连接Redis
redis_client = redis.StrictRedis(host='localhost', port=6379, db=0)

# 连接MySQL
mysql_conn = pymysql.connect(host='localhost', user='root', password='password', db='test')
mysql_cursor = mysql_conn.cursor()

# 获取Redis中的所有键
keys = redis_client.keys('*')

for key in keys:
    # 获取键的类型
    key_type = redis_client.type(key).decode('utf-8')
    
    if key_type == 'string':
        value = redis_client.get(key)
        # 将数据插入MySQL
        mysql_cursor.execute(f"INSERT INTO redis_data (key, value, type) VALUES ('{key}', '{value}', 'string')")
    elif key_type == 'hash':
        hash_data = redis_client.hgetall(key)
        # 将数据插入MySQL
        for field, value in hash_data.items():
            mysql_cursor.execute(f"INSERT INTO redis_data (key, field, value, type) VALUES ('{key}', '{field}', '{value}', 'hash')")
    # 其他数据类型类似处理...

# 提交事务并关闭连接
mysql_conn.commit()
mysql_cursor.close()
mysql_conn.close()