全部文档
当前文档

暂无内容

如果没有找到您期望的内容,请尝试其他搜索词

文档中心

管理存储空间生命周期(Go)

最近更新时间: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))
}

文档导读
纯净模式常规模式

纯净模式

点击可全屏预览文档内容
文档反馈