气流的 MSSQL 钩子答案

【问题标题】：MSSQL hook for the Airflow气流的 MSSQL 钩子
【发布时间】：2019-11-25 13:34:58
【问题描述】：

我正在尝试使用 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

P.S：我正在使用 Docker Container，其中包括：

 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

【问题讨论】：

标签： hook airflow pymssql

【解决方案1】：

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

这应该可以解决问题。

【讨论】：