Spring Cloud DataFlow - 작업 실행 후 실행 ID 얻기

Question

현재 스프링 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 DataFlow에서 스프링 배치 작업을 실행하고 있으므로 어쨌든 더 좋은 방법은 실행 작업 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