FileSensor¶

使用 FileSensor 来检测本地文件系统中出现的文件。您需要定义一个连接才能使用它（通过 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
)