From eb2bc4c0e62d35d70db9de19986dbacc3d33ba5b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=87=8C=E6=B5=B7=E4=BB=B2=E5=AD=90?= Date: Wed, 21 Dec 2022 07:25:49 +0800 Subject: [PATCH] init --- .gitignore | 3 +++ go.mod | 12 ++++++++++++ main.go | 40 ++++++++++++++++++++++++++++++++++++++++ readme.md | 2 ++ 4 files changed, 57 insertions(+) create mode 100644 .gitignore create mode 100644 go.mod create mode 100644 main.go create mode 100644 readme.md diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..3aa3857 --- /dev/null +++ b/.gitignore @@ -0,0 +1,3 @@ +tdengine-demo +.vscode/ +go.sum \ No newline at end of file diff --git a/go.mod b/go.mod new file mode 100644 index 0000000..32a02aa --- /dev/null +++ b/go.mod @@ -0,0 +1,12 @@ +module myschools.me/suguo/tdengine-demo + +go 1.19 + +require github.com/taosdata/driver-go/v3 v3.0.2 + +require ( + github.com/gorilla/websocket v1.5.0 // indirect + github.com/json-iterator/go v1.1.12 // indirect + github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421 // indirect + github.com/modern-go/reflect2 v1.0.2 // indirect +) diff --git a/main.go b/main.go new file mode 100644 index 0000000..2a2c49c --- /dev/null +++ b/main.go @@ -0,0 +1,40 @@ +package main + +import ( + "fmt" + "log" + + "github.com/taosdata/driver-go/v3/af" +) + +func main() { + conn, err := af.Open("localhost", "root", "taosdata", "", 6030) + if err != nil { + fmt.Println("fail to connect, err:", err) + } + defer conn.Close() + prepareDatabase(conn) + + var lines = []string{ + "meters,location=California.LosAngeles,groupid=2 current=11.8,voltage=221,phase=0.28 1648432611249", + "meters,location=California.LosAngeles,groupid=2 current=13.4,voltage=223,phase=0.29 1648432611250", + "meters,location=California.LosAngeles,groupid=3 current=10.8,voltage=223,phase=0.29 1648432611249", + "meters,location=California.LosAngeles,groupid=3 current=11.3,voltage=221,phase=0.35 1648432611250", + } + + err = conn.InfluxDBInsertLines(lines, "ms") + if err != nil { + log.Fatalln("insert error:", err) + } +} + +func prepareDatabase(conn *af.Connector) { + _, err := conn.Exec("CREATE DATABASE test") + if err != nil { + panic(err) + } + _, err = conn.Exec("USE test") + if err != nil { + panic(err) + } +} diff --git a/readme.md b/readme.md new file mode 100644 index 0000000..5fed132 --- /dev/null +++ b/readme.md @@ -0,0 +1,2 @@ +#### 注意 +1. 使用本地编译需要安装驱动https://docs.taosdata.com/develop/connect/#%E5%AE%89%E8%A3%85%E5%AE%A2%E6%88%B7%E7%AB%AF%E9%A9%B1%E5%8A%A8-taosc \ No newline at end of file