金山云-文档中心-管理请求者流控规则（Go）

对象存储(KS3)

查看更多结果

未找到含当前关键字的文档标题

页面目录

全部展开全部收起

产品更新动态

未找到含该关键词的产品

文档中心

对象存储(KS3)

SDK

存储空间（Go）

管理请求者流控规则（Go）

最近更新时间：2025-11-04 20:13:14



设置请求者流控规则

以下代码用于设置请求者流控规则：

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>"
    // 构造请求者流控规则
    requesterQosConfiguration := &s3.RequesterQosConfiguration{
        Rules: []*s3.RequesterQosRule{
            {
                UserType: aws.String("User"),
                Krn:      aws.String("12345678/user1"),
                Quotas: []*s3.BucketQosQuota{
                    {
                        StorageMedium:                   aws.String(s3.StorageMediumNormal),
                        ExtranetUploadBandwidth:         aws.Long(1),
                        IntranetUploadBandwidth:         aws.Long(1),
                        ExtranetDownloadBandwidth:       aws.Long(1),
                        IntranetDownloadBandwidth:       aws.Long(1),
                        OccupyExtranetUploadBandwidth:   aws.Long(1),
                        OccupyIntranetUploadBandwidth:   aws.Long(1),
                        OccupyExtranetDownloadBandwidth: aws.Long(1),
                        OccupyIntranetDownloadBandwidth: aws.Long(1),
                    },
                },
            },
            {
                UserType: aws.String("Role"),
                Krn:      aws.String("12345678/role1"),
                Quotas: []*s3.BucketQosQuota{
                    {
                        StorageMedium:                   aws.String(s3.StorageMediumNormal),
                        ExtranetUploadBandwidth:         aws.Long(1),
                        IntranetUploadBandwidth:         aws.Long(1),
                        ExtranetDownloadBandwidth:       aws.Long(1),
                        IntranetDownloadBandwidth:       aws.Long(1),
                        OccupyExtranetUploadBandwidth:   aws.Long(1),
                        OccupyIntranetUploadBandwidth:   aws.Long(1),
                        OccupyExtranetDownloadBandwidth: aws.Long(1),
                        OccupyIntranetDownloadBandwidth: aws.Long(1),
                    },
                },
            },
        },
    }
    // 设置请求者流控规则
    resp, err := client.PutRequesterQos(&s3.PutRequesterQosInput{
        Bucket:                    aws.String(bucket),        // 存储空间名称，必填
        RequesterQosConfiguration: requesterQosConfiguration, // 请求者流控规则，必填
    })
    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.GetRequesterQos(&s3.GetRequesterQosInput{
        Bucket: aws.String(bucket), // 存储空间名称，必填
    })
    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.DeleteRequesterQos(&s3.DeleteRequesterQosInput{
        Bucket: aws.String(bucket), // 存储空间名称，必填
    })
    if err != nil {
        panic(err)
    }
    fmt.Println("结果：\n", awsutil.StringValue(resp))
}

文档导读

上一篇：管理存储空间流控规则（Go）

下一篇：上传文件（Go）

纯净模式常规模式

纯净模式

点击可全屏预览文档内容