定时quart 复制mysql

from quart import Quart, task
import asyncio
import mysql.connector

app = Quart(__name__)

@task('interval', minutes=10)
async def copy_mysql():
    # 数据库连接配置
    config = {
        'user': 'your_user',
        'password': 'your_password',
        'host': 'your_host',
        'database': 'your_database'
    }
    
    # 连接源数据库
    source_conn = mysql.connector.connect(**config)
    source_cursor = source_conn.cursor()
    
    # 连接目标数据库
    target_conn = mysql.connector.connect(**config)
    target_cursor = target_conn.cursor()
    
    # 执行复制操作
    source_cursor.execute("SELECT * FROM your_table")
    rows = source_cursor.fetchall()
    for row in rows:
        target_cursor.execute("INSERT INTO your_table VALUES (%s, %s)", row)
    
    # 提交事务
    target_conn.commit()
    
    # 关闭连接
    source_cursor.close()
    source_conn.close()
    target_cursor.close()
    target_conn.close()

if __name__ == '__main__':
    app.run()