Я настраиваю Airflow с MySQL в качестве базы данных и Celery Executors.I сделал следующие настройки в файле airflow.cfg
a) sql_alchemy_conn = mysql: // {USERNAME}: { ПАРОЛЬ} @ {MYSQL_HOST}: 3306 / airflow (соответственно укажите имя пользователя и пароль) b) celery_result_backend = db + mysql: // {USERNAME}: {PASSWORD} @ {MYSQL_HOST}: 3306 / airflow (укажите имя пользователя и пароль соответственно) c) executor = CeleryExecutor
d) и выполнено явное_доступность_для_стадии = 1 в файле my.cnf
при запуске initdb воздушного потока я получаю ошибки ниже.
Файл " /home/npa/anaconda2/envs/python3.7.2/bin/airflow ", строка 25, из файла airflow.configuration import conf Файл" /home/npa/anaconda2/envs/python3.7.2/lib/python3 .7 / site-packages / airflow / init .py ", строка 47, в файле settings.initialize ()" /home/npa/anaconda2/envs/python3.7.2/lib/ python3 .7 / site-packages / airflow / settings.py ", строка 377, в файле инициализации configure_orm ()" /home/npa/anaconda2/envs/python3.7.2/lib/python3.7/ сайт- packages / airflow / settings.py ", строка 266, в файле configure_orm engine = create_engine (SQL_ALCHEMY_CONN, ** engine_args)" /home/npa/anaconda2/envs/python3.7.2/lib/python3.7/site -packages / sqlalchemy / engine / init .py ", строка 479, в файле create_engine return Strategy.create (* args, ** kwargs) Файл" / home / npa / anaconda2 / envs / python3. 7.2 / lib / python3 .7 / site-packages / sqlalchemy / engine / стратегия.py ", строка 87, в файле create dbapi = dialect_cls.dbapi (** dbapi_args)" / home / npa / anaconda2 / envs / python3 .7.2 / lib / python3 .7 / site-packages / sqlalchemy / dialects / mysql / mysqldb.py ", строка 118, в dbapi return import (" MySQLdb ") ModuleNotFoundError: Нет модуля с именем 'MySQLdb'
Есть предложения о том, что необходимо сделать?