安装 Go SDK

使用火山引擎 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

2. 引入 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)
}