Airflow CLI
- Обзор
- Общие команды
- Компоненты Celery
- Просмотр конфигурации
- Управление соединениями
- Управление DAG
- Управление базой данных
- Управление заданиями
- Управление KubernetesExecutor
- Управление пулами
- Управление провайдерами
- Управление ролями
- Управление задачами
- Управление пользователями
- Управление переменными
Обзор
В этот раздел включена справочная документация по интерфейсу командной строки Airflow.
Использование команд:
$ airflow COMMAND [GENERIC_OPTIONS] SUBCOMMAND [COMMAND_OPTIONS]Общие команды
Команды общего назначения для управления кластером Airflow.
| Команда | Описание |
|---|---|
Выводит подсказку по командам |
|
Запускает отдельный экземпляр процессора DAG |
|
Отображает информацию об Airflow и окружении |
|
Запускает обновление тикетов Kerberos |
|
Выводит информацию о загруженных плагинах |
|
Выполняет ротацию зашифрованных учетных данных соединения и переменных |
|
Запускает экземпляр планировщика |
|
Запускает полнофункциональную копию Airflow |
|
Обновляет разрешения для существующих ролей и групп DAG (если необходимо) |
|
Запускает экземпляр триггера |
|
Показывает версию Airflow |
|
Запускает экземпляр веб-сервера Airflow |
Управление DAG
Команды для управления DAG.
| Команда | Описание |
|---|---|
Запускает подразделы DAG для указанного диапазона дат |
|
Удаляет все записи БД, связанные с указанным DAG |
|
Отображает информацию о DAG |
|
Выводит список всех DAG |
|
Выводит список всех DAG, имеющих ошибки импорта |
|
Выводит список задач |
|
Выводит список запусков DAG |
|
Отображает даты выполнения следующих DAG |
|
Приостанавливает DAG |
|
Показывает отчет о загрузке DAG |
|
Повторно сериализует все DAG, анализируя файлы DAG |
|
Отображает задачи DAG с их зависимостями |
|
Отображает DAG с их зависимостями |
|
Отображает состояние запуска DAG |
|
Выполняет тестовый запуск DAG |
|
Запускает DAG |
|
Возобновляет приостановленный DAG |
Управление базой данных
Команды для управления базой данных Airflow.
| Команда | Описание |
|---|---|
Проверяет, доступна ли база данных |
|
Проверяет, завершена ли миграция |
|
Удаляет старые записи в таблицах metastore |
|
Понижает версию базы метаданных |
|
Удаляет архивные таблицы, созданные с помощью команды |
|
Экспортирует данные из архива таблицы |
|
Инициализирует базу метаданных |
|
Удаляет и пересоздает базу метаданных |
|
Запускает shell для доступа к базе данных |
|
Обновляет базу метаданных до последней версии |
Управление заданиями
Команды для управления заданиями Airflow.
| Команда | Описание |
|---|---|
Проверяет статус задания |
Управление KubernetesExecutor
Команды для управления KubernetesExecutor.
| Команда | Описание |
|---|---|
Удаляет модули Kubernetes (созданные KubernetesExecutor/KubernetesPodOperator) в состояниях |
|
Генерирует файлы YAML для всех задач в DAG. Полезно для отладки задач без запуска в кластере |
Управление провайдерами
Команды для получения информации о провайдерах.
| Команда | Описание |
|---|---|
Отображает информацию о бэкендах аутентификации API |
|
Отображает информацию о зарегистрированных типах подключений с кастомным поведением |
|
Отображает подробную информацию о провайдере |
|
Показывает список зарегистрированных хуков провайдера |
|
Показывает список дополнительных ссылок, зарегистрированных провайдерами |
|
Показывает список установленных провайдеров |
|
Отображает информацию об обработчиках логирования |
|
Отображает информацию о бэкендах конфиденциальной информации |
|
Отображает информацию о зарегистрированных подключениях виджетов |
Управление задачами
Команды для управления задачами Airflow.
| Команда | Описание |
|---|---|
Очищает набор экземпляров задач |
|
Возвращает известные планировщику зависимости задачи, которые вызвали ошибку |
|
Отображает задачи в DAG |
|
Отображает шаблоны задачи |
|
Запускает один экземпляр задачи |
|
Отображает статус задачи |
|
Отображает состояние всех задач в DAG |
|
Выполняет тестовый запуск задачи |