airflow_dag_gcs_create_bucket_operator_quickstart.py

1import os
2from datetime import datetime
3
4from airflow import DAG
5from airflow.providers.google.cloud.operators.gcs import GCSCreateBucketOperator
6
7# Define the DAG
8with DAG(
9    dag_id="example_google_cloud_gcs",
10    start_date=datetime(2023, 1, 1),
11    schedule=None,
12    catchup=False,
13    tags=["example", "gcs"],
14) as dag:
15
16    # Task to create a GCS Bucket
17    create_bucket = GCSCreateBucketOperator(
18        task_id="create_bucket",
19        bucket_name="example-bucket-name-unique",
20        project_id="your-google-cloud-project-id",
21        location="US",
22    )
23
24    create_bucket