Skip to content

Instantly share code, notes, and snippets.

View gist:b36d291d6b6829aa1b353b6118a50496
# Accessing a connection named "mys3bucket" from either a secrets backend or the Airflow backend:
# If using a secrets backend with connections prefix configured as:
# AIRFLOW__SECRETS__BACKEND_KWARGS={"connections_prefix":"airflow/connections"...}, this connection would be saved in
# param store as /airflow/connections/mys3bucket:
get_tagging = S3GetBucketTaggingOperator(
task_id='s3_get_bucket_tagging',
bucket_name='adam-cs-astrocloud',
aws_conn_id='mys3bucket'
)