Airflow DAG 未能触发

Question

我最近刚开始使用 Airflow，在写了一个简单的 DAG 到 t运行sfer 数据从 sftp 服务器到 s3 之后，我运行在触发 DAG 时遇到了这个错误：AttributeError: 'NoneType' 对象没有属性 'create_dagrun'。有人对此有经验吗？非常感谢

with dag:
 # test ssh connection
t1 = SFTPOperator( task_id='download_file_from_sftp',
ssh_conn_id='sendeffect_evania',
local_filepath="/tmp/test.csv",
remote_filepath='sftp://evania@11335-04.root.nessus.at/files/download/evania_daily_bounce.csv',
operation='get' )

Answer 1

根据您分享的内容，我认为您没有使用正确的语法来编写 DAG。尝试使用以下内容：

import datetime as datetime
from airflow.models import DAG
with DAG('my_dag', start_date=datetime(2016, 1, 1)) as dag:
    (
         t1 = SFTPOperator( task_id='download_file_from_sftp',
         ssh_conn_id='sendeffect_evania',
         local_filepath="/tmp/test.csv",
         remote_filepath='sftp://evania@11335-04.root.nessus.at/files/download/evania_daily_bounce.csv',
         operation='get' )
    )

Airflow DAG 未能触发

Airflow DAGs failed to be triggered

directed-acyclic-graphs

airflow