python - 没有名为“airflow.contrib.sensors.file_sensor”的模块
问题描述
我试图在气流中运行 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'
解决方案
推荐阅读
- angular - 选择元素的双向绑定无法正常工作 | 角 11
- matlab - 将矩阵中的垂直向量的值分配给 MATLAB r2019b 中的变量
- twitter-bootstrap - bootstrap 3.4.1 和 4.0.0 中元素的对齐外观和感觉不同
- javascript - 从 WebDataRocks “时间” JSON 类型中删除 :ss 部分
- javascript - 我想修复单击菜单按钮的问题
- sql - oracle sql中的条件COUNT(1)= 1是什么意思
- c++ - 数组的静态与动态内存分配
- delphi - 从 Delphi 中提取 TWebBrowser 中的 iframe 内容
- python - 如何以正确的方式为独立的 python 应用程序制作 setup.py?
- jquery - 主页活动类无法删除