obs.go 1.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354
  1. package file_store
  2. //
  3. //import (
  4. // "fmt"
  5. // "log"
  6. //
  7. // "github.com/huaweicloud/huaweicloud-sdk-go-obs/obs"
  8. //)
  9. //
  10. //type HuaWeiOBS struct {
  11. // Client interface{}
  12. // BucketName string
  13. //}
  14. //
  15. //func (e *HuaWeiOBS) Setup(endpoint, accessKeyID, accessKeySecret, BucketName string, options ...ClientOption) error {
  16. // // 创建ObsClient结构体
  17. // client, err := obs.New(accessKeyID, accessKeySecret, endpoint)
  18. // if err != nil {
  19. // log.Println("Error:", err)
  20. // return err
  21. // }
  22. // e.Client = client
  23. // e.BucketName = BucketName
  24. // return nil
  25. //}
  26. //
  27. //// UpLoad 文件上传
  28. //// yourObjectName 文件路径名称,与objectKey是同一概念,表示断点续传上传文件到OSS时需要指定包含文件后缀在内的完整路径,例如abc/efg/123.jpg
  29. //func (e *HuaWeiOBS) UpLoad(yourObjectName string, localFile interface{}) error {
  30. // // 获取存储空间。
  31. // input := &obs.PutFileInput{}
  32. // input.Bucket = e.BucketName
  33. // input.Key = yourObjectName
  34. // input.SourceFile = localFile.(string)
  35. // output, err := e.Client.(*obs.ObsClient).PutFile(input)
  36. //
  37. // if err == nil {
  38. // fmt.Printf("RequestId:%s\n", output.RequestId)
  39. // fmt.Printf("ETag:%s, StorageClass:%s\n", output.ETag, output.StorageClass)
  40. // } else {
  41. // if obsError, ok := err.(obs.ObsError); ok {
  42. // fmt.Println(obsError.Code)
  43. // fmt.Println(obsError.Message)
  44. // } else {
  45. // fmt.Println(err)
  46. // }
  47. // }
  48. // return nil
  49. //}
  50. //
  51. //func (e *HuaWeiOBS) GetTempToken() (string, error) {
  52. // return "", nil
  53. //}