气流的 MSSQL 钩子

Posted 2023-05-08

【中文标题】气流的 MSSQL 钩子

【英文标题】：MSSQL hook for the Airflow

【发布时间】：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

【参考方案1】：

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

这应该可以解决问题。