0

のApp Engine DataflowジョブでDataflow APIを使用してパラメータをテンプレートに渡す必要があります。マイコードでDataflow APIを使用して起動中のテンプレートへのパラメータの受け渡し

com.google.api.services.dataflow.Dataflow.Projects.Locations.Templates.Launch request1 = 


    dataflowService.projects().locations().templates().launch(projectId,"us-central1",null); 

       request1.setGcsPath(template); 
       request1.setLocation("us-central1"); 
       request1.setValidateOnly(false); 

       //Storing launch Response 
       LaunchTemplateResponse response1 = request1.execute(); 

、私はクラウドファンクションでのパラメータと同様に設定することができGCSパス、場所、および有効期限を設定しなくすることができますよ。 Javaを使用してパラメータを設定する方法です。なぜなら、Pythonでは可能なので、私はJavaでそう考えていたからです。

+0

「クラウド機能のようなパラメータを設定する」ということを具体的に説明できますか?テンプレートのすべてのパラメータをgcsパスなどと同じように設定することができるはずです。 –

+0

上記の質問を無視して、私はあなたが求めていることを知っていると思います。ちょうどAPIを参照してください。 –

答えて

1

ToパラメータA使用する - : LaunchTemplateParametersパラメータ= new LaunchTemplateParameters();

LaunchTemplateParameters parameters = new LaunchTemplateParameters(); 
    Map<String,String> map = new HashMap<String,String>(); 
      map.put("inputFile", "gs://xyz-bucket/Temp.txt"); 
parameters.setParameters(map); 
     com.google.api.services.dataflow.Dataflow.Projects.Locations.Templates.Launch request1 = 
         dataflowService.projects().locations().templates().launch(projectId,"us-central1",parameters); 

      request1.setGcsPath(template); 
      request1.setLocation("us-central1"); 
      request1.setValidateOnly(false); 


      LaunchTemplateResponse response1 = request1.execute(); 
関連する問題