redis mysql缓存方案

import redis
import mysql.connector

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

# 连接MySQL
mysql_conn = mysql.connector.connect(
    host='localhost',
    user='user',
    password='password',
    database='database'
)
mysql_cursor = mysql_conn.cursor()

def get_data(key):
    # 先从Redis缓存中获取数据
    data = redis_client.get(key)
    if data is not None:
        return data.decode('utf-8')
    
    # 如果缓存中没有数据，从MySQL数据库中获取
    mysql_cursor.execute("SELECT data FROM table WHERE key = %s", (key,))
    result = mysql_cursor.fetchone()
    if result is not None:
        data = result[0]
        # 将数据存入Redis缓存
        redis_client.setex(key, 3600, data)  # 设置1小时过期时间
        return data
    
    return None

def set_data(key, value):
    # 更新MySQL数据库
    mysql_cursor.execute("UPDATE table SET data = %s WHERE key = %s", (value, key))
    mysql_conn.commit()
    # 更新Redis缓存
    redis_client.setex(key, 3600, value)  # 设置1小时过期时间

# 示例调用
data = get_data('example_key')
print(data)

set_data('example_key', 'new_value')