标签：minio err nil demo fmt object API Println

package main

import (
   "context"
   "fmt"
   "github.com/minio/minio-go/v7"
   "github.com/minio/minio-go/v7/pkg/credentials"
   "log"
)

func main() {
   endpoint := "127.0.0.1:9000"
   accessKeyID := "minioadmin"
   secretAccessKey := "minioadmin"
   useSSL := false
   ctx := context.Background()
   // Initialize minio client object.
   minioClient, err := minio.New(endpoint, &minio.Options{
      Creds:  credentials.NewStaticV4(accessKeyID, secretAccessKey, ""),
      Secure: useSSL,
   })
   if err != nil {
      log.Fatalln(err)
   }

   //log.Printf("%#v\n", minioClient) // minioClient is now setup
   //// Create a bucket at region 'us-east-1' with object locking enabled.
   //err = minioClient.MakeBucket(ctx, "gwx",minio.MakeBucketOptions{})
   //if err != nil {
   // fmt.Println("******************",err)
   // return
   //}
   //fmt.Println("Successfully created mybucket.")

   //buckets, err := minioClient.ListBuckets(ctx)
   //if err != nil {
   // fmt.Println(err)
   // return
   //}
   //for _, bucket := range buckets {
   // fmt.Println(bucket)
   //}


   ctx, cancel := context.WithCancel(context.Background())

   defer cancel()

   objectCh := minioClient.ListObjects(ctx, "test", minio.ListObjectsOptions{
      Prefix: "",
      Recursive: true,
   })
   var totalSize int64
   for object := range objectCh {
      if object.Err != nil {
         fmt.Println(object.Err)
         return
      }
      totalSize += object.Size
      fmt.Println(object,"******",object.Size,totalSize,object.LastModified)

   }

   //err = minioClient.RemoveBucket(context.Background(), "gwx")
   //if err != nil {
   // fmt.Println(err)
   // return
   //}



   objectsCh := make(chan minio.ObjectInfo)
   // Send object names that are needed to be removed to objectsCh
   go func() {
      defer close(objectsCh)
      // List all objects from a bucket-name with a matching prefix.
      for object := range minioClient.ListObjects(ctx, "test", minio.ListObjectsOptions{
         Prefix: "对象数据集/模拟-考试题",
         Recursive: true,
      }) {
         if object.Err != nil {
            log.Fatalln(object.Err)
         }
         fmt.Println(object)
         objectsCh <- object
      }
   }()

   opts := minio.RemoveObjectsOptions{
      GovernanceBypass: true,
   }

   for rErr := range minioClient.RemoveObjects(context.Background(), "test", objectsCh, opts) {
      fmt.Println("Error detected during deletion: ", rErr)
   }



   //file, err := os.Open("D:\\huawei-oj\\test\\work\\main.go.bk")
   //if err != nil {
   // fmt.Println(err)
   // return
   //}
   //defer file.Close()
   //
   //fileStat, err := file.Stat()
   //if err != nil {
   // fmt.Println(err)
   // return
   //}
   //
   //n, err := minioClient.PutObject(ctx, "test", "对象数据集/test.txt", file, fileStat.Size(), minio.PutObjectOptions{ContentType:"application/octet-stream"})
   //if err != nil {
   // fmt.Println(err)
   // return
   //}
   //fmt.Println("Successfully uploaded bytes: ", n)




   //objInfo, err := minioClient.StatObject(ctx,"test", "test.txt", minio.StatObjectOptions{})
   //if err != nil {
   // fmt.Println(err)
   // return
   //}
   //fmt.Println(objInfo)


   //object, err := minioClient.GetObject(ctx,"test", "test.txt", minio.GetObjectOptions{})
   //if err != nil {
   // fmt.Println(err)
   // return
   //}
   //buf := make([]byte,1024,1024)
   //object.Read(buf)
   //
   //fmt.Println(object.Read(buf))

   //func get(w http.ResponseWriter, r *http.Request) {
   // // 收到 接口服务器的 请求
   // // 提取 要获取的文件名
   // name := strings.Split(r.URL.EscapedPath(), "/")[2]
   // f, e := os.Open(objectDir + name)
   // if e != nil {
   //    log.Println(e)
   //    w.WriteHeader(http.StatusNotFound)
   //    return
   // }
   // defer f.Close()
   // // 真正读取，并发送
   // io.Copy(w, f)
   //}

   //localFile, err := os.Create("/tmp/test.txt")
   //if err != nil {
   // fmt.Println(err)
   // return
   //}
   //if _, err = io.Copy(localFile, object); err != nil {
   // fmt.Println(err)
   // return
   //}


   //opts := minio.RemoveObjectOptions{
   //}
   //
   //err = minioClient.RemoveObject(ctx,"test","对象数据集",opts)
   //if err != nil {
   // fmt.Println("********", err)
   // return
   //}
   //
   //fmt.Println("********", err)


}

标签：minio,err,nil,demo,fmt,object,API,Println
来源： https://www.cnblogs.com/gongxianjin/p/16510637.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。