我最近從 Airflow 1.10.15 升級到了 2.2.4。使用 sudo 安裝。升級后升級資料庫。Airflow 正在運行,但存在匯入錯誤。
我有多個 DAG,from airflow.operators.mssql_operator import MsSqlOperator但是一旦調度程式和網路服務器啟動,我就會收到以下錯誤:
Broken DAG: [/opt/airflow/dags/admissions.py] Traceback (most recent call last):
File "/opt/airflow/dags/admissions.py", line 7, in <module>
from airflow.operators.mssql_operator import MsSqlOperator
File "/usr/local/lib/python3.6/dist-packages/airflow/operators/mssql_operator.py", line 22, in <module>
from airflow.providers.microsoft.mssql.operators.mssql import MsSqlOperator # noqa
ModuleNotFoundError: No module named 'airflow.providers.microsoft.mssql.operators'
有關提供者的其他資訊:
apache-airflow-providers-ftp | 2.1.0
apache-airflow-providers-http | 2.1.0
apache-airflow-providers-imap | 2.2.1
apache-airflow-providers-microsoft-mssql | 2.1.1
apache-airflow-providers-odbc | 2.0.2
apache-airflow-providers-sqlite | 2.1.1
我該如何解決這個問題?
uj5u.com熱心網友回復:
看來您確實擁有正確的提供程式包 ( apache-airflow-providers-microsoft-mssql)
但是,您使用的是“舊形式”匯入而不是新形式
請嘗試更改
from airflow.operators.mssql_operator import MsSqlOperator
為
from airflow.providers.microsoft.mssql.operators.mssql import MsSqlOperator
API參考和小教程的一些鏈接:
https ://airflow.apache.org/docs/apache-airflow-providers-microsoft-mssql/stable/_api/airflow/providers/microsoft/mssql/operators/mssql/index.html #module-airflow.providers.microsoft.mssql.operators.mssql
https://airflow.apache.org/docs/apache-airflow-providers-microsoft-mssql/stable/operators.html#howto-operator-mssqloperator
轉載請註明出處,本文鏈接:https://www.uj5u.com/qukuanlian/452423.html
上一篇:更改char資料型別的日期格式
下一篇:SQLCount列剩余為1
