prefect_gcp_gcs_bucket_file_upload_quickstart.py

1from prefect import flow
2from prefect_gcp.cloud_storage import GcsBucket
3
4@flow
5def upload_to_gcs_flow():
6    # Load the GcsBucket block that contains your credentials and bucket info
7    # Note: You must first create this block via the Prefect UI or CLI
8    gcs_bucket_block = GcsBucket.load("my-gcs-bucket")
9    
10    # Upload a file to the specified GCS bucket
11    gcs_bucket_block.upload_from_path(from_path="local_file.txt", to_path="remote_file.txt")
12
13if __name__ == "__main__":
14    upload_to_gcs_flow()