Airflow REST API를 통해, 목록에서 DAG 제거하는 방법

 

🔥 TODO

👉 Airflow REST API를 통해, 목록에서 DAG 제거하기

 Postman으로 Airflow Webserver에 요청하여 특정 DAG를 목록에서 제거하겠습니다.

성공하면, 외부 시스템에서 DAG를 목록에서 강제로 제거할 수 있을 것입니다.

 

예시를 위해, example_skip_dag를 제거해보겠습니다.

🧙 특정 DAG를 목록에서 제거

👉 아래 사진을 참고하여 Postman을 설정하시면 됩니다.

Authorization의 Username은 Airflow webserver의 접속 정보를 입력하시면 됩니다.

DELETE를 선택하신 후 URL은 아래의 사진을 참고하세요.

https://airflow.apache.org/api/v1/dags/{dag_id}

 

Headers의 Key는 Content-Type을 입력해주시고 Value는 applicaton/json을 입력합니다.

입력이 완료되었으면, Send 버튼을 클릭합니다.

그러면 아래와 같은 결과를 얻을 수 있습니다.

🏆 Result

👉 Airflow webserver에서 확인해보면 다음과 같이

example_skip_dag가 목록에서 제거된 것을 확인할 수 있습니다.

 

다만 주의할 점이 있다면, 위 DELETE API는 .py를 제거하지 않습니다.

즉, DAG를 목록에서만 제거하는 것이고 DAG 원천이 되는 파이썬 파일을 제거하는 것은 아니라는 뜻입니다. 만약, Airflow webserver에서 .py을 자동으로 인식하여 DAG 목록으로 불러오는 설정이 있다면 제거해야합니다. 그래야 위 DELETE API를 제대로 사용하실 수 있을 것입니다.

 

한번 다뤄보시면 무슨 말인지 아실 것입니다 ^ ㅡ ^;

 

If I was of any help to you, please buy me coffee 😿😢😥

If you have any questions, please leave them in the comments

Buy me a coffee

▶ Youtube Sub

🧭 References

[1] reference : https://doctorson0309.tistory.com/

[2] Ads : https://play.google.com/store/apps/details?id=io.cordova.seoulfilter