python-3.x - 如何在 AWS MWAA Airflow DAG 上获得 pyodbc 连接？

Question

我尝试将requirements.txt放入MWAA Airflowwithpyodbc=4.0.30和代码中，使连接字符串像

dbconnection = pyodbc.connect("Driver={ODBC Driver 17 for SQL Server};Server="+Server+";Database="+Database+";UID="+UserID+";PWD="+Password, autocommit=True)

现在的错误是Broken DAG: [/usr/local/airflow/dags/test.py] No module named 'pyodbc'

气流版本：1.10.12

几乎没有任何关于SQL Server/ Postgres基于文档的连接的MWAA AWS文档，特别是对于pyodbc连接，我之前遇到了这个问题并用 解决了这个问题lambda functions，lambda layers但不确定如何MWAA工作，任何建议表示赞赏。

请不要推荐任何其他技术，如 EC2 来托管 Airflow，因为该公司非常严格地使用 MWAA Airflow。

Answer 1

import pymssql

conn = pymssql.connect(
            server=server,
            user=username,
            password=password,
            database=database
        )
query ="select IDpk,name,Remarks from TestTable"
df = pd.read_sql(query,conn)