You need to enable JavaScript to run this app.
消息队列 Kafka版

消息队列 Kafka版

复制全文
Volcengine Go SDK
安装 Go SDK
复制全文
安装 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
  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)
}
最近更新时间:2023.08.18 19:13:49
这个页面对您有帮助吗?
有用
有用
无用
无用