设置DIS通知策略

package main

import (
	"fmt"
	"log"
        obs "github.com/huaweicloud/huaweicloud-sdk-go-obs/obs"
)

func main() {
    //推荐通过环境变量获取AKSK，这里也可以使用其他外部引入方式传入，如果使用硬编码可能会存在泄露风险。
    //您可以登录访问管理控制台获取访问密钥AK/SK，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html。
        ak := os.Getenv("AccessKeyID")
        sk := os.Getenv("SecretAccessKey")
    // 【可选】如果使用临时AK/SK和SecurityToken访问OBS，同样建议您尽量避免使用硬编码，以降低信息泄露风险。您可以通过环境变量获取访问密钥AK/SK，也可以使用其他外部引入方式传入。
    securityToken := os.Getenv("SecurityToken")
    // endpoint填写Bucket对应的Endpoint，这里以华北-北京四为例，其他地区请按实际情况填写。     endPoint := "https://obs.cn-north-4.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 := client.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"
        obs "github.com/huaweicloud/huaweicloud-sdk-go-obs/obs"
)

func main() {
    //推荐通过环境变量获取AKSK，这里也可以使用其他外部引入方式传入，如果使用硬编码可能会存在泄露风险。
    //您可以登录访问管理控制台获取访问密钥AK/SK，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html。
        ak := os.Getenv("AccessKeyID")
        sk := os.Getenv("SecretAccessKey")
    // 【可选】如果使用临时AK/SK和SecurityToken访问OBS，同样建议您尽量避免使用硬编码，以降低信息泄露风险。您可以通过环境变量获取访问密钥AK/SK，也可以使用其他外部引入方式传入。
    securityToken := os.Getenv("SecurityToken")
    // endpoint填写Bucket对应的Endpoint，这里以华北-北京四为例，其他地区请按实际情况填写。     endPoint := "https://obs.cn-north-4.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:      "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 := client.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"
        obs "github.com/huaweicloud/huaweicloud-sdk-go-obs/obs"
)

func main() {
    //推荐通过环境变量获取AKSK，这里也可以使用其他外部引入方式传入，如果使用硬编码可能会存在泄露风险。
    //您可以登录访问管理控制台获取访问密钥AK/SK，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html。
        ak := os.Getenv("AccessKeyID")
        sk := os.Getenv("SecretAccessKey")
    // 【可选】如果使用临时AK/SK和SecurityToken访问OBS，同样建议您尽量避免使用硬编码，以降低信息泄露风险。您可以通过环境变量获取访问密钥AK/SK，也可以使用其他外部引入方式传入。
    securityToken := os.Getenv("SecurityToken")
    // endpoint填写Bucket对应的Endpoint，这里以华北-北京四为例，其他地区请按实际情况填写。     endPoint := "https://obs.cn-north-4.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 := client.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 = client.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"
        obs "github.com/huaweicloud/huaweicloud-sdk-go-obs/obs"
)

func main() {
    //推荐通过环境变量获取AKSK，这里也可以使用其他外部引入方式传入，如果使用硬编码可能会存在泄露风险。
    //您可以登录访问管理控制台获取访问密钥AK/SK，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html。
        ak := os.Getenv("AccessKeyID")
        sk := os.Getenv("SecretAccessKey")
    // 【可选】如果使用临时AK/SK和SecurityToken访问OBS，同样建议您尽量避免使用硬编码，以降低信息泄露风险。您可以通过环境变量获取访问密钥AK/SK，也可以使用其他外部引入方式传入。
    securityToken := os.Getenv("SecurityToken")
    // endpoint填写Bucket对应的Endpoint，这里以华北-北京四为例，其他地区请按实际情况填写。     endPoint := "https://obs.cn-north-4.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 := client.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 = client.SetDisPolicy(updateInput)
if err != nil {
	log.Fatalf("Failed to update DIS policy: %v", err)
}
}