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 для офлайн-миграции. Обязательная опция при использовании параметров -–from-revision или -–from-version

-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;
Нашли ошибку? Выделите текст и нажмите Ctrl+Enter чтобы сообщить о ней