mysql定时取redis数据

import redis
import pymysql
from apscheduler.schedulers.blocking import BlockingScheduler

# 连接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()

def sync_data():
    # 从Redis读取数据
    data = redis_client.get('my_key')
    
    if data:
        try:
            # 数据转换和写入MySQL
            mysql_cursor.execute("INSERT INTO my_table (data) VALUES (%s)", (data,))
            mysql_conn.commit()
        except Exception as e:
            print(f"Error: {e}")
            mysql_conn.rollback()

# 创建调度器并添加任务
scheduler = BlockingScheduler()
scheduler.add_job(sync_data, 'interval', minutes=5)

try:
    scheduler.start()
except (KeyboardInterrupt, SystemExit):
    pass