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")

此外，對於此作業，你可以在可延遲模式下使用 Sensor

airflow/example_dags/example_sensors.py

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