airflowctl - новый официальный CLI, который разговаривает с Airflow Public API и даёт удобные команды для повседневных задач:
🔘триггерить DAG-и
🔘листать и проверять DagRun-ы
🔘паузить/анпаузить
🔘управлять connections/variables
Всё это удалённо, из CI/CD или локально, без SSH на кластеры.
Зачем это нужно:
🔘централизованный доступ к продам и стейджам через API
🔘единый инструмент для SRE/Platfоrm/DE‑команд и пайплайнов
🔘безопаснее: используем API‑токен, который хранится в keyring.
Пример - поставить и дернуть DAG удалённо:
# установка
pip install apache-airflow-ctl
# логин (через токен; API должен быть включён)
export AIRFLOW_CLI_TOKEN=<api_token>
airflowctl auth login --api-url https://airflow.example.com --env prod
# посмотреть доступные DAG-и
airflowctl dags list -o table
# триггернуть DAG с конфигом и заметкой
airflowctl dags trigger \
--dag-id example_etl \
--conf '{"country":"RU"}' \
--note "triggered from airflowctl"
# проверить последние запуски
airflowctl dagrun list --dag-id example_etl --limit 5 -o table
Подробнее в доке.
#airflow #release #airflowctl