GCSCheckBlobUpdateTimeTrigger

Astronomer ProvidersCertified

A trigger that makes an async call to GCS to check whether the object is updated in a bucket.

Access Instructions

Install the Astronomer Providers provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Parameters

bucketgoogle cloud storage bucket name cloud storage where the objects are residing.
object_namethe file or folder present in the bucket
tsdatetime object
poke_intervalpolling period in seconds to check for file/folder
google_cloud_conn_idreference to the Google Connection
hook_paramsDIct object has delegate_to and impersonation_chain

Documentation

A trigger that makes an async call to GCS to check whether the object is updated in a bucket.

Was this page helpful?