Spring Cloud DataFlow - タスク実行後に実行IDを取得

Question

現在、私はワークフローと実行時環境としてSpring XDからSpring Cloud DataFlowとApache Airflowに移行しています。 Airflowでワークフローを作成し、カスタムAirflow演算子を使用してSpring Cloud DataFlowサーバー上でSpring Cloud TasksをREST-APIで実行したいとします。

それは使用可能です：

curl -X GET http://SERVER:9393/tasks/deployments/... 

残念ながら、データフローは、アプリケーションの監視のための簡単な方法を作成するには、この要求にジョブ実行IDを返しません。このIDを同期的に取得する方法はありますか？特定の仕事の最後の実行を得ることは間違いにつながる可能性があります。私は同じ時間に多くの同じジョブを実行した場合、ジョブの実行が失われています。

私はSpringバッチジョブを実行していますので、何らかの形で実行ジョブIDを設定して入力パラメータとして渡してください。

Answer 1

あなたの豆からタスク情報を収集するために、次のアノテーションを使用してみてください：

public class MyBean { 

    @BeforeTask 
    public void methodA(TaskExecution taskExecution) { 
    } 

    @AfterTask 
    public void methodB(TaskExecution taskExecution) { 
    } 

    @FailedTask 
    public void methodC(TaskExecution taskExecution, Throwable throwable) { 
    } 
} 

https://docs.spring.io/spring-cloud-task/docs/current-SNAPSHOT/reference/htmlsingle/#features-task-execution-listener