copy_object.go 2.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889
  1. package sample
  2. import (
  3. "fmt"
  4. "github.com/aliyun/aliyun-oss-go-sdk/oss"
  5. )
  6. // CopyObjectSample Copy Object Sample
  7. func CopyObjectSample() {
  8. // 创建Bucket
  9. bucket, err := GetTestBucket(bucketName)
  10. if err != nil {
  11. HandleError(err)
  12. }
  13. // 创建一个Object
  14. err = bucket.PutObjectFromFile(objectKey, localFile)
  15. if err != nil {
  16. HandleError(err)
  17. }
  18. // 场景1:把已经存在的对象copy成一个新对象
  19. var descObjectKey = "descobject"
  20. _, err = bucket.CopyObject(objectKey, descObjectKey)
  21. if err != nil {
  22. HandleError(err)
  23. }
  24. // 场景2:把已经存在的对象copy成一个新对象,目标对象存在时,会覆盖
  25. _, err = bucket.CopyObject(objectKey, descObjectKey)
  26. if err != nil {
  27. HandleError(err)
  28. }
  29. err = bucket.DeleteObject(descObjectKey)
  30. if err != nil {
  31. HandleError(err)
  32. }
  33. // 场景3:对象copy时对源对象执行约束条件,满足时候copy,不满足时返回错误,不执行copy
  34. // 约束条件不满足,copy没有执行
  35. _, err = bucket.CopyObject(objectKey, descObjectKey, oss.CopySourceIfModifiedSince(futureDate))
  36. if err == nil {
  37. HandleError(err)
  38. }
  39. fmt.Println("CopyObjectError:", err)
  40. // 约束条件满足,copy执行
  41. _, err = bucket.CopyObject(objectKey, descObjectKey, oss.CopySourceIfUnmodifiedSince(futureDate))
  42. if err != nil {
  43. HandleError(err)
  44. }
  45. // 场景4:对象copy时,可以指定目标对象的Properties,同时一定要指定MetadataDirective为MetaReplace
  46. options := []oss.Option{
  47. oss.Expires(futureDate),
  48. oss.Meta("myprop", "mypropval"),
  49. oss.MetadataDirective(oss.MetaReplace)}
  50. _, err = bucket.CopyObject(objectKey, descObjectKey, options...)
  51. if err != nil {
  52. HandleError(err)
  53. }
  54. meta, err := bucket.GetObjectDetailedMeta(descObjectKey)
  55. if err != nil {
  56. HandleError(err)
  57. }
  58. fmt.Println("meta:", meta)
  59. // 场景5:当源对象和目标对象相同时,目的是用来修改源对象的meta
  60. options = []oss.Option{
  61. oss.Expires(futureDate),
  62. oss.Meta("myprop", "mypropval"),
  63. oss.MetadataDirective(oss.MetaReplace)}
  64. _, err = bucket.CopyObject(objectKey, objectKey, options...)
  65. if err != nil {
  66. HandleError(err)
  67. }
  68. fmt.Println("meta:", meta)
  69. // 删除object和bucket
  70. err = DeleteTestBucketAndObject(bucketName)
  71. if err != nil {
  72. HandleError(err)
  73. }
  74. fmt.Println("CopyObjectSample completed")
  75. }