SchedulerX:アップストリームジョブからワークフロー内のダウンストリームジョブへのデータの受け渡し

手順

1. 3 つのアプリケーションに対して、ジョブスケジューリングクラス JobProcessor A、JobProcessor B、および JobProcessor C をそれぞれ実装します。

   • JobProcessor A

     @Component
     public class TestSimpleJobA extends JavaProcessor {
     @Override
     public ProcessResult process(JobContext context) throws Exception {
     System.out.println("TestSimpleJobA " + DateTime.now().toString("yyyy-MM-dd HH:mm:ss"));
     return new ProcessResult(true, String.valueOf(1));
     }
     }                            

   • JobProcessor B

     @Component
     public class TestSimpleJobB extends JavaProcessor {
     @Override
     public ProcessResult process(JobContext context) throws Exception {
     System.out.println("TestSimpleJobB " + DateTime.now().toString("yyyy-MM-dd HH:mm:ss"));
     return new ProcessResult(true, String.valueOf(2));
     }
     }                            

   • JobProcessor C

     @Component
     public class TestSimpleJobC extends JavaProcessor {
     @Override
     public ProcessResult process(JobContext context) throws Exception {
     List<JobInstanceData> upstreamDatas = context.getUpstreamData();
     int sum = 0;
     for (JobInstanceData jobInstanceData : upstreamDatas) {
           System.out.println("jobName=" + jobInstanceData.getJobName() 
               + ", data=" + jobInstanceData.getData()); // アップストリームジョブ名とデータを出力します
           sum += Integer.valueOf(jobInstanceData.getData());
     }
     System.out.println("TestSimpleJobC sum=" + sum); // 合計値を出力します
     return new ProcessResult(true, String.valueOf(sum));
     }
     }                            

2. Enterprise Distributed Application Service（EDAS）にアプリケーションをデプロイします。
3. アプリケーションごとにグループを作成し、jobA、jobB、および jobC を作成します。 詳細については、「アプリケーション管理」および「ジョブの作成」をご参照ください。
4. ワークフローを作成し、ジョブをワークフローにインポートします。 詳細については、「ワークフローの作成」をご参照ください。
5. Process Management ページで、ワークフローの 詳細[操作] 列の 一度だけ実行 をクリックし、 を選択します。