Configuring a DIS Notification Policy

package main

import (
	"fmt"
	"log"

        obs "github.com/huaweicloud/huaweicloud-sdk-go-obs/obs"
)

func main() {
    // Obtain an AK/SK pair using environment variables or import an AK/SK pair in other ways. Using hard coding may result in leakage.
    // Obtain an AK/SK pair on the management console. For details, see https://support.huaweicloud.com/intl/en-us/usermanual-ca/ca_01_0003.html.
        ak := os.Getenv("AccessKeyID")
        sk := os.Getenv("SecretAccessKey")
    // (Optional) If you use a temporary AK/SK pair and a security token to access OBS, you are not advised to use hard coding, which may result in information leakage. You can obtain an AK/SK pair using environment variables or import an AK/SK pair in other ways.
    securityToken := os.Getenv("SecurityToken")


    // Enter the endpoint corresponding to the bucket. CN-Hong Kong is used here as an example. Replace it with the one currently in use.
    endPoint := "https://obs.ap-southeast-1.myhuaweicloud.com"




	// Create a client.
    obsClient, err := obs.New(ak, sk, endPoint, obs.WithSecurityToken(securityToken))
    if err != nil {
        fmt.Printf("Create obsClient error, errMsg: %s", err.Error())
    }

// Configure a DIS policy.
	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")
}

Example 2: This example creates a DIS notification policy with multiple rules for bucket examplebucket to monitor the creation of objects whose name prefix is upload/ and the deletion of objects whose name suffix is .log. The events are pushed to the DIS stream my-dis-stream (which can be purchased and viewed on the DIS console).

package main

import (
	"fmt"
	"log"

        obs "github.com/huaweicloud/huaweicloud-sdk-go-obs/obs"
)

func main() {
    // Obtain an AK/SK pair using environment variables or import an AK/SK pair in other ways. Using hard coding may result in leakage.
    // Obtain an AK/SK pair on the management console. For details, see https://support.huaweicloud.com/intl/en-us/usermanual-ca/ca_01_0003.html.
        ak := os.Getenv("AccessKeyID")
        sk := os.Getenv("SecretAccessKey")
    // (Optional) If you use a temporary AK/SK pair and a security token to access OBS, you are not advised to use hard coding, which may result in information leakage. You can obtain an AK/SK pair using environment variables or import an AK/SK pair in other ways.
    securityToken := os.Getenv("SecurityToken")


    // Enter the endpoint corresponding to the bucket. CN-Hong Kong is used here as an example. Replace it with the one currently in use.
    endPoint := "https://obs.ap-southeast-1.myhuaweicloud.com"




	// Create a client.
    obsClient, err := obs.New(ak, sk, endPoint, obs.WithSecurityToken(securityToken))
    if err != nil {
        fmt.Printf("Create obsClient error, errMsg: %s", err.Error())
    }
	// Configure a DIS policy with multiple rules.
	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")
}

Example 3: This example deletes the DIS notification rule whose ID is rule-001 from bucket examplebucket.

package main

import (
	"fmt"
	"log"

        obs "github.com/huaweicloud/huaweicloud-sdk-go-obs/obs"
)

func main() {
    // Obtain an AK/SK pair using environment variables or import an AK/SK pair in other ways. Using hard coding may result in leakage.
    // Obtain an AK/SK pair on the management console. For details, see https://support.huaweicloud.com/intl/en-us/usermanual-ca/ca_01_0003.html.
        ak := os.Getenv("AccessKeyID")
        sk := os.Getenv("SecretAccessKey")
    // (Optional) If you use a temporary AK/SK pair and a security token to access OBS, you are not advised to use hard coding, which may result in information leakage. You can obtain an AK/SK pair using environment variables or import an AK/SK pair in other ways.
    securityToken := os.Getenv("SecurityToken")


    // Enter the endpoint corresponding to the bucket. CN-Hong Kong is used here as an example. Replace it with the one currently in use.
    endPoint := "https://obs.ap-southeast-1.myhuaweicloud.com"




	// Create a client.
    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"}

	// Step 1: Obtain the current policy.
	currentPolicy, err := client.GetDisPolicy(bucketName)
	if err != nil {
		log.Fatalf("Failed to obtain the DIS policy: %v", err)
	}

	fmt.Printf("Current number of rules: %d\n", len(currentPolicy.Rules))

	// Step 2: Construct the ID mapping for deletion.
	idMap := make(map[string]bool)
	for _, id := range idsToDelete {
		idMap[id] = true
	}

	// Step 3: Delete the target rule from the rule list.
	var updatedRules []obs.DisPolicyRule
	for _, rule := range currentPolicy.Rules {
		if !idMap[rule.ID] {
			updatedRules = append(updatedRules, rule)
		}
	}

	// Step 4: Reconfigure the policy.
	setInput := &obs.SetDisPolicyInput{
		Bucket: bucketName,
		Rules:  updatedRules,
	}

	_, err = client.SetDisPolicy(setInput)
	if err != nil {
		log.Fatalf("Failed to set the new policy: %v", err)
	}

	fmt.Printf("Successfully deleted %d rules. Number of remaining rules: %d\n", len(idsToDelete), len(updatedRules))
}

Example 4: This example adds a DIS rule to bucket examplebucket, where a DIS policy has already been configured.

package main

import (
	"fmt"
	"log"

        obs "github.com/huaweicloud/huaweicloud-sdk-go-obs/obs"
)

func main() {
    // Obtain an AK/SK pair using environment variables or import an AK/SK pair in other ways. Using hard coding may result in leakage.
    // Obtain an AK/SK pair on the management console. For details, see https://support.huaweicloud.com/intl/en-us/usermanual-ca/ca_01_0003.html.
        ak := os.Getenv("AccessKeyID")
        sk := os.Getenv("SecretAccessKey")
    // (Optional) If you use a temporary AK/SK pair and a security token to access OBS, you are not advised to use hard coding, which may result in information leakage. You can obtain an AK/SK pair using environment variables or import an AK/SK pair in other ways.
    securityToken := os.Getenv("SecurityToken")


    // Enter the endpoint corresponding to the bucket. CN-Hong Kong is used here as an example. Replace it with the one currently in use.
    endPoint := "https://obs.ap-southeast-1.myhuaweicloud.com"




	// Create a client.
    obsClient, err := obs.New(ak, sk, endPoint, obs.WithSecurityToken(securityToken))
    if err != nil {
        fmt.Printf("Create obsClient error, errMsg: %s", err.Error())
    }
// Obtain the existing policy.
output, err := client.GetDisPolicy("examplebucket")
if err != nil {
	log.Fatalf("Failed to get DIS policy: %v", err)
}

// Add a new rule.
newRules := append(output.Rules, obs.DisPolicyRule{
	ID:      "new-rule",
	Stream:  "my-dis-stream",
	Project: "project-id-12345",
	Events: []string{
		"ObjectCreated:*",
	},
	Agency: "obs_dis_agency",
})

// Update the policy.
updateInput := &obs.SetDisPolicyInput{
	Bucket: "examplebucket",
	Rules:  newRules,
}

_, err = client.SetDisPolicy(updateInput)
if err != nil {
	log.Fatalf("Failed to update DIS policy: %v", err)
}
}