数据处理及使用
更新时间：2025-08-21
生命周期管理
BOS支持用户对Bucket设置生命周期规则，以自动将过期的文件清除，节省存储空间。针对不同前缀的文件，用户可以同时设置多条规则。 在为Bucket设置一条生命周期规则时，需注意如下参数的使用方式：
| 规则项 | 描述 | 是否必填 | 备注 |
|---|---|---|---|
| id | 规则的标识符 | 必填 | 同一个bucket内规则id必须唯一，不能重复。如果用户不填系统会自动帮用户生成一个 |
| status | 规则的状态 | 必填 | 取值为enabled或disabled，当规则处于disabled时规则不生效 |
| resource | 规则对哪些资源生效 | 必填 | 举例：对samplebucket里以prefix/为前缀的Object生效：samplebucket/prefix/* |
| condition | 规则依赖的条件 | 必填 | 目前只支持time形式 |
| +time | 时间限制条件 | 必填 | 通过定义的dateGreaterThan实现 |
| ++dateGreaterThan | 描述时间关系 | 必填 | 支持绝对时间date和相对时间days。绝对时间date格式为yyyy-mm-ddThh:mm:ssZ，eg. 2016-09-07T00:00:00Z。绝对时间为UTC时间,必须以00:00:00(UTC 0点)结尾；相对时间days的描述遵循ISO8601,支持的最小时间粒度为天，如:$(lastModified)+P7D表示的时间为object的last-modified之后7天。 |
| action | 对resource执行的操作动作 | 必填 | - |
| +name | 执行的操作名称 | 必填 | 取值为Transition、DeleteObject、AbortMultipartUpload |
| +storageClass | Object的存储类型 | 可选 | action为Transition时可以设定，取值为STANDARD_IA或COLD，表示从原存储类型转为低频存储或冷存储 |
设置生命周期规则
可通过如下代码设置一条生命周期规则：
Go
1// import "github.com/baidubce/bce-sdk-go/bce"
2
3ruleStr := `{
4 "rule": [
5 {
6 "id": "delete-rule-1",
7 "status": "enabled",
8 "resource": ["my-bucket/abc*"],
9 "condition": {
10 "time": {
11 "dateGreaterThan": "2018-01-01T00:00:00Z"
12 }
13 },
14 "action": {
15 "name": "DeleteObject"
16 }
17 }
18 ]
19}`
20
21// 1. 通过stream调用接口进行设置
22body, _ := bce.NewBodyFromString(ruleStr)
23err := bosClient.PutBucketLifecycle(bucketName, body)
24
25// 2. 直接传入字符串
26err := bosClient.PutBucketLifecycleFromString(bucketName, ruleStr)查看生命周期规则
可通过如下代码查看Bucket内的生命周期规则：
Go
1res, err := bosClient.GetBucketLifecycle(bucketName)
2fmt.Printf("%+v\n", res.Rule)删除生命周期规则
可通过如下代码清空生命周期规则：
Go
1err := bosClient.DeleteBucketLifecycle(bucketName)跨域资源共享
跨域资源共享（Cross-Origin Resource Sharing），简称CORS，是HTML5提供的标准跨域解决方案，BOS目前已经支持CORS标准来实现跨域访问。关于跨域访问的介绍请参考跨域访问。
设置CORS规则
用户可针对Bucket设置CORS规则，支持通过json字符串、文件、流、对象方式设置：
Go
1// import "github.com/baidubce/bce-sdk-go/service/bos/api"
2
3// 1. 通过流式调用接口进行设置
4err := bosClient.PutBucketCors(bucketName, body)
5
6// 2. 直接传入字符串
7err := bosClient.PutBucketCorsFromString(bucketName, corsString)
8
9// 3. 传入CORS文件名
10err := bosClient.PutBucketCorsFromFile(bucketName, corsFile)
11
12// 4. 传入对象
13corsObj := api.BucketCORSType{
14 AllowedOrigins: []string{"example.com"},
15 AllowedMethods: []string{"HEAD", "GET"},
16 AllowedHeaders: []string{"*"},
17 AllowedExposeHeaders: []string{"user-custom-expose-header"},
18 MaxAgeSeconds: 3600,
19}
20err := bosClient.PutBucketCorsFromStruct(src, &api.PutBucketCorsArgs{CorsConfiguration:[]api.BucketCORSType{corsObj}})获取CORS规则
用户可获取指定Bucket的CORS规则：
Go
1result, err := bosClient.GetBucketCors(bucketName)结果对象的定义与PutBucketCorsFromStruct接口的请求参数相同。
删除CORS规则
可参考如下代码删除Bucket的CORS规则，删除后的Bucket将无法进行跨域访问。
Go
1err := bosClient.DeleteBucketCors(bucketName)管理存储类型
每个Bucket会有自身的存储类型，如果该Bucket下的Object上传时未指定存储类型则会默认继承该Bucket的存储类型。
设置Bucket存储类型
Bucket默认的存储类型为标准模式，用户可以通过下面的代码进行设置：
Go
1storageClass := "STANDARD_IA"
2err := bosClient.PutBucketStorageclass(bucketName, storageClass)获取Bucket存储类型
下面的代码可以查看一个Bucket的默认存储类型：
Go
1storageClass, err := bosClient.GetBucketStorageclass(bucketName)设置访问日志
BOS GO SDK支持将用户访问Bucket时的请求记录记录为日志，用户可以指定访问Bucket的日志存放的位置。日志会包括请求者、Bucket名称、请求时间和请求操作等。关于Bucket日志的详细功能说明可参见设置访问日志。
开启Bucket日志
用户通过设置用于放置日志的Bucket和日志文件前缀来开启Bucket日志功能。下面的示例代码可以设置访问日志的位置和前缀：
Go
1// import "github.com/baidubce/bce-sdk-go/bce"
2
3// 1. 从JSON字符串设置
4loggingStr := `{"targetBucket": "logging-bucket", "targetPrefix": "my-log/"}`
5err := bosClient.PutBucketLoggingFromString(bucketName, loggingStr)
6
7// 2. 从参数对象设置
8args := new(api.PutBucketLoggingArgs)
9args.TargetBucket = "logging-bucket"
10args.TargetPrefix = "my-log/"
11err := bosClient.PutBucketLoggingFromStruct(bucketName, args)
12
13// 3. 读取json格式的文件进行设置
14loggingStrem := bce.NewBodyFromFile("<path-to-logging-setting-file>")
15err := bosClient.PutBucketLogging(bucketName, loggingStream)查看Bucket日志设置
下面的代码分别给出了如何获取给定Bucket的日志配置信息：
Go
1res, err := bosClient.GetBucketLogging(bucketName)
2fmt.Println(res.Status)
3fmt.Println(res.TargetBucket)
4fmt.Println(res.TargetPrefix)关闭Bucket日志
需要关闭Bucket的日志功能时，只需调用删除接口即可实现：
Go
1err := bosClient.DeleteBucketLogging(bucketName)服务端加密
设置服务端加密功能
用户可针对一个Bucket设置开启服务端加密的功能，所有存储到该Bucket的数据将会进行加密存储，保证数据安全性。
Go
1err := bosClient.PutBucketEncryption(bucketName, algorithm)algorithm参数为加密算法，当前只支持“AES256”加密算法。
获取服务端加密
用户可调用如下接口获取Bucket的服务端加密功能：
Go
1algorithm, err := bosClient.GetBucketEncryption(bucketName)删除服务端加密功能
用户可调用如下接口删除指定Bucket的服务端加密功能：
Go
1err := bosClient.DeleteBucketEncryption(bucketName)原图保护功能
用户可针对Bucket下存储的图片设置原图保护功能，用户需指定待保护的资源。
开启原图保护功能
通过如下代码开启原图保护功能：
Go
1resources := []stirng{
2 "bucket/prefix/*",
3 "bucket/*/suffix",
4 }
5err := bosClient.PutBucketCopyrightProtection(bucketName, resources...)resources参数表示图片保护的范围，可指定前缀、后缀，"bucket/*"表示整个bucket。
获取原图保护设置
用户通过如下示例代码获取Bucket设置的原图保护的资源：
Go
1resources, err := bosClient.GetBucketCopyrightProtection(bucketName)删除原图保护配置
Go
1err := bosClient.DeleteBucketCopyrightProtection(bucketName)静态网站托管
开启静态网站托管
用户可通过如下示例代码设置一个Bucket开启静态网站托管的功能：
Go
1// import "github.com/baidubce/bce-sdk-go/service/bos/api"
2
3// 1. 通过流式调用接口进行设置
4err := bosClient.PutBucketStaticWebsite(bucketName, body)
5
6// 2. 直接传入json字符串
7jsonStr := `{"index": "index.html", "notFound": "404.html"}`
8err := bosClient.PutBucketStaticWebsiteFromString(bucketName, jsonStr)
9
10// 3. 传入对象
11args := &api.BucketStaticWebsiteType{
12 Index: "index.html",
13 NotFound: "404.html",
14}
15err := bosClient.PutBucketStaticWebsiteFromStruct(bucketName, (*api.PutBucketStaticWebsiteArgs)(args))
16
17// 4. 简单接口设置
18err := bosClient.SimplePutBucketStaticWebsite(bucketName, "index.html", "404.html")获取静态网站托管的设置
用户通过如下代码获取指定Bucket的静态网站托管的设置情况：
Go
1result, err := bosClient.GetBucketStaticWebsite(bucketName)
2fmt.Println(result.Index)
3fmt.Println(result.NotFound)删除静态网站托管的设置
通过如下示例代码删除指定Bucket的静态网站托管功能：
Go
1err := bosClient.DeleteBucketStaticWebsite(bucketName)跨区域复制
BOS提供了跨区域复制功能，针对用户在某个物理区域创建的Bucket，为了数据安全或其他目的，可配置将整个Bucket的数据复制到物理上的一个或多个地域
开启Bucket跨区域复制功能
用户可通过如下代码开启Bucket的跨区域复制功能：
Go
1// 1. json字符串
2jsonStr := `{
3 "status":"enabled",
4 "resource":[
5 "bucket/abc",
6 "bucket/cd*"
7 ],
8 "destination": {
9 "bucket":"bucket-name",
10 "storageClass":"COLD"
11 },
12 "replicateHistory": {
13 "storageClass":"COLD"
14 },
15 "replicateDeletes":"enabled",
16 "id":"sample-bucket"
17}`
18err := bosClient.PutBucketReplicationFromString(bucketName, jsonStr, "sample-bucket")
19
20// 2. 使用配置文件名
21err := bosClient.PutBucketReplicationFromFile(bucketName, configFile, "sample-bucket")
22
23// 3. 使用参数对象
24argsObj := &api.PutBucketReplicationArgs{
25 Id: "sample-bucket",
26 Status: "enabled",
27 Resource: []string{"bucket/abc"},
28 ReplicateDeletes: "enabled",
29 Destination: &api.BucketReplicationDescriptor{"bucket-abc", "COLD"},
30 ReplicateHistory: &api.BucketReplicationDescriptor{"bucket-abc", "COLD"},
31}
32err := bosClient.PutBucketReplicationFromStruct(bucketName, argsObj, argsObj.Id)
33
34// 4. 使用流
35err := bosClient.PutBucketReplication(bucketName, bodyStream, "sample-bucket")获取Bucket跨区域复制的配置
用户可使用如下示例代码获取Bucket的跨区域复制的配置，返回的结果与Put接口字段相同。
Go
1result, err := bosClient.GetBucketReplication(bucketName, "sample-bucket")删除Bucket跨区域复制配置
用户可使用如下示例代码删除Bucket跨区域复制功能：
Go
1err := bosClient.DeleteBucketReplication(bucketName, "sample-bucket")获取跨区域复制的进度
由于跨区域复制需要后台进行异步复制操作，用户可通过如下接口查询当前复制到进度：
Go
1result, err := bosClient.GetBucketReplicationProgress(bucketName, "sample-bucket")返回的结果对象包含了如下字段：
Status(string): 当前的状态HistoryReplicationPercent(float64): 当前复制到进度LatestReplicationTime(string): 最近一次执行复制的时间
获取replication规则列表
用户可使用如下示例代码获取bucket replication规则列表
Go
1list, err := bosClient.ListBucketReplication(srcBucket)镜像回源
开启镜像回源
用户可通过如下示例代码设置一个Bucket开启镜像回源的功能
Go
1 mirrorRule := &api.MirrorConfigurationRule{
2 Prefix: "prefix",
3 SourceUrl: "http://bj.bcebos.com",
4 Mode: "fetch",
5 StorageClass: "STANDARD",
6 PassQueryString: false,
7 PassHeaders: []string{"header3", "header4"},
8 IgnoreHeaders: []string{"header3", "header4"},
9 Resource: "*",
10 PrefixReplace: "test1",
11 Version: "v2",
12 }
13 mirrorArgs := &api.PutBucketMirrorArgs{
14 BucketMirroringConfiguration: []api.MirrorConfigurationRule{*mirrorRule},
15 }
16 err = bosClient.PutBucketMirror(bucketName, mirrorArgs)获取镜像回源
Go
1 result, err := bosClient.GetBucketMirror(bucketName)删除镜像回源
Go
1err = bosClient.DeleteBucketMirror(bucketName)标签管理
为bucket添加标签
用户可通过如下示例代码为bucket绑定标签
Go
1 tag1 := api.Tag{
2 Tagkey: "tagKey1",
3 TagValue: "tagValue1",
4 }
5 tag2 := api.Tag{
6 Tagkey: "tagKey2",
7 TagValue: "tagValue2",
8 }
9 tags := []api.Tag{tag1, tag2}
10 putBucketTagArgs := &api.PutBucketTagArgs{
11 Tags: tags,
12 }
13 err = bosClient.PutBucketTag(bucketName, putBucketTagArgs)获取bucket标签
Go
1 result, err := bosClient.GetBucketTag(bucketName)删除Bucket标签
Go
1err = bosClient.DeleteBucketTag(bucketName)