如何使用事件总线的Go SDK - 事件总线EventBridge

本文介绍了Go SDK的安装方法、示例代码以及如何使用Go SDK发布事件。

SDK简介

事件总线EventBridge的SDK分为管控API SDK和数据API SDK，示例代码和使用的依赖有所不同。

管控API SDK：对控制台页面进行操作使用的SDK。
数据API SDK：事件数据的通道，目前只有发送事件（PutEvents）属于此类。

前提条件

您已完成以下操作：

环境准备

环境要求
安装Golang1.12.0以上的版本。更多信息，请参见安装Golang。
查看语言版本
执行命令go version查看Go语言版本。

管控API SDK

安装SDK

执行以下命令启用Go mod。
```
go env -w GO111MODULE=on
```

执行以下命令设置Go mod代理。

go env -w GOPROXY=https://goproxy.cn,direct

执行以下命令进行初始化，生成go.mod文件。
```
go mod init
```

执行以下命令安装Go SDK。

go get github.com/alibabacloud-go/eventbridge-20200401/v2

执行以下命令安装打印端口。

go get github.com/alibabacloud/tea-console

SDK示例

您可以在OpenAPI门户通过调用API接口，自动生成对应的SDK示例。具体操作，请参见如何自动生成SDK示例。

数据API SDK

安装SDK

执行以下命令启用Go mod。
```
go env -w GO111MODULE=on
```

执行以下命令设置Go mod代理。

go env -w GOPROXY=https://goproxy.cn,direct

执行以下命令进行初始化，生成go.mod文件。
```
go mod init
```

执行以下命令安装Go SDK。

go get github.com/alibabacloud-go/eventbridge-sdk

执行以下命令安装打印端口。

go get github.com/alibabacloud/tea-console

SDK示例

数据API SDK目前只包含发布事件（PutEvents），如需使用Go SDK发布一个或多个事件，请参考以下示例代码。

package main

import (
    "fmt"

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

func main() {
    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)
    }

    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",
        })

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