小编gcl*_*jr5的帖子

我对 Airflow 很陌生。我已经多次通读文档，在网上阅读了许多 S/O 问题和许多随机文章，但尚未解决此问题。我有一种感觉，我做错了一些非常简单的事情。我有适用于 Windows 的 Docker，我拉取了puckel/docker-airflow映像并运行了一个暴露端口的容器，这样我就可以从我的主机访问 UI。我有另一个容器在运行mcr.microsoft.com/mssql/server，我在其中恢复了 WideWorldImporters 示例数据库。从 Airflow UI，我已经能够成功地创建到这个数据库的连接，甚至可以从数据分析部分查询它。检查下面的图像： 连接创建 成功查询到连接

因此，虽然这有效，但我的 dag 在第二个任务中失败了sqlData。这是代码：

from airflow.models import DAG
from airflow.operators.bash_operator import BashOperator
from airflow.operators.python_operator import PythonOperator
from airflow.operators.mssql_operator import MsSqlOperator
from datetime import timedelta, datetime

copyData = DAG(
    dag_id='copyData',
    schedule_interval='@once',
    start_date=datetime(2019,1,1)
)


printHelloBash = BashOperator(
    task_id = "print_hello_Bash",
    bash_command = 'echo "Lets copy some data"',
    dag = copyData
)

mssqlConnection = "WWI"
sqlData = MsSqlOperator(sql="select top 100 InvoiceDate, TotalDryItems from …