Шаг 2 из 3

Настройка airflow.cfg

Для настройки CeleryExecutor необходимо выполнить следующие шаги:

• Заменить LocalExecutor на CeleryExecutor у свойства executor:

executor = CeleryExecutor

• Найти свойство broker_url и указать параметры брокера, для Redis можно формат: redis://<host>:<port>/<db_num>:

broker_url = redis://localhost:6379/0

• Найти свойство result_backend, оно отвечает за параметры доступа к хранилищу, куда будет складироваться статус выполнения задач. Я предпочитаю использовать те же параметры что и для базы данных Airflow:

result_backend = db+postgresql://airflow:password@localhost:6666/airflow

Этого достаточно для начальной настройки выполнения задач через Celery.