如何通过Python Google API客户端库在私有子网运行Dataflow
你需要在请求的body参数中新增environment字段,将子网配置放在该字段下即可,修改后的代码示例如下:
request = dataflow.projects().locations().templates().launch( projectId = PROJECT_ID, location = REGION, gcsPath = TEMPLATE_LOCATION, body = { 'jobName': job_name, 'parameters': job_parameters, # 运行时环境配置统一放在environment字段下 'environment': { # 填写子网的完整资源标识 'subnetwork': f'regions/{REGION}/subnetworks/data-subnet' # 若使用跨项目共享VPC,需携带宿主项目标识,格式如下: # 'subnetwork': f'projects/{VPC_HOST_PROJECT_ID}/regions/{REGION}/subnetworks/data-subnet' # 如需禁止Worker分配公网IP,可新增以下配置: # 'ipConfiguration': 'WORKER_IP_PRIVATE' } } ) response = request.execute()
补充说明:Dataflow模板启动接口中,parameters字段仅用于传递作业业务参数,网络、机器规格、服务账号等基础运行环境配置,均需放在environment字段下声明。
内容的提问来源于stack exchange,提问作者DarioB
相关产品推荐
相关产品推荐

