Почему Airflow Worker пытается подключиться к локальному серверу MYSQL, а не из конфигурации airflow - PullRequest
Новая
       2

Почему Airflow Worker пытается подключиться к локальному серверу MYSQL, а не из конфигурации airflow

0 голосов
/ 29 октября 2018

Когда я запускаю работника воздушного потока с какой-то очередью, выдается следующее сообщение об ошибке.

Я сконфигурировал детали базы данных в конфигурации воздушного потока. но не уверен, почему он пытается подключиться к локальному серверу MySQL 

[2018-10-29 18:59:32,012: ERROR/MainProcess] Pool callback raised exception: OperationalError('(_mysql_exceptions.OperationalError) (2002, "Can\'t connect to local MySQL server through socket \'/var/lib/mysql/mysql.sock\' (2)")',)
Traceback (most recent call last):
  File "/home/airflow/.local/lib/python2.7/site-packages/billiard/pool.py", line 1747, in safe_apply_callback
    fun(*args, **kwargs)
    return dialect.connect(*cargs, **cparams)
  File "/home/airflow/.local/lib/python2.7/site-packages/sqlalchemy/engine/default.py", line 393, in connect
    return self.dbapi.connect(*cargs, **cparams)
  File "/usr/lib64/python2.7/site-packages/MySQLdb/__init__.py", line 81, in Connect
    return Connection(*args, **kwargs)
  File "/usr/lib64/python2.7/site-packages/MySQLdb/connections.py", line 193, in __init__
    super(Connection, self).__init__(*args, **kwargs2)
OperationalError: (_mysql_exceptions.OperationalError) (2002, "Can't connect to local MySQL server through socket '/var/lib/mysql/mysql.sock' (2)")
...