如何在AWS MWAA风流DAG上实现pyodbc连接？

Question

我尝试在requirements.txt for MWAA Airflow中添加pyodbc=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主机气流，因为公司是非常严格的使用MWAA气流。

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)