mysql - 如何在本地将 Airflow 连接到 SQLite？

Question

我第一次尝试使用 Airflow，并尝试将它连接到本地 SQLite 数据库。但我似乎无法理解如何真正做到这一点。

我已经阅读了 Airflow's document , 将我的 executor 设置为 LocalExecutor 并将我的 sql_alchemy_conn 设置为 sqlite:////home/myName/Programs/sqlite3/DatabaseName.db 但它似乎不起作用，因为它抛出一个

Traceback (most recent call last):
  File "/usr/local/bin/airflow", line 21, in <module>
    from airflow import configuration
  File "/usr/local/lib/python2.7/dist-packages/airflow/__init__.py", line 35, in <module>
    from airflow import configuration as conf
  File "/usr/local/lib/python2.7/dist-packages/airflow/configuration.py", line 520, in <module>
    conf.read(AIRFLOW_CONFIG)
  File "/usr/local/lib/python2.7/dist-packages/airflow/configuration.py", line 283, in read
    self._validate()
  File "/usr/local/lib/python2.7/dist-packages/airflow/configuration.py", line 169, in _validate
    self.get('core', 'executor')))
airflow.exceptions.AirflowConfigException: error: cannot use sqlite with the LocalExecutor

当我尝试运行 airflow initdb 时出错。我试着四处搜索并尝试了 vipul sharma 的解决方案 found here并将我的 sql_alchemy_conn 的值设置为 mysql://:@localhost:3306/ 但它仍然不起作用，因为它抛出一个

sqlalchemy.exc.OperationalError: (_mysql_exceptions.OperationalError) (1045, "Access denied for user 'myName'@'localhost' (using password: NO)")

错误。我知道答案应该很简单，但我真的不知道该怎么做，所以我希望你能指导我完成做什么/阅读什么。

Answer 1

使用顺序执行器

“这个执行器一次只会运行一个任务实例，可用于调试。它也是唯一可以与 sqlite 一起使用的执行器，因为 sqlite 不支持多连接。” airflow documentation

您只是不需要更改为 LocalExecutor，将其更改回 SequentialExecutor，将 sql_alchemy_conn 更改为指向 sqlite:////home/myName/Programs/sqlite3/DatabaseName .db 并停止 Airflow 服务(网络服务器、调度程序)。

执行airflow initdb，然后再次启动服务。

希望这能奏效。