SFTP Sensor Async¶
Checks for the existence of a file on an SFTP server
SFTPSensorAsync
.
async_sftp_sensor = SFTPSensorAsync(
task_id="async_sftp_sensor",
sftp_conn_id=SFTP_CONN_ID,
path="/home/ubuntu/",
file_pattern="*.csv",
poke_interval=5,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/sftp/example_dags/example_sftp.py