从变量向BQ表插入数据时Bigquery表模式的动态处理

from google.cloud import bigquery

# 创建BigQuery客户端
client = bigquery.Client()

# 定义目标表的基本结构
table_ref = client.dataset('your_dataset').table('your_table')
table = bigquery.Table(table_ref)
table = client.create_table(table)  # 创建空表

# 根据变量的值动态生成模式
schema = [
    bigquery.SchemaField('column1', 'STRING'),
    bigquery.SchemaField('column2', 'INTEGER'),
    # 根据需要添加更多的列和数据类型
]

# 修改目标表的模式
table.schema = schema
table = client.update_table(table, ['schema'])  # 更新表的模式

# 插入数据到目标表
rows_to_insert = [
    ('value1', 1),
    ('value2', 2),
    # 根据需要添加更多的数据
]

client.insert_rows(table, rows_to_insert)  # 插入数据到表中