redis 定时写入mysql

import redis
import pymysql
from quartz import Scheduler

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

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

def sync_data():
    data = redis_client.keys('*')
    for key in data:
        value = redis_client.get(key)
        try:
            mysql_cursor.execute("INSERT INTO table (key, value) VALUES (%s, %s)", (key, value))
            mysql_conn.commit()
        except Exception as e:
            mysql_conn.rollback()
            print(f"Error: {e}")

# 创建定时任务
scheduler = Scheduler()
scheduler.add_job(sync_data, 'interval', minutes=10)
scheduler.start()

def sync_data():
    data = redis_client.keys('*')
    for key in data:
        value = redis_client.get(key)
        version = redis_client.get(f"{key}:version")
        try:
            mysql_cursor.execute("SELECT version FROM table WHERE key = %s", (key,))
            result = mysql_cursor.fetchone()
            if result and result[0] >= version:
                continue
            mysql_cursor.execute("INSERT INTO table (key, value, version) VALUES (%s, %s, %s)", (key, value, version))
            mysql_conn.commit()
        except Exception as e:
            mysql_conn.rollback()
            print(f"Error: {e}")