hook - 气流的 MSSQL 钩子

Question

我正在尝试使用 Airflow Hooks 连接到 Mssql 服务器，但向我抛出了以下错误：

Broken DAG: [/usr/local/airflow/dags/odoo_customer_sql.py] No module named 'pymssql'

我的代码是：

hook = MsSqlHook(mssql_conn_id='ofo_sql_server')
conn = hook.get_conn()
return conn

PS：我正在使用 Docker 容器，其中包括：

 webserver:
    image: puckel/docker-airflow:1.10.1
    build:
      context: https://github.com/puckel/docker-airflow.git#1.10.1
      dockerfile: Dockerfile
      args:
        AIRFLOW_DEPS: gcp_api,s3, mssql, pyodbc
        PYTHON_DEPS: sqlalchemy==1.2.0, pyodbc == 4.0.27, pymssql == 2.1.3

标签： hookairflowpymssql

Answer 1

• 打开泊坞窗仪表板
• 打开 apache 气流 CLI（命令行界面）
• pip install pymssql --upgrade
• 重启网络服务器
• 刷新浏览器

这应该可以解决问题。