prefect_gcp_quickstart_upload_string_to_gcs_bucket.py

1from prefect import flow
2from prefect_gcp import GcpCredentials
3from prefect_gcp.cloud_storage import GcsBucket
4
5@flow
6def example_gcs_flow():
7    # To use a pre-defined block, you can load it by name
8    # gcp_credentials_block = GcpCredentials.load("my-gcp-creds")
9    
10    # Or, define credentials inline (for demonstration)
11    gcp_credentials_block = GcpCredentials(
12        service_account_info={
13            "type": "service_account",
14            "project_id": "your-project-id",
15            # ... other service account fields
16        }
17    )
18
19    gcs_bucket = GcsBucket(
20        bucket_name="my-bucket-name",
21        gcp_credentials=gcp_credentials_block
22    )
23    
24    # Upload data to the bucket
25    gcs_bucket.upload_from_content(
26        content="Hello from Prefect!",
27        blob_path="prefect_quickstart.txt"
28    )
29
30if __name__ == "__main__":
31    example_gcs_flow()