Created
August 1, 2018 09:56
-
-
Save ruseel/df5f8cf1adb1ff928bbc839a8d057db6 to your computer and use it in GitHub Desktop.
scala - google storage transfer job create
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
# | |
# service-account can call Google StorageTransfer API. | |
# | |
import scala.collection.JavaConversions._ | |
val c = createStorageTransferClient | |
val j = new TransferJob() | |
.setProjectId("projec-id-a") | |
.setDescription("dsec ...") | |
.setSchedule(new Schedule() | |
.setScheduleStartDate( | |
new Date().setYear(2018).setMonth(8).setDay(1) | |
) | |
.setScheduleEndDate( | |
new Date().setYear(2018).setMonth(8).setDay(1) | |
)) | |
.setStatus("ENABLED") | |
.setTransferSpec( | |
new TransferSpec() | |
.setAwsS3DataSource( | |
new AwsS3Data() | |
.setBucketName("aws-bucket-name") | |
.setAwsAccessKey( | |
new AwsAccessKey() | |
.setAccessKeyId("ACCESS_KEY_ID__SHOUD_BE_REPLACED") | |
.setSecretAccessKey("SECRET_ACCESS_KEY_ID__SHOUD_BE_REPLACED"))) | |
.setObjectConditions( | |
new ObjectConditions() | |
.setIncludePrefixes(List("test-r1/")) | |
) | |
.setGcsDataSink( | |
new GcsData() | |
.setBucketName("gcs-bucket-name") | |
)) | |
val res = c.transferJobs().create(j).execute() |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment