FileSensor¶

使用 FileSensor 检测本地文件系统中出现的 file。您需要定义连接才能使用它（通过 fs_conn_id 传递连接 ID）。默认连接是 fs_default。

airflow/example_dags/example_sensors.py[源代码]

t6 = FileSensor(task_id="wait_for_file", filepath="/tmp/temporary_file_for_testing")

此外，对于此作业，您可以在可延迟模式下使用传感器

airflow/example_dags/example_sensors.py[源代码]

t7 = FileSensor(
    task_id="wait_for_file_async", filepath="/tmp/temporary_file_for_testing", deferrable=True
)