全部产品
Search
文档中心

事件总线EventBridge:Go SDK使用手册

更新时间:Oct 26, 2023

本文介绍了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

  1. 执行以下命令启用Go mod。

    go env -w GO111MODULE=on
  2. 执行以下命令设置Go mod代理。

    go env -w GOPROXY=https://goproxy.cn,direct 
  3. 执行以下命令进行初始化,生成go.mod文件。

    go mod init
  4. 执行以下命令安装Go SDK。

    go get github.com/alibabacloud-go/eventbridge-20200401/v2  
  5. 执行以下命令安装打印端口。

    go get github.com/alibabacloud/tea-console

SDK示例

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

数据API SDK

安装SDK

  1. 执行以下命令启用Go mod。

    go env -w GO111MODULE=on
  2. 执行以下命令设置Go mod代理。

    go env -w GOPROXY=https://goproxy.cn,direct 
  3. 执行以下命令进行初始化,生成go.mod文件。

    go mod init
  4. 执行以下命令安装Go SDK。

    go get github.com/alibabacloud-go/eventbridge-sdk    
  5. 执行以下命令安装打印端口。

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