我第一次尝试使用airflow,并尝试将其连接到本地sqlite数据库。但我似乎不知道该怎么做。
我读了airflow的文件 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
. 我试着到处搜索,试着VipulSharma在这里找到的解决方案,并设置我的 sql_alchemy_conn
至 mysql://:@localhost:3306/
但当它抛出一个
sqlalchemy.exc.OperationalError: (_mysql_exceptions.OperationalError) (1045, "Access denied for user 'myName'@'localhost' (using password: NO)")
错误。我知道答案应该很简单,但我真的不明白怎么做,所以我希望你能指导我做什么/读什么。
1条答案
按热度按时间piztneat1#
使用顺序执行器
“此执行器一次只运行一个任务示例,可用于调试。它也是唯一可以与sqlite一起使用的执行器,因为sqlite不支持多个连接
你不需要改成localexecutor,改回sequentialexecutor,再改
sql_alchemy_conn
指向sqlite:////home/myName/Programs/sqlite3/DatabaseName.db
并停止气流服务(Web服务器、调度程序)。执行
airflow initdb
然后再次启动服务。希望能成功。