从Go app的Dataflow模板创建作业

1 回答

• 1

  仅当为您正在呼叫的服务开发了Google Client Library for Go时，才建议使用Auto-generated Google APIs for Go . Dataflow还没有客户端库 .

  要使用默认凭据从Go应用程序启动Dataflow模板：

  ctx := context.Background()
  oauthClient, err := google.DefaultClient(ctx, dataflow.CloudPlatformScope)
  
  dataflowService, err := dataflow.New(oauthClient)
  
  if err != nil {
    panic(err)
  }
  
  templateRequest := dataflow.CreateJobFromTemplateRequest{
    GcsPath: "gcs path to template here",
    JobName: "choose a unique job name here",
    Parameters: map[string]string{
      "parameters": "for job",
    },
  }
  
  result, err := dataflowService.Projects.Templates.Create("project id", &templateRequest).Do()
  
  if err != nil {
    panic(err)
  }
  

  回复于 2024-04-28T15:32:19+08:00