本地数据库实时更新到云服务器

import pymysql
from tencentcloud.common import credential
from tencentcloud.dts.v20180330 import dts_client, models

# 配置本地数据库连接
local_db = pymysql.connect(host='localhost', user='user', password='password', db='database')

# 配置腾讯云DTS客户端
cred = credential.Credential("your_secret_id", "your_secret_key")
client = dts_client.DtsClient(cred, "ap-guangzhou")

# 创建同步任务
req = models.CreateSyncJobRequest()
params = {
    "JobName": "LocalToCloudSync",
    "Source": {
        "Type": "mysql",
        "InstanceID": "local_db_instance_id"
    },
    "Target": {
        "Type": "mysql",
        "InstanceID": "cloud_db_instance_id"
    },
    "SyncOption": {
        "SyncType": "full",
        "SyncDirection": "one_way"
    }
}
req.from_json_string(params)

resp = client.CreateSyncJob(req)
print(resp.to_json_string(indent=2))