You need to enable JavaScript to run this app.
导航
安装 Go SDK
最近更新时间:2023.08.18 19:13:49首次发布时间:2023.08.18 19:13:49

使用火山引擎 Go SDK 进行各类操作前,您需要安装 Go SDK。本文介绍 Go SDK 的安装方法。

前提条件

  • 已创建并获取火山引擎访问密钥 AccessKey。获取方式请参考密钥管理
  • 访问密钥 AccessKey 拥有所有 API 的全部权限。建议您通过 IAM 用户进行 API 相关操作和日常运维。使用 IAM 用户前,主账号需要为 IAM 用户授予消息队列 Kafka版相关资源和操作的权限。

准备开发环境

请参考 Go 官网下载和安装 Go 编译运行环境。

  • Go 安装完毕后请新建系统变量 GOPATH,并将其指向您的代码目录。要了解更多 GOPATH 相关信息,请执行命令 go help gopath
  • Go SDK 支持 Go 1.13 及后续版本,可执行 go version 检查当前 Go 的版本信息。

安装 SDK

  1. 下载火山引擎 Volcengine Go SDK。
go get -u github.com/volcengine/volcengine-go-sdk
  1. 引入 Volcengine Go SDK。
require github.com/volcengine/volcengine-go-sdk v1.0.91

初始化客户端

Volcengine Go SDK 支持通过 Session 的方式来初始化客户端。通过 Session 方式创建的 客户端,底层会实现 HTTP/HTTPS 资源(连接或请求)的复用。当需要初始化多个客户端进行操作时,通过 Session 方式创建可以提升客户端的性能。本文介绍如何通过 Session 的方式来初始化客户端。
初始化客户端的示例代码如下:

package main

import (
    "github.com/volcengine/volcengine-go-sdk/service/kafka"
    "github.com/volcengine/volcengine-go-sdk/volcengine"
    "github.com/volcengine/volcengine-go-sdk/volcengine/credentials"
    "github.com/volcengine/volcengine-go-sdk/volcengine/session"
)

func main() {
    ak, sk, region := "Your AK", "Your SK", "cn-beijing"
    config := volcengine.NewConfig().
       WithRegion(region).
       WithCredentials(credentials.NewStaticCredentials(ak, sk, ""))
    sess, err := session.NewSession(config)
    if err != nil {
       panic(err)
    }
    svc := kafka.New(sess)
}