BigQuery 定时查询:无法在 JURISDICTION_US 创建传输,当目标数据集位于 REGION_EUROPE_NORTH_1 时。
创始人
2024-12-12 06:00:28
0

您可以使用 BigQuery 定时查询来解决这个问题。以下是一个解决方案的代码示例:

from google.cloud import bigquery
from google.cloud import bigquery_datatransfer

def create_scheduled_query(project_id, dataset_id, query, destination_dataset_project_id, destination_dataset_id):
    client = bigquery_datatransfer.DataTransferServiceClient()
    
    transfer_config = bigquery_datatransfer.TransferConfig(
        destination_dataset_id=destination_dataset_id,
        display_name='Scheduled query transfer config',
        data_source_id='scheduled_query',
        params={
            'query': query,
            'destination_table_name_template': 'table_{run_time|"%Y%m%d"}',
            'write_disposition': 'WRITE_TRUNCATE',
            'partitioning_field': '',
            'destination_dataset_table': f"{destination_dataset_project_id}.{destination_dataset_id}"
        },
        schedule='every 24 hours'
    )
    
    parent = f"projects/{project_id}/locations/US"
    transfer_config = client.create_transfer_config(parent=parent, transfer_config=transfer_config)
    
    print(f"Created transfer config: {transfer_config.name}")

if __name__ == "__main__":
    project_id = "YOUR_PROJECT_ID"
    dataset_id = "SOURCE_DATASET_ID"
    query = "SELECT * FROM `YOUR_PROJECT_ID.YOUR_DATASET_ID.YOUR_TABLE_ID`"
    destination_dataset_project_id = "DESTINATION_PROJECT_ID"
    destination_dataset_id = "DESTINATION_DATASET_ID"
    
    create_scheduled_query(project_id, dataset_id, query, destination_dataset_project_id, destination_dataset_id)

请将以下值替换为您自己的项目和数据集信息:

  • YOUR_PROJECT_ID: 您的项目 ID
  • SOURCE_DATASET_ID: 源数据集 ID
  • YOUR_TABLE_ID: 源数据集中的表 ID
  • DESTINATION_PROJECT_ID: 目标数据集所在的项目 ID
  • DESTINATION_DATASET_ID: 目标数据集 ID

此代码示例使用 bigquery_datatransfer 库来创建一个定时查询的传输配置。在 params 中,您可以设置查询、目标表的命名模板、写入行为和分区字段。在 schedule 中,您可以设置定时查询运行的计划。

请确保您的项目已经启用了 BigQuery 数据传输服务,并且您具有适当的权限来创建传输配置。

相关内容

热门资讯

德州ai人工智能!nzt德州辅... 德州ai人工智能!nzt德州辅助软件,德州之星一贯真的是有挂(详细有作弊教程)1、超多福利:超高返利...
wepoke有挂!wepoke... wepoke有挂!wepoke人有挂(透视)wepOkE(都是真的有挂)1、许多玩家不知道wepOk...
wepoke ai辅助!微扑克... wepoke ai辅助!微扑克真的有挂,aapoker线上规律(详细透视教程);亲们利用一分钟了解精...
wpk德州透视辅助(WPK)w... wpk德州透视辅助(WPK)wpk辅助软件(透明挂)都是真的有挂(必胜教程);1、每一步都需要思考,...
德州ai辅助有用!德扑手牌胜率... 德州ai辅助有用!德扑手牌胜率计算工具,德州app总是真的是有挂(详细ai辅助有用教程),您好,德州...
wepoke ai辅助!wep... 1、wepoke ai辅助!wepoke算法,wepoke系统是免费的,存在挂教程(有挂插件);详细...
wepoke辅助有挂!来玩德州... wepoke辅助有挂!来玩德州app辅助软件,wpk德州俱乐部机器人(详细辅助教程);wpk透视辅助...
wpk真的有外 挂!wpk透视... wpk真的有外 挂!wpk透视辅助效果图,wpK原来真的有挂,详细教程,(有挂规律)1、wpk系统规...
德州之星辅助!德州之星辅助器多... 您好,德州之星辅助这款游戏可以开挂的,确实是有挂的,需要了解加微【136704302】很多玩家在这款...
aapoker透明挂!wepo... aapoker透明挂!wepower德州扑克,WePoke本来真的有挂,2025教程(有挂揭秘)是一...