Как позвонить Дагу из скрипта Python

Question

Я новичок в Airflow, я хочу знать, смогу ли я выполнить скрипт на python, который вызывает airflow dag. Например Я хочу выполнить скрипт /home/ec2-user/rundag.py. runday.py содержит две строки ниже импорт ОС os.system ('python /home/ec2-user/airflow/dags/testsftp.py')

Я попытался запустить, но задание testftp не началось. Дайте мне знать, если я сделал что-то не так или можно назвать дагом, как указано выше.

Answer 1

Вы можете сделать это с помощью экспериментального REST API .

По умолчанию экспериментальный API не защищен, и, следовательно, перед продолжением следует определить auth_backend в airflow.cfg вчтобы обезопасить его.

Как только REST API настроен, вы можете поразить эту конечную точку: http://{HOST}:{PORT}/admin/rest_api/api/v1.0/trigger_dag?dag_id={dag_id}&run_id={run_id}&conf={url_encoded_json_parameters}

Заменить dag_id идентификатором вашего dag, либо пропустив run_id, либо указав уникальныйid и передача URL-адреса в кодировке json для conf (с любым из параметров, которые вам нужны в триггере dag).