设置DIS通知策略

package main
import (
    "fmt"
    "log"
    "os"
)
func main() {
    // 推荐通过环境变量获取AKSK，这里也可以使用其他外部引入方式传入，如果使用硬编码可能会存在泄露风险。
    // 您可以登录访问管理控制台获取访问密钥AK/SK。
    ak := os.Getenv("AccessKeyID")
    sk := os.Getenv("SecretAccessKey")
    // 【可选】如果使用临时AK/SK和SecurityToken访问OBS，同样建议您尽量避免使用硬编码，以降低信息泄露风险。您可以通过环境变量获取访问密钥AK/SK，也可以使用其他外部引入方式传入。
    securityToken := os.Getenv("SecurityToken")
    // endpoint填写Bucket对应的Endpoint，这里以中国-香港为例，其他地区请按实际情况填写。
    endPoint := "https://obs.ap-southeast-1.myhuaweicloud.com"
    // 创建客户端
    obsClient, err := obs.New(ak, sk, endPoint, obs.WithSecurityToken(securityToken))
    if err != nil {
        fmt.Printf("Create obsClient error, errMsg: %s", err.Error())
    }
    // 设置 DIS 策略
    input := &obs.SetDisPolicyInput{
        Bucket: "examplebucket",
        Rules: []obs.DisPolicyRule{
            {
                ID:      "dis-rule-01",
                Stream:  "my-dis-stream",
                Project: "project-id-12345",
                Events: []string{
                    "ObjectCreated:*",
                    "ObjectRemoved:*",
                },
                Agency: "obs_dis_agency",
            },
        },
    }
    output, err := obsClient.SetDisPolicy(input)
    if err != nil {
        log.Fatalf("Failed to set DIS policy: %v", err)
    }
    fmt.Printf("Request ID: %s\n", output.RequestId)
    fmt.Println("DIS policy set successfully")
}

示例2-桶examplebucket同时创建多条DIS通知策略，分别是监控桶上前缀为upload/的对象创建事件和后缀为.log的删除事件，事件推送到名称为my-dis-stream的DIS通道中（在DIS云服务中可以购买查看）。

package main
import (
    "fmt"
    "log"
    "os"
)
func main() {
    // 推荐通过环境变量获取AKSK，这里也可以使用其他外部引入方式传入，如果使用硬编码可能会存在泄露风险。
    // 您可以登录访问管理控制台获取访问密钥AK/SK。
    ak := os.Getenv("AccessKeyID")
    sk := os.Getenv("SecretAccessKey")
    // 【可选】如果使用临时AK/SK和SecurityToken访问OBS，同样建议您尽量避免使用硬编码，以降低信息泄露风险。您可以通过环境变量获取访问密钥AK/SK，也可以使用其他外部引入方式传入。
    securityToken := os.Getenv("SecurityToken")
    // endpoint填写Bucket对应的Endpoint，这里以中国-香港为例，其他地区请按实际情况填写。
    endPoint := "https://obs.ap-southeast-1.myhuaweicloud.com"
    endPoint := "https://your-endpoint"
    // 创建客户端
    obsClient, err := obs.New(ak, sk, endPoint, obs.WithSecurityToken(securityToken))
    if err != nil {
        fmt.Printf("Create obsClient error, errMsg: %s", err.Error())
    }
    // 设置多规则 DIS 策略
    input := &obs.SetDisPolicyInput{
        Bucket: "examplebucket",
        Rules: []obs.DisPolicyRule{
            {
                ID:      "create-rule",
                Stream:  "my-dis-stream",
                Project: "project-id-12345",
                Events: []string{
                    "ObjectCreated:*",
                },
                Prefix: "upload/",
                Agency: "obs_dis_agency",
            },
            {
                ID:      "delete-rule",
                Stream:  "my-dis-stream",
                Project: "project-id-12345",
                Events: []string{
                    "ObjectRemoved:*",
                },
                Suffix: ".log",
                Agency: "obs_dis_agency",
            },
        },
    }
    output, err := obsClient.SetDisPolicy(input)
    if err != nil {
        log.Fatalf("Failed to set multi-rule DIS policy: %v", err)
    }
    fmt.Printf("Request ID: %s\n", output.RequestId)
    fmt.Printf("Configured %d rules\n", len(input.Rules))
    fmt.Println("Multi-rule DIS policy set successfully")
}

示例3-删除桶examplebucket上多条DIS策略中rule id为rule-001的策略。

