GCSPrefixBlobTrigger

Astronomer ProvidersCertified

A trigger that fires and it looks for all the objects in the given bucket which matches the given prefix if not found sleep for certain interval and checks again.

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

bucketthe bucket in the google cloud storage where the objects are residing.
prefixThe prefix of the blob_names to match in the Google cloud storage bucket
google_cloud_conn_idreference to the Google Connection
poke_intervalpolling period in seconds to check

Documentation

A trigger that fires and it looks for all the objects in the given bucket which matches the given prefix if not found sleep for certain interval and checks again.

Was this page helpful?