最近更新时间:2025-09-09 14:20:20
以下代码用于设置生命周期规则:
package main
import (
"fmt"
"github.com/ks3sdklib/aws-sdk-go/aws"
"github.com/ks3sdklib/aws-sdk-go/aws/awsutil"
"github.com/ks3sdklib/aws-sdk-go/aws/credentials"
"github.com/ks3sdklib/aws-sdk-go/service/s3"
)
func main() {
// 创建访问凭证,请将<AccessKeyID>与<SecretAccessKey>替换成真正的值
cre := credentials.NewStaticCredentials("<AccessKeyID>", "<SecretAccessKey>", "")
// 创建S3Client,更多配置项请查看Go-SDK初始化文档
client := s3.New(&aws.Config{
Credentials: cre, // 访问凭证
Region: "BEIJING", // 填写您的Region
Endpoint: "ks3-cn-beijing.ksyuncs.com", // 填写您的Endpoint
})
// 填写存储空间名称
bucket := "<bucket_name>"
// 构造存储空间的生命周期规则
lifecycleConfiguration := &s3.LifecycleConfiguration{
Rules: []*s3.LifecycleRule{
{
ID: aws.String("rule1"), // 规则的唯一标识
Status: aws.String("Enabled"), // 指定规则是否启用,Enabled:启用,Disabled:禁用
Filter: &s3.LifecycleFilter{
Prefix: aws.String("prefix1/"), // 指定该规则匹配的前缀
},
Expiration: &s3.LifecycleExpiration{
Days: aws.Long(60), // 指定Object在最后修改多少天后被删除
},
Transitions: []*s3.Transition{
{
Days: aws.Long(30), // 指定Object在最后修改多少天后转换存储类型
StorageClass: aws.String(s3.StorageClassIA), // 指定Object转换的目标存储类型
},
},
AbortIncompleteMultipartUpload: &s3.AbortIncompleteMultipartUpload{
DaysAfterInitiation: aws.Long(60), // 指明分片上传开始后多少天内必须完成上传,否则删除
},
},
{
ID: aws.String("rule2"), // 规则的唯一标识
Status: aws.String("Enabled"), // 指定规则是否启用,Enabled:启用,Disabled:禁用
Filter: &s3.LifecycleFilter{
And: &s3.And{ // 如果需要指定Tags,必须使用And,且指定Tags时不支持设置AbortIncompleteMultipartUpload
Prefix: aws.String("prefix2/"), // 指定该规则匹配的前缀
Tags: []*s3.Tag{
{
Key: aws.String("key1"), // 指定该规则匹配的标签键
Value: aws.String("value1"), // 指定该规则匹配的标签值
},
},
},
},
Expiration: &s3.LifecycleExpiration{
Days: aws.Long(60), // 指定Object在最后修改多少天后被删除
},
Transitions: []*s3.Transition{
{
Days: aws.Long(30), // 指定Object在最后访问多少天后转换存储类型
StorageClass: aws.String(s3.StorageClassIA), // 指定Object转换的目标存储类型
IsAccessTime: aws.Boolean(true), // 指定基于最后访问时间匹配规则,设置该参数需要桶开启访问追踪功能
ReturnToStdWhenVisit: aws.Boolean(true), // 指定Object转为其他存储类型后,再次访问时将Object转为源存储类型,只有当IsAccessTime设置为true时才有效
},
},
},
},
}
// 设置存储空间的生命周期
resp, err := client.PutBucketLifecycle(&s3.PutBucketLifecycleInput{
Bucket: aws.String(bucket), // 存储空间名称,必填
LifecycleConfiguration: lifecycleConfiguration, // 生命周期规则,必填
AllowSameActionOverlap: aws.Boolean(true), // 指定生命周期规则是否允许前缀重叠,默认值为false,非必填
})
if err != nil {
panic(err)
}
fmt.Println("结果:\n", awsutil.StringValue(resp))
}有关设置生命周期规则详情,请参见Put Bucket Lifecycle。
以下代码用于获取生命周期规则:
package main
import (
"fmt"
"github.com/ks3sdklib/aws-sdk-go/aws"
"github.com/ks3sdklib/aws-sdk-go/aws/awsutil"
"github.com/ks3sdklib/aws-sdk-go/aws/credentials"
"github.com/ks3sdklib/aws-sdk-go/service/s3"
)
func main() {
// 创建访问凭证,请将<AccessKeyID>与<SecretAccessKey>替换成真正的值
cre := credentials.NewStaticCredentials("<AccessKeyID>", "<SecretAccessKey>", "")
// 创建S3Client,更多配置项请查看Go-SDK初始化文档
client := s3.New(&aws.Config{
Credentials: cre, // 访问凭证
Region: "BEIJING", // 填写您的Region
Endpoint: "ks3-cn-beijing.ksyuncs.com", // 填写您的Endpoint
})
// 填写存储空间名称
bucket := "<bucket_name>"
// 获取存储空间的生命周期
resp, err := client.GetBucketLifecycle(&s3.GetBucketLifecycleInput{
Bucket: aws.String(bucket), // 存储空间名称,必填
})
if err != nil {
panic(err)
}
fmt.Println("结果:\n", awsutil.StringValue(resp))
}有关获取生命周期规则详情,请参见GET Bucket Lifecycle。
以下代码用于删除生命周期规则:
package main
import (
"fmt"
"github.com/ks3sdklib/aws-sdk-go/aws"
"github.com/ks3sdklib/aws-sdk-go/aws/awsutil"
"github.com/ks3sdklib/aws-sdk-go/aws/credentials"
"github.com/ks3sdklib/aws-sdk-go/service/s3"
)
func main() {
// 创建访问凭证,请将<AccessKeyID>与<SecretAccessKey>替换成真正的值
cre := credentials.NewStaticCredentials("<AccessKeyID>", "<SecretAccessKey>", "")
// 创建S3Client,更多配置项请查看Go-SDK初始化文档
client := s3.New(&aws.Config{
Credentials: cre, // 访问凭证
Region: "BEIJING", // 填写您的Region
Endpoint: "ks3-cn-beijing.ksyuncs.com", // 填写您的Endpoint
})
// 填写存储空间名称
bucket := "<bucket_name>"
// 删除存储空间的生命周期
resp, err := client.DeleteBucketLifecycle(&s3.DeleteBucketLifecycleInput{
Bucket: aws.String(bucket), // 存储空间名称,必填
})
if err != nil {
panic(err)
}
fmt.Println("结果:\n", awsutil.StringValue(resp))
}有关删除生命周期规则详情,请参见DELETE Bucket Lifecycle。
以下代码用于设置存储空间访问跟踪状态:
package main
import (
"fmt"
"github.com/ks3sdklib/aws-sdk-go/aws"
"github.com/ks3sdklib/aws-sdk-go/aws/awsutil"
"github.com/ks3sdklib/aws-sdk-go/aws/credentials"
"github.com/ks3sdklib/aws-sdk-go/service/s3"
)
func main() {
// 创建访问凭证,请将<AccessKeyID>与<SecretAccessKey>替换成真正的值
cre := credentials.NewStaticCredentials("<AccessKeyID>", "<SecretAccessKey>", "")
// 创建S3Client,更多配置项请查看Go-SDK初始化文档
client := s3.New(&aws.Config{
Credentials: cre, // 访问凭证
Region: "BEIJING", // 填写您的Region
Endpoint: "ks3-cn-beijing.ksyuncs.com", // 填写您的Endpoint
})
// 填写存储空间名称
bucket := "<bucket_name>"
// 设置存储空间访问跟踪状态
resp, err := client.PutBucketAccessMonitor(&s3.PutBucketAccessMonitorInput{
Bucket: aws.String(bucket), // 存储空间名称,必填
AccessMonitorConfiguration: &s3.AccessMonitorConfiguration{
Status: aws.String(s3.StatusEnabled), // 存储空间访问跟踪状态,必填
},
})
if err != nil {
panic(err)
}
fmt.Println("结果:\n", awsutil.StringValue(resp))
}以下代码用于获取存储空间访问跟踪状态:
package main
import (
"fmt"
"github.com/ks3sdklib/aws-sdk-go/aws"
"github.com/ks3sdklib/aws-sdk-go/aws/awsutil"
"github.com/ks3sdklib/aws-sdk-go/aws/credentials"
"github.com/ks3sdklib/aws-sdk-go/service/s3"
)
func main() {
// 创建访问凭证,请将<AccessKeyID>与<SecretAccessKey>替换成真正的值
cre := credentials.NewStaticCredentials("<AccessKeyID>", "<SecretAccessKey>", "")
// 创建S3Client,更多配置项请查看Go-SDK初始化文档
client := s3.New(&aws.Config{
Credentials: cre, // 访问凭证
Region: "BEIJING", // 填写您的Region
Endpoint: "ks3-cn-beijing.ksyuncs.com", // 填写您的Endpoint
})
// 填写存储空间名称
bucket := "<bucket_name>"
// 获取存储空间访问跟踪状态
resp, err := client.GetBucketAccessMonitor(&s3.GetBucketAccessMonitorInput{
Bucket: aws.String(bucket), // 存储空间名称,必填
})
if err != nil {
panic(err)
}
fmt.Println("结果:\n", awsutil.StringValue(resp))
}
纯净模式
