공기 흐름을 통해 일부 특정 dag와 연결된 키로 사용자 패스 매개 변수를 끝낼 수 있습니다.

Question

많은 링크를 검색했지만 가지고있는 문제점을 해결하지 못했습니다. 기류 UI에 key/var를 전달할 수있는 옵션을 보았지만 최종 사용자가 어떤 키가 어떤 dag와 관련되어 있는지 혼동하는 것은 정말 혼란 스럽습니다. 다음과 같은 기능을 구현할 수있는 방법이 있습니까 :

While running an airflow job, end user will be asked for values to some parameters and after entering those details airflow will run the job.

Answer 1

유감스럽게도, 사용자 입력을 기다리는 것이 Airflow UI에서 가능하지 않습니다. DAG는 프로그래밍 방식으로 작성되며 코드로 정의되는 것을 의미하며 웹 서버, 스케줄러 및 작업자에서 동시에 가져오고 동일해야하므로 동적이지 않아야합니다.

내가 생각해 낸 두 가지 해결 방법이 있으며, 처음에는 프로덕션 환경에서 사용합니다.

1) 변수 주위에 작은 래퍼를 만듭니다. 각 DAG에 대해 변수를로드하고 인수를 구성한 다음 default_arguments을 통해 연산자에 전달합니다.

2) 사용자 입력을 대기하도록 프로그래밍 방식으로 구성 할 수있는 슬랙 연산자를 추가합니다. 그런 다음 해당 정보를 XCOM을 통해 다음 운영자에게 전파하십시오.