cicv_data_closed_loop/amd64/dispatch_server/package/infra/i_oss.go

package infra

import (
	"cicv-data-closedloop/common/config/c_log"
	"fmt"
	"github.com/aliyun/aliyun-oss-go-sdk/oss"
	"os"
)

var (
	OssClient *oss.Client
	OssBucket *oss.Bucket
)

func InitOss(isUseCname bool, endpoint string, accessKeyId string, accessKeySecret string, bucketName string) {
	var err error
	if isUseCname {
		OssClient, err = oss.New(endpoint, accessKeyId, accessKeySecret, oss.UseCname(true)) // 公网
	} else {
		OssClient, err = oss.New(endpoint, accessKeyId, accessKeySecret, oss.UseCname(false)) // 内网
	}
	if err != nil {
		c_log.GlobalLogger.Error("无法创建阿里云client:", err)
		os.Exit(-1)
	}
	OssBucket, err = OssClient.Bucket(bucketName)
	if err != nil {
		fmt.Println("无法创建阿里云bucket:", err)
		os.Exit(-1)
	}
}