English | 中文

Apache IoTDB Go语言客户端

概览

本仓库是Apache IoTDB的Go语言客户端.

Apache IoTDB website: https://iotdb.apache.org Apache IoTDB Github: https://github.com/apache/iotdb

环境准备

golang >= 1.13

如何使用 (快速上手)

使用go mod

export GO111MODULE=on
export GOPROXY=https://goproxy.io

mkdir session_example && cd session_example

curl -o session_example.go -L https://github.com/apache/iotdb-client-go/raw/main/example/session_example.go

go mod init session_example
go run session_example.go

不使用go mod，采用GOPATH

# get thrift 0.14.1
go get github.com/apache/thrift
cd $GOPATH/src/github.com/apache/thrift
git checkout 0.14.1

mkdir -p $GOPATH/src/iotdb-client-go-example/session_example
cd $GOPATH/src/iotdb-client-go-example/session_example
curl -o session_example.go -L https://github.com/apache/iotdb-client-go/raw/main/example/session_example.go
go run session_example.go

SessionPool

通过SessionPool管理session，用户不需要考虑如何重用session，当到达pool的最大值时，获取session的请求会阻塞 注意：session使用完成后需要调用PutBack方法

创建sessionPool

单实例

config := &client.PoolConfig{
    Host:     host,
    Port:     port,
    UserName: user,
    Password: password,
}
sessionPool = client.NewSessionPool(config, 3, 60000, 60000, false)

分布式或双活

config := &client.PoolConfig{
		UserName: user,
		Password: password,
		NodeUrls: strings.Split("127.0.0.1:6667,127.0.0.1:6668", ","),
	}
sessionPool = client.NewSessionPool(config, 3, 60000, 60000, false)

使用sessionPool获取session，使用完手动调用PutBack

例1：设置存储组

session, err := sessionPool.GetSession()
defer sessionPool.PutBack(session)
if err == nil {
    session.SetStorageGroup(sg)
}

例2：查询

var timeout int64 = 1000
session, err := sessionPool.GetSession()
defer sessionPool.PutBack(session)
if err != nil {
    log.Print(err)
    return
}
sessionDataSet, err := session.ExecuteQueryStatement(sql, &timeout)
if err == nil {
    defer sessionDataSet.Close()
    printDataSet1(sessionDataSet)
} else {
    log.Println(err)
}

iotdb-client-go的开发者环境要求

操作系统

• Linux、Macos或其他类unix系统
• Windows+bash(WSL、cygwin、Git Bash)

命令行工具

• golang >= 1.13
• make >= 3.0
• curl >= 7.1.1
• thrift 0.14.1

疑难解答

Open函数参数名称与实际功能不匹配的问题

函数client/session.go/Open()有一个参数connectionTimeoutInMs，表示了以毫秒为单位的连接超时时间。 但旧版本中，该函数在实现时并未正确进行单位转换，而是将其看作了纳秒。现在该问题已修复。 当该参数为0时，表示不设置超时时间；当设置为正数时表示以毫秒为单位的超时时间。