upgrade
Содержание
Использование
$ airflow db upgrade [-h] [--from-revision FROM_REVISION]
[--from-version FROM_VERSION] [-s] [-r TO_REVISION]
[-n TO_VERSION] [-m] [-v]Аргументы
| Параметр | Описание |
|---|---|
--from-revision |
(Необязательно) При генерации SQL передайте в этом параметре Alembic-версию, с которой необходимо обновиться |
--from-version |
(Опционально) При генерации SQL передайте в этом параметре версию, с которой необходимо обновиться |
-s, --show-sql-only |
Вместо запуска миграции сгенерировать скрипты SQL для офлайн-миграции. Обязательная опция при использовании параметров |
-r, --to-revision |
Выполнить миграции до указанной Alembic-версии |
-n, --to-version |
Версия Airflow, на которую необходимо перейти |
-m, --use-migration-files |
Использовать файлы миграции |
-h, --help |
Вывести справку для команды |
-v, --verbose |
Более подробный вывод команды |
Примеры
Пример команды, отображающей инструкции SQL для обновления базы данных:
$ airflow db upgrade --from-version 2.3.2 --to-version 2.3.3 --show-sql-onlyПример вывода:
DB: postgresql+psycopg2://airflow:***@elenas-ado.ru-central1.internal:5432/airflow Generating sql for upgrade -- upgrade commands will *not* be submitted. BEGIN; -- Running upgrade 3c94c427fdf6 -> f5fcbda3e651 CREATE INDEX idx_task_fail_task_instance ON task_fail (dag_id, task_id, run_id, map_index); CREATE INDEX idx_task_reschedule_dag_run ON task_reschedule (dag_id, run_id); CREATE INDEX idx_xcom_task_instance ON xcom (dag_id, task_id, run_id, map_index); UPDATE alembic_version SET version_num='f5fcbda3e651' WHERE alembic_version.version_num = '3c94c427fdf6'; COMMIT;