funccreateEventDrivenAWSTransfer(wio.Writer,projectIDstring,s3SourceBucketstring,gcsSinkBucketstring,sqsQueueARNstring)(*storagetransferpb.TransferJob,error){// Your Google Cloud Project ID.// projectID := "my-project-id"// The name of the source AWS S3 bucket.// s3SourceBucket := "my-source-bucket"// The name of the GCS bucket to transfer objects to.// gcsSinkBucket := "my-sink-bucket"// The Amazon Resource Name (ARN) of the AWS SNS queue to subscribe the event driven transfer to.// sqsQueueARN := "arn:aws:sqs:us-east-1:1234567891011:s3-notification-queue"// The AWS access key credential, should be accessed via environment variable for securityawsAccessKeyID:=os.Getenv("AWS_ACCESS_KEY_ID")// The AWS secret key credential, should be accessed via environment variable for securityawsSecretKey:=os.Getenv("AWS_SECRET_ACCESS_KEY")ctx:=context.Background()client,err:=storagetransfer.NewClient(ctx)iferr!=nil{returnnil,fmt.Errorf("storagetransfer.NewClient: %w",err)}deferclient.Close()req:=&storagetransferpb.CreateTransferJobRequest{TransferJob:&storagetransferpb.TransferJob{ProjectId:projectID,TransferSpec:&storagetransferpb.TransferSpec{DataSource:&storagetransferpb.TransferSpec_AwsS3DataSource{AwsS3DataSource:&storagetransferpb.AwsS3Data{BucketName:s3SourceBucket,AwsAccessKey:&storagetransferpb.AwsAccessKey{AccessKeyId:awsAccessKeyID,SecretAccessKey:awsSecretKey,}},},DataSink:&storagetransferpb.TransferSpec_GcsDataSink{GcsDataSink:&storagetransferpb.GcsData{BucketName:gcsSinkBucket}},},EventStream:&storagetransferpb.EventStream{Name:sqsQueueARN},Status:storagetransferpb.TransferJob_ENABLED,},}resp,err:=client.CreateTransferJob(ctx,req)iferr!=nil{returnnil,fmt.Errorf("failed to create transfer job: %w",err)}fmt.Fprintf(w,"Created an event driven transfer job from %v to %v subscribed to %v with name %v",s3SourceBucket,gcsSinkBucket,sqsQueueARN,resp.Name)returnresp,nil}

importcom.google.storagetransfer.v1.proto.StorageTransferServiceClient;importcom.google.storagetransfer.v1.proto.TransferProto;importcom.google.storagetransfer.v1.proto.TransferTypes;publicclassCreateEventDrivenAwsTransfer{publicstaticvoidmain(String[]args)throwsException{// Your Google Cloud Project IDStringprojectId="your-project-id";// The name of the source AWS bucket to transfer data fromStrings3SourceBucket="yourS3SourceBucket";// The name of the GCS bucket to transfer data toStringgcsSinkBucket="your-gcs-bucket";// The ARN of the SQS queue to subscribe toStringsqsQueueArn="arn:aws:sqs:us-east-1:1234567891011:s3-notification-queue";createEventDrivenAwsTransfer(projectId,s3SourceBucket,gcsSinkBucket,sqsQueueArn);}publicstaticvoidcreateEventDrivenAwsTransfer(StringprojectId,Strings3SourceBucket,StringgcsSinkBucket,StringsqsQueueArn)throwsException{// Initialize client that will be used to send requests. This client only needs to be created// once, and can be reused for multiple requests. After completing all of your requests, call// the "close" method on the client to safely clean up any remaining background resources,// or use "try-with-close" statement to do this automatically.try(StorageTransferServiceClientstorageTransfer=StorageTransferServiceClient.create()){// The ID used to access your AWS account. Should be accessed via environment variable.StringawsAccessKeyId=System.getenv("AWS_ACCESS_KEY_ID");// The Secret Key used to access your AWS account. Should be accessed via environment// variable.StringawsSecretAccessKey=System.getenv("AWS_SECRET_ACCESS_KEY");TransferTypes.TransferJobtransferJob=TransferTypes.TransferJob.newBuilder().setProjectId(projectId).setTransferSpec(TransferTypes.TransferSpec.newBuilder().setAwsS3DataSource(TransferTypes.AwsS3Data.newBuilder().setBucketName(s3SourceBucket).setAwsAccessKey(TransferTypes.AwsAccessKey.newBuilder().setAccessKeyId(awsAccessKeyId).setSecretAccessKey(awsSecretAccessKey)).build()).setGcsDataSink(TransferTypes.GcsData.newBuilder().setBucketName(gcsSinkBucket))).setStatus(TransferTypes.TransferJob.Status.ENABLED).setEventStream(TransferTypes.EventStream.newBuilder().setName(sqsQueueArn).build()).build();TransferTypes.TransferJobresponse=storageTransfer.createTransferJob(TransferProto.CreateTransferJobRequest.newBuilder().setTransferJob(transferJob).build());System.out.println("Created a transfer job from "+s3SourceBucket+" to "+gcsSinkBucket+" subscribed to "+sqsQueueArn+" with name "+response.getName());}}}

// Imports the Google Cloud client libraryconst{StorageTransferServiceClient,}=require('@google-cloud/storage-transfer');/** * TODO(developer): Uncomment the following lines before running the sample. */// The ID of the Google Cloud Platform Project that owns the job// projectId = 'my-project-id'// AWS S3 source bucket name// s3SourceBucket = 'my-s3-source-bucket'// Google Cloud Storage destination bucket name// gcsSinkBucket = 'my-gcs-destination-bucket'// The ARN of the SQS queue to subscribe to// sqsQueueArn = 'arn:aws:sqs:us-east-1:1234567891011:s3-notification-queue'// AWS Access Key ID. Should be accessed via environment variable for security.// awsAccessKeyId = 'AKIA...'// AWS Secret Access Key. Should be accessed via environment variable for security.// awsSecretAccessKey = 'HEAoMK2.../...ku8'// Creates a clientconstclient=newStorageTransferServiceClient();/** * Creates an event driven transfer that tracks an SQS queue. */asyncfunctioncreateEventDrivenAwsTransfer(){const[transferJob]=awaitclient.createTransferJob({transferJob:{projectId,status:'ENABLED',transferSpec:{awsS3DataSource:{bucketName:s3SourceBucket,awsAccessKey:{accessKeyId:awsAccessKeyId,secretAccessKey:awsSecretAccessKey,},},gcsDataSink:{bucketName:gcsSinkBucket,},},eventStream:{name:sqsQueueArn,},},});console.log(`Created an event driven transfer from '${s3SourceBucket}' to '${gcsSinkBucket}' with name${transferJob.name}`);}createEventDrivenAwsTransfer();

fromgoogle.cloudimportstorage_transferdefcreate_event_driven_aws_transfer(project_id:str,description:str,source_s3_bucket:str,sink_gcs_bucket:str,sqs_queue_arn:str,aws_access_key_id:str,aws_secret_access_key:str,):"""Create an event driven transfer between two GCS buckets that tracks an AWS SQS queue"""client=storage_transfer.StorageTransferServiceClient()# The ID of the Google Cloud Platform Project that owns the job# project_id = 'my-project-id'# A description of this job# description = 'Creates an event-driven transfer that tracks an SQS queue'# AWS S3 source bucket name# source_s3_bucket = 'my-s3-source-bucket'# Google Cloud Storage destination bucket name# sink_gcs_bucket = 'my-gcs-destination-bucket'# The ARN of the SQS queue to subscribe to# pubsub_id = 'arn:aws:sqs:us-east-1:1234567891011:s3-notification-queue'# AWS Access Key ID. Should be accessed via environment variable for security purposes.# aws_access_key_id = 'AKIA...'# AWS Secret Access Key. Should be accessed via environment variable for security purposes.# aws_secret_access_key = 'HEAoMK2.../...ku8'transfer_job_request=storage_transfer.CreateTransferJobRequest({"transfer_job":{"project_id":project_id,"description":description,"status":storage_transfer.TransferJob.Status.ENABLED,"transfer_spec":{"aws_s3_data_source":{"bucket_name":source_s3_bucket,"aws_access_key":{"access_key_id":aws_access_key_id,"secret_access_key":aws_secret_access_key,},},"gcs_data_sink":{"bucket_name":sink_gcs_bucket,},},"event_stream":{"name":sqs_queue_arn,},},})result=client.create_transfer_job(transfer_job_request)print(f"Created transferJob:{result.name}")