EventBridge:EventBridge SDK for Go

Sample code

This example publishes a single event to an event bus:

package main

import (
	"fmt"
	"os"

	eventbridge "github.com/alibabacloud-go/eventbridge-sdk/eventbridge"
)

func main() {
	// Configure the client with credentials from environment variables.
	config := new(eventbridge.Config).
		SetAccessKeyId(os.Getenv("ALIBABA_CLOUD_ACCESS_KEY_ID")).
		SetAccessKeySecret(os.Getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET")).
		SetEndpoint("<endpoint>")

	client, err := eventbridge.NewClient(config)
	if err != nil {
		panic(err)
	}

	// Build a CloudEvent with the required attributes.
	event := new(eventbridge.CloudEvent).
		SetDatacontenttype("application/json").
		SetData([]byte("test")).
		SetId("id").
		SetSource("source").
		SetTime("2020-08-24T13:54:05.965Asia/Shanghai").
		SetSubject("1.0").
		SetType("type").
		SetExtensions(map[string]interface{}{
			"aliyuneventbusname": "BusName",
		})

	// Publish the event.
	resp, err := client.PutEvents([]*eventbridge.CloudEvent{event})
	if err != nil {
		panic(err)
	}
	fmt.Println(resp)
}

Set the following environment variables before you run the code:

In the code, replace the following placeholder values:

The sample code uses panic(err) for brevity. In production, implement proper error handling, including retry logic for transient failures.

CloudEvent attributes

Each event requires the following attributes: