金山云-文档中心-管理存储空间事件通知规则（Go）

对象存储(KS3)

查看更多结果

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

页面目录

全部展开全部收起

产品更新动态

未找到含该关键词的产品

文档中心

对象存储(KS3)

SDK

存储空间（Go）

管理存储空间事件通知规则（Go）

最近更新时间：2026-01-22 14:37:31



1. 事件通知功能仅支持宁夏区域。

2. 事件通知为邀测功能，如有需要请联系商务或提交工单申请。

3. 有关事件通知的更多详细描述，请参见文档：事件通知。

设置存储空间事件通知规则

以下代码用于设置存储空间事件通知规则：

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>"
    // 构造存储空间事件通知规则
    bucketNotification := &s3.BucketNotification{
        Notifications: []*s3.Notification{
            {
                RuleId: aws.String("test_rule1"),
                Method: aws.String("POST"),
                Events: []string{"ks3:ObjectCreated:PutObject", "ks3:ObjectCreated:PostObject"},
                Resources: []*s3.NotificationResource{
                    {
                        Prefix: aws.String("prefix1"),
                        Suffix: aws.String("suffix1"),
                    },
                    {
                        Prefix: aws.String("prefix2"),
                        Suffix: aws.String("suffix2"),
                    },
                },
                Destinations: []*s3.NotificationDestination{
                    {
                        DestType:    aws.String("Endpoint"),
                        CallbackUrl: aws.String("http://11.11.11.11:8080"),
                    },
                },
                Report: &s3.NotificationReport{
                    ReportType: aws.String("failed"),
                    Enabled:    aws.Boolean(true),
                    Bucket:     aws.String("bucketname"),
                    Prefix:     aws.String("prefixname"),
                },
            },
        },
    }
    // 设置存储空间事件通知规则
    resp, err := client.PutBucketNotification(&s3.PutBucketNotificationInput{
        Bucket:             aws.String(bucket), // 存储空间名称，必填
        BucketNotification: bucketNotification, // 存储空间事件通知规则，必填
    })
    if err != nil {
        panic(err)
    }
    fmt.Println("结果：\n", awsutil.StringValue(resp))
}

接口详情请参见文档：PUT Bucket Notification。

获取存储空间事件通知规则

以下代码用于获取存储空间事件通知规则：

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.GetBucketNotification(&s3.GetBucketNotificationInput{
        Bucket: aws.String(bucket), // 存储空间名称，必填
    })
    if err != nil {
        panic(err)
    }
    fmt.Println("结果：\n", awsutil.StringValue(resp))
}

接口详情请参见文档：GET Bucket Notification。

删除存储空间事件通知规则

以下代码用于删除存储空间事件通知规则：

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.DeleteBucketNotification(&s3.DeleteBucketNotificationInput{
        Bucket: aws.String(bucket), // 存储空间名称，必填
    })
    if err != nil {
        panic(err)
    }
    fmt.Println("结果：\n", awsutil.StringValue(resp))
}

接口详情请参见文档：DELETE Bucket Notification。

文档导读

上一篇：管理请求者流控规则（Go）

下一篇：管理存储空间配额（Go）

纯净模式常规模式

纯净模式

点击可全屏预览文档内容