从运营数据存储到仓库

import mysql.connector
from tencentcloud.common import credential
from tencentcloud.cdw.v20200915 import cdw_client, models

# 连接MySQL数据库
mysql_conn = mysql.connector.connect(
    host="your_mysql_host",
    user="your_mysql_user",
    password="your_mysql_password",
    database="your_mysql_database"
)

# 查询数据
cursor = mysql_conn.cursor()
cursor.execute("SELECT * FROM your_table")
data = cursor.fetchall()

# 连接腾讯云数据仓库CDW
cred = credential.Credential("your_secret_id", "your_secret_key")
client = cdw_client.CdwClient(cred, "ap-guangzhou")

# 创建表
create_table_request = models.CreateTableRequest()
create_table_request.DatabaseName = "your_database_name"
create_table_request.TableName = "your_table_name"
create_table_request.Columns = [
    models.Column(name="column1", type="STRING"),
    models.Column(name="column2", type="INT")
]
client.CreateTable(create_table_request)

# 插入数据
insert_data_request = models.InsertDataRequest()
insert_data_request.DatabaseName = "your_database_name"
insert_data_request.TableName = "your_table_name"
insert_data_request.Rows = data
client.InsertData(insert_data_request)

# 关闭连接
cursor.close()
mysql_conn.close()