如何用python将云函数中的数据帧加载到BigQuery分区表中

pip install google-cloud-bigquery pandas

from google.cloud import bigquery
import pandas as pd

client = bigquery.Client()

data = {
    'column1': [value1, value2, ...],
    'column2': [value1, value2, ...],
    ...
}

df = pd.DataFrame(data)

project_id = 'your-project-id'
dataset_id = 'your-dataset-id'
table_id = 'your-table-id'

table_ref = client.dataset(dataset_id).table(table_id)
job_config = bigquery.LoadJobConfig()
job_config.write_disposition = bigquery.WriteDisposition.WRITE_APPEND
job_config.create_disposition = bigquery.CreateDisposition.CREATE_IF_NEEDED

job = client.load_table_from_dataframe(df, table_ref, job_config=job_config)
job.result()  # 等待加载作业完成