Go日志轉(zhuǎn)存
訪問OSS的過程中會(huì)產(chǎn)生大量的訪問日志。您可以通過日志轉(zhuǎn)存功能將這些日志按照固定命名規(guī)則,以小時(shí)為單位生成日志文件寫入您指定的存儲(chǔ)空間(Bucket)。
注意事項(xiàng)
本文示例代碼以華東1(杭州)的地域ID
cn-hangzhou
為例,默認(rèn)使用外網(wǎng)Endpoint,如果您希望通過與OSS同地域的其他阿里云產(chǎn)品訪問OSS,請使用內(nèi)網(wǎng)Endpoint。關(guān)于OSS支持的Region與Endpoint的對應(yīng)關(guān)系,請參見OSS地域和訪問域名。本文以從環(huán)境變量讀取訪問憑證為例。如何配置訪問憑證,請參見配置訪問憑證。
要開啟日志轉(zhuǎn)存,您必須有
oss:PutBucketLogging
權(quán)限;要查看日志轉(zhuǎn)存配置,您必須有oss:GetBucketLogging
權(quán)限;要關(guān)閉日志轉(zhuǎn)存,您必須有oss:DeleteBucketLogging
權(quán)限。具體操作,請參見為RAM用戶授權(quán)自定義的權(quán)限策略。
示例代碼
開啟日志轉(zhuǎn)存
以下代碼用于開啟日志轉(zhuǎn)存功能。
package main
import (
"context"
"flag"
"log"
"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
)
// 定義全局變量
var (
region string // 存儲(chǔ)區(qū)域
bucketName string // 存儲(chǔ)空間名稱
)
// init函數(shù)用于初始化命令行參數(shù)
func init() {
flag.StringVar(®ion, "region", "", "The region in which the bucket is located.")
flag.StringVar(&bucketName, "bucket", "", "The name of the bucket.")
}
func main() {
// 解析命令行參數(shù)
flag.Parse()
// 檢查bucket名稱是否為空
if len(bucketName) == 0 {
flag.PrintDefaults()
log.Fatalf("invalid parameters, bucket name required")
}
// 檢查region是否為空
if len(region) == 0 {
flag.PrintDefaults()
log.Fatalf("invalid parameters, region required")
}
// 加載默認(rèn)配置并設(shè)置憑證提供者和區(qū)域
cfg := oss.LoadDefaultConfig().
WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
WithRegion(region)
// 創(chuàng)建OSS客戶端
client := oss.NewClient(cfg)
// 創(chuàng)建開啟存儲(chǔ)空間日志轉(zhuǎn)存功能的請求
putRequest := &oss.PutBucketLoggingRequest{
Bucket: oss.Ptr(bucketName), // 填寫待開啟日志轉(zhuǎn)存功能的Bucket名稱
BucketLoggingStatus: &oss.BucketLoggingStatus{
LoggingEnabled: &oss.LoggingEnabled{
TargetBucket: oss.Ptr("TargetBucket"), // 填寫存放日志文件的目標(biāo)Bucket。targetBucketName與bucketName必須處于相同地域,可以是相同或不同的Bucket。
TargetPrefix: oss.Ptr("log"), // 設(shè)置日志文件存儲(chǔ)的目錄。如果指定此項(xiàng),則日志文件將保存在目標(biāo)Bucket的指定目錄下。如果不指定此項(xiàng),則日志文件將保存在目標(biāo)Bucket的根目錄下。
},
},
}
// 執(zhí)行開啟存儲(chǔ)空間日志轉(zhuǎn)存功能的請求
putResult, err := client.PutBucketLogging(context.TODO(), putRequest)
if err != nil {
log.Fatalf("failed to put bucket logging %v", err)
}
// 打印開啟存儲(chǔ)空間日志轉(zhuǎn)存功能的結(jié)果
log.Printf("put bucket logging result:%#v\n", putResult)
}
查看日志轉(zhuǎn)存配置
以下代碼用于查看日志轉(zhuǎn)存配置。
package main
import (
"context"
"flag"
"log"
"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
)
// 定義全局變量
var (
region string // 存儲(chǔ)區(qū)域
bucketName string // 存儲(chǔ)空間名稱
)
// init函數(shù)用于初始化命令行參數(shù)
func init() {
flag.StringVar(®ion, "region", "", "The region in which the bucket is located.")
flag.StringVar(&bucketName, "bucket", "", "The name of the bucket.")
}
func main() {
// 解析命令行參數(shù)
flag.Parse()
// 檢查bucket名稱是否為空
if len(bucketName) == 0 {
flag.PrintDefaults()
log.Fatalf("invalid parameters, bucket name required")
}
// 檢查region是否為空
if len(region) == 0 {
flag.PrintDefaults()
log.Fatalf("invalid parameters, region required")
}
// 加載默認(rèn)配置并設(shè)置憑證提供者和區(qū)域
cfg := oss.LoadDefaultConfig().
WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
WithRegion(region)
// 創(chuàng)建OSS客戶端
client := oss.NewClient(cfg)
// 創(chuàng)建獲取存儲(chǔ)空間日志轉(zhuǎn)存配置的請求
getRequest := &oss.GetBucketLoggingRequest{
Bucket: oss.Ptr(bucketName), // 存儲(chǔ)空間名稱
}
// 執(zhí)行獲取存儲(chǔ)空間日志轉(zhuǎn)存配置的操作并處理結(jié)果
getResult, err := client.GetBucketLogging(context.TODO(), getRequest)
if err != nil {
log.Fatalf("failed to get bucket logging %v", err)
}
// 打印獲取存儲(chǔ)空間日志轉(zhuǎn)存配置的結(jié)果
log.Printf("get bucket logging result target bucket:%#v\n", getResult.BucketLoggingStatus.LoggingEnabled.TargetBucket)
}
關(guān)閉日志轉(zhuǎn)存
以下代碼用于關(guān)閉日志轉(zhuǎn)存功能。
package main
import (
"context"
"flag"
"log"
"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
)
// 定義全局變量
var (
region string // 存儲(chǔ)區(qū)域
bucketName string // 存儲(chǔ)空間名稱
)
// init函數(shù)用于初始化命令行參數(shù)
func init() {
flag.StringVar(®ion, "region", "", "The region in which the bucket is located.")
flag.StringVar(&bucketName, "bucket", "", "The name of the bucket.")
}
func main() {
// 解析命令行參數(shù)
flag.Parse()
// 檢查bucket名稱是否為空
if len(bucketName) == 0 {
flag.PrintDefaults()
log.Fatalf("invalid parameters, bucket name required")
}
// 檢查region是否為空
if len(region) == 0 {
flag.PrintDefaults()
log.Fatalf("invalid parameters, region required")
}
// 加載默認(rèn)配置并設(shè)置憑證提供者和區(qū)域
cfg := oss.LoadDefaultConfig().
WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
WithRegion(region)
// 創(chuàng)建OSS客戶端
client := oss.NewClient(cfg)
// 創(chuàng)建關(guān)閉存儲(chǔ)空間日志轉(zhuǎn)存功能的請求
delRequest := &oss.DeleteBucketLoggingRequest{
Bucket: oss.Ptr(bucketName), // 存儲(chǔ)空間名稱
}
// 執(zhí)行關(guān)閉存儲(chǔ)空間日志轉(zhuǎn)存功能的操作并處理結(jié)果
delResult, err := client.DeleteBucketLogging(context.TODO(), delRequest)
if err != nil {
log.Fatalf("failed to delete bucket logging %v", err)
}
// 打印關(guān)閉存儲(chǔ)空間日志轉(zhuǎn)存功能的結(jié)果
log.Printf("delete bucket logging result:%#v\n", delResult)
}
相關(guān)文檔
關(guān)于開啟日志轉(zhuǎn)存功能的API接口說明,請參見PutBucketLogging。
關(guān)于查看日志轉(zhuǎn)存配置的API接口說明,請參見GetBucketLogging。
關(guān)于關(guān)閉日志轉(zhuǎn)存功能的API接口說明,請參見DeleteBucketLogging。