由于我是Apache Airflow的新手,有人能告诉我如何使用API调用触发,更新气流dag吗?
4urapxun1#
Airflow提供REST API。您可以使用/dags/{dag_id}/dagRuns端点触发dag运行。我不知道你说的“使用API调用更新气流数据库”是什么意思。Airflow根据DAGS_FOLDER中的源文件更新DAG。
/dags/{dag_id}/dagRuns
DAGS_FOLDER
rwqw0loc2#
Airflow有rest API端点,可以在你的node js应用中使用https://airflow.apache.org/docs/apache-airflow/1.10.10/rest-api-ref.html这里是视频教程以及https://www.youtube.com/watch?v=WTR-YT5imrY
2条答案
按热度按时间4urapxun1#
Airflow提供REST API。您可以使用
/dags/{dag_id}/dagRuns
端点触发dag运行。我不知道你说的“使用API调用更新气流数据库”是什么意思。Airflow根据
DAGS_FOLDER
中的源文件更新DAG。rwqw0loc2#
Airflow有rest API端点,可以在你的node js应用中使用
https://airflow.apache.org/docs/apache-airflow/1.10.10/rest-api-ref.html
这里是视频教程以及
https://www.youtube.com/watch?v=WTR-YT5imrY