google_cloud_storage_transfer_service_one_time_bucket_job.py

1from google.cloud import storage_transfer
2
3def create_transfer_job(project_id, description, source_bucket, sink_bucket):
4    """Creates a one-time transfer job."""
5    client = storage_transfer.StorageTransferServiceClient()
6
7    transfer_job = {
8        "project_id": project_id,
9        "description": description,
10        "status": storage_transfer.TransferJob.Status.ENABLED,
11        "transfer_spec": {
12            "gcs_data_source": {
13                "bucket_name": source_bucket,
14            },
15            "gcs_data_sink": {
16                "bucket_name": sink_bucket,
17            },
18        },
19    }
20
21    result = client.create_transfer_job({"transfer_job": transfer_job})
22    print(f"Created transferJob: {result.name}")
23
24if __name__ == "__main__":
25    # TODO: Replace with your project ID and bucket names
26    PROJECT_ID = "your-project-id"
27    DESCRIPTION = "Quickstart transfer job"
28    SOURCE_BUCKET = "your-source-bucket"
29    SINK_BUCKET = "your-destination-bucket"
30
31    create_transfer_job(PROJECT_ID, DESCRIPTION, SOURCE_BUCKET, SINK_BUCKET)