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

Question

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

我已经阅读了Airflow 的文档，Set my executortoLocalExecutor和 set my sql_alchemy_conntosqlite:////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 的解决方案并将 my 的值设置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不支持多连接。” 气流文档

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

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

希望这有效。