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
)