airflow.contrib.operators.gcs_delete_operator

Module Contents

class airflow.contrib.operators.gcs_delete_operator.GoogleCloudStorageDeleteOperator(bucket_name, objects=None, prefix=None, google_cloud_storage_conn_id='google_cloud_default', delegate_to=None, *args, **kwargs)[source]

Bases: airflow.models.BaseOperator

Deletes objects from a Google Cloud Storage bucket, either from an explicit list of object names or all objects matching a prefix.

Parameters

  • bucket_name (str) – The GCS bucket to delete from

  • objects (List[str]) – List of objects to delete. These should be the names of objects in the bucket, not including gs://bucket/

  • prefix – Prefix of objects to delete. All objects matching this prefix in the bucket will be deleted.

  • google_cloud_storage_conn_id (str) – The connection ID to use for Google Cloud Storage

  • delegate_to (str) – The account to impersonate, if any. For this to work, the service account making the request must have domain-wide delegation enabled.

template_fields = ['bucket_name', 'prefix', 'objects'][source]
execute(self, context)[source]