Golang实现Amazon S3兼容云存储操作的插件库minio-go的使用

简介

MinIO Go Client SDK提供了简单的API来访问任何兼容Amazon S3的对象存储服务。本指南将介绍如何安装MinIO客户端SDK、连接到MinIO以及创建一个示例文件上传程序。

安装

从项目目录执行以下命令安装minio-go库：

go get github.com/minio/minio-go/v7

初始化MinIO客户端对象

MinIO客户端需要以下参数来连接到Amazon S3兼容的对象存储：

package main

import (
	"log"

	"github.com/minio/minio-go/v7"
	"github.com/minio/minio-go/v7/pkg/credentials"
)

func main() {
	endpoint := "play.min.io"
	accessKeyID := "Q3AM3UQ867SPQQA43P2F"
	secretAccessKey := "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG"
	useSSL := true

	// 初始化minio客户端对象
	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现在已设置好
}

示例 - 文件上传器

这个示例代码连接到对象存储服务器，创建一个存储桶，并上传一个文件到该存储桶。它使用MinIO的play服务器，这是一个位于play.min.io的公共MinIO集群。

play服务器运行最新稳定版本的MinIO，可用于测试和开发。此示例中显示的访问凭证是公开的，上传到play的所有数据都应视为公开且不受保护。

FileUploader.go

这个示例执行以下操作：

• 使用提供的凭证连接到MinIO play服务器
• 创建一个名为testbucket的存储桶
• 从/tmp上传一个名为testdata的文件
• 使用mc ls验证文件是否已创建

// FileUploader.go MinIO示例
package main

import (
	"context"
	"log"

	"github.com/minio/minio-go/v7"
	"github.com/minio/minio-go/v7/pkg/credentials"
)

func main() {
	ctx := context.Background()
	endpoint := "play.min.io"
	accessKeyID := "Q3AM3UQ867SPQQA43P2F"
	secretAccessKey := "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG"
	useSSL := true

	// 初始化minio客户端对象
	minioClient, err := minio.New(endpoint, &minio.Options{
		Creds:  credentials.NewStaticV4(accessKeyID, secretAccessKey, ""),
		Secure: useSSL,
	})
	if err != nil {
		log.Fatalln(err)
	}

	// 创建一个名为testbucket的新存储桶
	bucketName := "testbucket"
	location := "us-east-1"

	err = minioClient.MakeBucket(ctx, bucketName, minio.MakeBucketOptions{Region: location})
	if err != nil {
		// 检查是否已经拥有这个存储桶（如果运行两次会发生这种情况）
		exists, errBucketExists := minioClient.BucketExists(ctx, bucketName)
		if errBucketExists == nil && exists {
			log.Printf("We already own %s\n", bucketName)
		} else {
			log.Fatalln(err)
		}
	} else {
		log.Printf("Successfully created %s\n", bucketName)
	}

	// 上传测试文件
	// 如果文件在另一个位置，请更改filePath的值
	objectName := "testdata"
	filePath := "/tmp/testdata"
	contentType := "application/octet-stream"

	// 使用FPutObject上传测试文件
	info, err := minioClient.FPutObject(ctx, bucketName, objectName, filePath, minio.PutObjectOptions{ContentType: contentType})
	if err != nil {
		log.Fatalln(err)
	}

	log.Printf("Successfully uploaded %s of size %d\n", objectName, info.Size)
}

1. 创建一个包含数据的测试文件

在Linux或macOS系统上可以使用dd命令：

dd if=/dev/urandom of=/tmp/testdata bs=2048 count=10

或者在Windows上使用fsutil：

fsutil file createnew "C:\Users\<username>\Desktop\sample.txt" 20480

2. 使用以下命令运行FileUploader：

go mod init example/FileUploader
go get github.com/minio/minio-go/v7
go get github.com/minio/minio-go/v7/pkg/credentials
go run FileUploader.go

输出类似于：

2023/11/01 14:27:55 Successfully created testbucket
2023/11/01 14:27:55 Successfully uploaded testdata of size 20480

3. 使用mc ls验证上传的文件：

mc ls play/testbucket
[2023-11-01 14:27:55 UTC]  20KiB STANDARD TestDataFile

API参考

完整的API参考可在此处找到。

API参考：存储桶操作

• MakeBucket
• ListBuckets
• BucketExists
• RemoveBucket
• ListObjects
• ListIncompleteUploads

API参考：存储桶策略操作

• SetBucketPolicy
• GetBucketPolicy

API参考：存储桶通知操作

• SetBucketNotification
• GetBucketNotification
• RemoveAllBucketNotification
• ListenBucketNotification (MinIO扩展)
• ListenNotification (MinIO扩展)

API参考：文件对象操作

• FPutObject
• FGetObject

API参考：对象操作

• GetObject
• PutObject
• PutObjectStreaming
• StatObject
• CopyObject
• RemoveObject
• RemoveObjects
• RemoveIncompleteUpload
• SelectObjectContent

API参考：预签名操作

• PresignedGetObject
• PresignedPutObject
• PresignedHeadObject
• PresignedPostPolicy

API参考：客户端自定义设置

• SetAppInfo
• TraceOn
• TraceOff

完整示例

完整示例：存储桶操作

• makebucket.go
• listbuckets.go
• bucketexists.go
• removebucket.go
• listobjects.go
• listobjectsV2.go
• listincompleteuploads.go

完整示例：存储桶策略操作

• setbucketpolicy.go
• getbucketpolicy.go
• listbucketpolicies.go

完整示例：存储桶生命周期操作

• setbucketlifecycle.go
• getbucketlifecycle.go

完整示例：存储桶加密操作

• setbucketencryption.go
• getbucketencryption.go
• removebucketencryption.go

完整示例：存储桶复制操作

• setbucketreplication.go
• getbucketreplication.go
• removebucketreplication.go

完整示例：存储桶通知操作

• setbucketnotification.go
• getbucketnotification.go
• removeallbucketnotification.go
• listenbucketnotification.go (MinIO扩展)
• listennotification.go (MinIO扩展)

完整示例：文件对象操作

• fputobject.go
• fgetobject.go

完整示例：对象操作

• putobject.go
• getobject.go
• statobject.go
• copyobject.go
• removeobject.go
• removeincompleteupload.go
• removeobjects.go

完整示例：加密对象操作

• put-encrypted-object.go
• get-encrypted-object.go
• fput-encrypted-object.go

完整示例：预签名操作

• presignedgetobject.go
• presignedputobject.go
• presignedheadobject.go
• presignedpostpolicy.go

许可证

此SDK根据Apache License, Version 2.0分发。