일부 응용 프로그램이 실행 중이며 공기 흐름을 사용하기를 원합니다. 설명서에서 DAG를 시작하는 유일한 방법은 명령 줄을 사용하는 것입니다. 사실입니까?공기 흐름 비단뱀 클라이언트
예를 들어 플라스크 서버가 실행 중이며 공기 흐름에 의해 제어되는 워크 플로를 시작하려고합니다. 우리는 어떻게 이것을 할 수 있습니까? 예를 들어 트리거 할 수있는 API가 있습니까? "이제 매개 변수 x, y, h가있는 DAG 실행"?
공기 흐름을 사용하여이를 수행하는 데는 몇 가지 방법이 있습니다. 그것은 귀하의 상황에 따라 다르며, 귀하가 어떤 상황에 처한 상황에 따라 다릅니다. 내 마음에 오는 두 가지 제안 :
트리거 된 DAG를 사용하십시오. 백그라운드에서 실행중인 Python 작업은 이벤트가 발생할 경우 실행될 DAG를 트리거 할 수 있습니다. GitHub Airflow
사용 SensorTasks : 저장소의 경우 a example_trigger_controller_dag.py보고 example_trigger_target_dag.py을 가지고 당신이 데이터 소스 f.e.의 특정 이벤트를 수신하는 데 사용할 수있는 사용 가능한 몇 가지 미리 정의 된 센서가 있습니다 일단 기존의 요구 사항을 만족하지 않는 경우, 공기 흐름은 당신이로 내가 당신의 유스 케이스를 이해 Airflow Sensor
질문을 읽은 후 자신의 센서를 구현할 수 있도록 충분히 적응할 수 있어야한다 : 당신이 실행하고자하는 그
/A를 트리거 수동 또한
당신은 실험에 여전히 HERE을 갈 수는 DAG를/트리거 실행할 수있는 (8080/로컬 호스트) - HTTP 서버에서 DAG는
> 당신은 제공된 공기 흐름 웹 서버를 사용할 수 있습니다 모드로 설정하고 제공된 API를 사용하십시오
질문을 더 잘 이해하기 위해 더 자세히 설명하십시오.