小编Anm*_*rki的帖子

气流文件传感器,用于检测本地驱动器上的文件

有没有人对FileSensor有任何想法?我在研究本地目录中的传感文件时遇到了它.代码如下:

  task= FileSensor(
    task_id="senseFile"
    filepath="etc/hosts",
    fs_conn_id='fs_local',
   _hook=self.hook,
    dag=self.dag,)
Run Code Online (Sandbox Code Playgroud)

我还将我的conn_id和conn类型设置为File(path)并给出{'path':'mypath'}但是即使我设置了一个非现有路径,或者如果文件不在指定路径中,则任务完成而dag是成功的.FileSensor似乎根本无法感知文件.

airflow

6
推荐指数
1
解决办法
6980
查看次数

标签 统计

airflow ×1