没有名为“airflow.contrib.sensors.file\u sensor”的模块

Question

我尝试在气流中运行dag，其中一项任务涉及文件传感器

当我尝试运行它时：

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'