在 BigQuery Transfer Service UI 中,可以使用 run_date
参数来指定数据传输作业运行的日期。以下是一个示例代码,展示了如何使用 run_date
参数来运行数据传输作业:
from google.cloud import bigquery_datatransfer
# 定义数据传输作业的配置
transfer_config = {
"destination_dataset_id": "your_destination_dataset_id",
"display_name": "your_display_name",
"data_source_id": "your_data_source_id",
"params": {
"run_date": "2022-01-01" # 设置运行日期
}
}
# 创建 BigQuery Transfer Service 客户端
client = bigquery_datatransfer.DataTransferServiceClient()
# 运行数据传输作业
response = client.create_transfer_config(parent="projects/your_project_id", transfer_config=transfer_config)
# 打印响应
print(response)
在上述示例代码中,你需要替换以下参数:
your_destination_dataset_id
:目标数据集的 ID。your_display_name
:数据传输作业的显示名称。your_data_source_id
:数据源的 ID。your_project_id
:你的项目 ID。通过设置 params
字典中的 run_date
参数,可以指定数据传输作业的运行日期。在上述示例中,我们将 run_date
设置为 2022-01-01
。
请确保你已经完成了相关的准备工作,包括安装了 google-cloud-bigquery-datatransfer
库,以及正确配置了你的认证凭据。