toolbar/osssync/sync/oss.go

   1 package sync
   2
   3 import (
   4         "bytes"
   5         "io/ioutil"
   6
   7         "github.com/aliyun/aliyun-oss-go-sdk/oss"
   8 )
   9
  10 // PutObjByteArr upload Byte Array object
  11 func (s *Sync) PutObjByteArr(objectName string, objectValue []byte) error {
  12         objectAcl := oss.ObjectACL(oss.ACLPublicRead)
  13         return s.OssBucket.PutObject(objectName, bytes.NewReader(objectValue), objectAcl)
  14 }
  15
  16 // GetObjToData download object to stream
  17 func (s *Sync) GetObjToData(objectName string) ([]byte, error) {
  18         body, err := s.OssBucket.GetObject(objectName)
  19         if err != nil {
  20                 return nil, err
  21         }
  22
  23         defer body.Close()
  24
  25         data, err := ioutil.ReadAll(body)
  26         if err != nil {
  27                 return nil, err
  28         }
  29
  30         return data, err
  31 }