没有名为“ airflow.contrib.sensors.file_sensor”的模块

问题描述

我试图在气流中抽风，其中一项任务涉及文件传感器。

当我尝试运行它时：

from airflow import DAG
from datetime import datetime
from airflow.contrib.sensors.file_sensor import FileSensor
from airflow.operators.dummy_operator import DummyOperator



dag = DAG('file_sensor_dag',start_date=datetime(2017,3,20),catchup=False)
          
          
          
dummy_operator = DummyOperator(task_id='dummy_task',retries=3,dag=dag)

sensor_task = FileSensor(task_id= "file_sensor_task",poke_interval= 30,filepath= "\root\cr1.csv",dag=dag)

dummy_operator >> sensor_task

它引发以下错误

No module named 'airflow.contrib.sensors.file_sensor'

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）