package main
import (
    "fmt"
    "log"
    "os"
)
func main() {
    // 推荐通过环境变量获取AKSK，这里也可以使用其他外部引入方式传入，如果使用硬编码可能会存在泄露风险。
    // 您可以登录访问管理控制台获取访问密钥AK/SK。
    ak := os.Getenv("AccessKeyID")
    sk := os.Getenv("SecretAccessKey")
    // 【可选】如果使用临时AK/SK和SecurityToken访问OBS，同样建议您尽量避免使用硬编码，以降低信息泄露风险。您可以通过环境变量获取访问密钥AK/SK，也可以使用其他外部引入方式传入。
    securityToken := os.Getenv("SecurityToken")
    // endpoint填写Bucket对应的Endpoint，这里以中国-香港为例，其他地区请按实际情况填写。
    endPoint := "https://obs.ap-southeast-1.myhuaweicloud.com"
    // 创建客户端
    obsClient, err := obs.New(ak, sk, endPoint, obs.WithSecurityToken(securityToken))
    if err != nil {
        fmt.Printf("Create obsClient error, errMsg: %s", err.Error())
    }
    bucketName := "examplebucket"
    idsToDelete := []string{"rule-001"}
    // 步骤 1：获取当前策略
    currentPolicy, err := obsClient.GetDisPolicy(bucketName)
    if err != nil {
        log.Fatalf("获取 DIS 策略失败: %v", err)
    }
    fmt.Printf("当前规则数量: %d\n", len(currentPolicy.Rules))
    // 步骤 2：构建要删除的 ID 映射
    idMap := make(map[string]bool)
    for _, id := range idsToDelete {
        idMap[id] = true
    }
    // 步骤 3：从规则列表中移除要删除的规则
    var updatedRules []obs.DisPolicyRule
    for _, rule := range currentPolicy.Rules {
        if !idMap[rule.ID] {
            updatedRules = append(updatedRules, rule)
        }
    }
    // 步骤 4：重新设置策略
    setInput := &obs.SetDisPolicyInput{
        Bucket: bucketName,
        Rules:  updatedRules,
    }
    _, err = obsClient.SetDisPolicy(setInput)
    if err != nil {
        log.Fatalf("设置新策略失败: %v", err)
    }
    fmt.Printf("成功删除 %d 条规则! 剩余规则数量: %d\n", len(idsToDelete), len(updatedRules))
}

示例4-在桶examplebucket上，已经配置过DIS策略的情况下，再添加一条DIS策略。

package main
import (
    "fmt"
    "log"
    "os"
)
func main() {
    // 推荐通过环境变量获取AKSK，这里也可以使用其他外部引入方式传入，如果使用硬编码可能会存在泄露风险。
    // 您可以登录访问管理控制台获取访问密钥AK/SK。
    ak := os.Getenv("AccessKeyID")
    sk := os.Getenv("SecretAccessKey")
    // 【可选】如果使用临时AK/SK和SecurityToken访问OBS，同样建议您尽量避免使用硬编码，以降低信息泄露风险。您可以通过环境变量获取访问密钥AK/SK，也可以使用其他外部引入方式传入。
    securityToken := os.Getenv("SecurityToken")
    // endpoint填写Bucket对应的Endpoint，这里以中国-香港为例，其他地区请按实际情况填写。
    endPoint := "https://obs.ap-southeast-1.myhuaweicloud.com"
    // 创建客户端
    obsClient, err := obs.New(ak, sk, endPoint, obs.WithSecurityToken(securityToken))
    if err != nil {
        fmt.Printf("Create obsClient error, errMsg: %s", err.Error())
    }
    // 获取现有策略
    output, err := obsClient.GetDisPolicy("examplebucket")
    if err != nil {
        log.Fatalf("Failed to get DIS policy: %v", err)
    }
    // 添加新规则
    newRules := append(output.Rules, obs.DisPolicyRule{
        ID:      "new-rule",
        Stream:  "my-dis-stream",
        Project: "project-id-12345",
        Events: []string{
            "ObjectCreated:*",
        },
        Agency: "obs_dis_agency",
    })
    // 更新策略
    updateInput := &obs.SetDisPolicyInput{
        Bucket: "examplebucket",
        Rules:  newRules,
    }
    _, err = obsClient.SetDisPolicy(updateInput)
    if err != nil {
        log.Fatalf("Failed to update DIS policy: %v", err)
    }
}