以下提供了流式计算 Flink版的 SDK 使用说明,如需查看全部的 API 详细信息，请查看 API文档。您可以通过 API Explorer 快速发起 API 调用，获取响应结果和代码示例。

发布地址

https://github.com/volcengine/volcengine-go-sdk/tree/master/service/flink20250101

源码地址

https://github.com/volcengine/volcengine-go-sdk/tree/master/service/flink20250101

前置条件

• 您已注册火山引擎账号并完成实名认证，具体步骤，请参见账号注册及实名认证。
• 如果要使用火山引擎Go SDK访问指定服务的API ，请确认您已在 火山引擎控制台 开通当前服务。
• 您已获取账号的AccessKey、SecretKey，具体步骤，请参见获取AccessKey、SecretKey。

环境要求

Go版本最低1.14+，如使用方舟服务(service/arkruntime)，需要使用go1.18+。

安装步骤

步骤一： 使用go mod方式进行依赖管理

go get github.com/volcengine/volcengine-go-sdk

Endpoint设置

如果您要自定义SDK的Endpoint，可以按照以下示例代码设置：

config = volcengine.NewConfig().
        WithCredentials(credentials.NewStaticCredentials(ak, sk, "")).
        WithRegion(region).WithEndpoint("ecs.cn-beijing-autodriving.volcengineapi.com")

火山引擎标准的Endpoint规则说明：

注：Service中存在_符号时，Endpoint时需转为-符号。存在大写字母时需转成小写。

以下提供调用【GetApplicationInstance】API的SDK示例代码,实际项目中您可以替换成SDK中已支持的任意API。

// Example Code generated by Beijing Volcanoengine Technology.
package main

import (
        "fmt"

        "github.com/volcengine/volcengine-go-sdk/service/flink20250101"
        "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 := flink20250101.New(sess)
        getApplicationInstanceInput := &flink20250101.GetApplicationInstanceInput{}

        resp, err := svc.GetApplicationInstance(getApplicationInstanceInput)
        if err != nil {
                panic(err)
        }
        fmt.Println(resp)
}