的步骤如下:
version: '3'
services:
airflow:
image: puckel/docker-airflow
ports:
- "8080:8080"
environment:
- LOAD_EX=n
- EXECUTOR=Local
volumes:
- ./dags:/usr/local/airflow/dags
- ./logs:/usr/local/airflow/logs
- ./plugins:/usr/local/airflow/plugins
这个配置文件使用了puckel/docker-airflow镜像,该镜像已经预装了Airflow和相关依赖。
pymssql
这个文件用于指定Airflow所需的依赖包。
docker-compose up -d
这个命令会下载所需的镜像,并创建并启动Airflow容器。
http://localhost:8080
,即可进入Airflow的Web界面。import pymssql
conn = pymssql.connect(server='localhost', user='username', password='password', database='dbname')
cursor = conn.cursor()
# 执行SQL查询
cursor.execute('SELECT * FROM table')
# 获取查询结果
result = cursor.fetchall()
# 处理查询结果
for row in result:
print(row)
# 关闭连接
conn.close()
在这个示例中,需要将localhost
替换为MSSQL服务器的地址,username
和password
替换为登录MSSQL服务器的用户名和密码,dbname
替换为要连接的数据库名称。
以上就是使用Docker从Apache Airflow连接到本地MSSQL服务器的步骤。在实际应用中,可以根据具体需求进行配置和调整。
领取专属 10元无门槛券
手把手带您无忧上云