1. 首先，确保已安装所需的依赖（例如 pymssql 和 numpy ）。
2. 确保已正确配置 Airflow 的连接，可以在 DAG 中使用 MSSQL 连接。示例：

from airflow import DAG from airflow.operators.python_operator import PythonOperator from airflow.hooks.mssql_hook import MsSqlHook

def query_mssql(): mssql_hook = MsSqlHook(mssql_conn_id='my_mssql_conn') connection = mssql_hook.get_conn() cursor = connection.cursor() cursor.execute("SELECT * FROM my_table") results = cursor.fetchall() print(results)

dag = DAG('mssql_dag', description='MSSQL query DAG') run_this = PythonOperator( task_id='query_mssql_task', python_callable=query_mssql, dag=dag)

3. 如果还是无法导入 MS SQL Hook 和操作符，则可能需要手动安装 pymssql 或修复依赖问题。