で動作するように風量を設定する:は、私はこのようなCeleryExecutorを使うにAirbnbの空気の流れを設定しようCeleryExecutor
# The executor class that airflow should use. Choices include
# SequentialExecutor, LocalExecutor, CeleryExecutor
executor = CeleryExecutor
しかし、私は得る:
私はSequentialExecutor
からCeleryExecutor
にairflow.cfgでexecuter
を変更しました次のエラー:
airflow.configuration.AirflowConfigException: error: cannot use sqlite with the CeleryExecutor
注sql_alchemy_conn
は次のように設定されていること:
sql_alchemy_conn = sqlite:////root/airflow/airflow.db
私はエアフローのGIT(https://github.com/airbnb/airflow/blob/master/airflow/configuration.py)
を見て、次のコードは、この例外をスローすることがわかった:
def _validate(self):
if (
self.get("core", "executor") != 'SequentialExecutor' and
"sqlite" in self.get('core', 'sql_alchemy_conn')):
raise AirflowConfigException("error: cannot use sqlite with the {}".
format(self.get('core', 'executor')))
それはsql_alchemy_conn
がsqlite
を含めることはできません。このvalidate
方法かららしいです。
CeleryExecutor
をsqlliteなしで設定する方法はありますか?必要に応じてCeleryExecuterを操作するためのrabitMQをダウンロードしたことに注意してください。
postgresqlの代わりにmysql接続を追加する方法 – abhijeetmote
@abhijeetmote sqlalchemyのmsql接続文字列は、mysql:// username:password @ hostname:port/database_name'のようにすることができます。 – nehiljain