Apache Airflow 提供程序 Sqlite 模块未找到/错误钩子“airflow.hooks.dbapi import DbApiHook”

如何解决Apache Airflow 提供程序 Sqlite 模块未找到/错误钩子“airflow.hooks.dbapi import DbApiHook”

我对 Airflow 很陌生，并开始练习它，但目前遇到了一个损坏的 DAG，它抱怨找不到“airflow.hooks.dbapi”模块。

下面是我试图运行的代码片段。

from airflow.models import DAG
from airflow.providers.sqlite.operators.sqlite import sqliteOperator
from datetime import datetime

default_args = {
'start_date': datetime(2020,1,1)
}

with DAG('user_processing',schedule_interval='daily',default_args=default_args,catchup=False) as dag:

creating_table = sqliteOperator(
    task_id='creating_table',sqlite_conn_id='db_sqlite',sql='''
        CREATE TABLE users (
            firstname TEXT NOT NULL,lastname TEXT NOT NULL,country TEXT NOT NULL,username TEXT NOT NULL,password TEXT NOT NULL,email TEXT NOT NULL PRIMARY KEY,);
        '''
)

我从 Airflow UI 收到以下错误：

broken DAG: [/home/airflow/airflow/dags/user_processing.py] Traceback (most recent call 
last):
File "/home/airflow/sandBox/lib/python3.8/site- 
packages/airflow/providers/sqlite/operators/sqlite.py",line 21,in <module>
from airflow.providers.sqlite.hooks.sqlite import sqliteHook
File "/home/airflow/sandBox/lib/python3.8/site- 
packages/airflow/providers/sqlite/hooks/sqlite.py",in <module>
from airflow.hooks.dbapi import DbApiHook
ModuleNotFoundError: No module named 'airflow.hooks.dbapi'

所以我尝试修改导入语句如下，但仍然没有运气。

from airflow.models import DAG
from airflow.providers.sqlite.hooks.sqlite import sqliteHook
from airflow.providers.sqlite.operators.sqlite import sqliteOperator

有解决问题的想法或解决方案吗？我正在使用 Airflow 版本 = 2.0.0b3 和 python = 3.8.5。 我确实尝试过查看 here 和 here，但运气不佳。

解决方法

您正在运行 Airflow 的旧测试版，但并非所有功能都能正常运行。您不应在生产中使用测试版。

使用最新的 Airflow 稳定版 2.1.0 具体而言，您遇到的错误已在该版本中得到解决。