要连接SQL Server,需要使用Microsoft提供的ODBC驱动程序。首先,需要下载安装Microsoft ODBC驱动程序13或17版本。然后,在Airflow中创建一个连接,以使用ODBC数据源名称(DSN)来指定SQL Server实例的名称和其他参数。
以下是一个使用pyodbc库连接SQL Server的示例代码:
import pyodbc
conn = pyodbc.connect('DSN=sqlserverdsn;UID=user;PWD=password')
cursor = conn.cursor()
# Execute a query
cursor.execute('SELECT * FROM table')
# Fetch query results
result = cursor.fetchall()
# Print results
print(result)
在此示例中,“sqlserverdsn”是作为DSN名称的ODBC连接名称。将其替换为SQL Server实例的名称。还需要用实际的用户名和密码替换“user”和“password”。