Я пытаюсь вызвать мой даг с помощью AirFlow rest API. Однако не в состоянии понять, как сделать аутентификацию.
Следующий URL работает нормально из моего браузера.
http://localhost: 8181 / api / экспериментальный / dags / demo / dag_runs
Однако следующий код выдает ошибку аутентификации.
import requests import json from pprint import pprint result = requests.get( "http://localhost:8181/api/experimental/dags/demo/dag_runs", data=json.dumps("{}"), auth=("myuser", "mypassword")) pprint(result.content.decode('utf-8'))
Я тоже нашел это, но теперь уверен, как пройти auth
https://github.com/apache/airflow/blob/master/airflow/api/client/api_client.py