【问题标题】:How to wrtie data to influxdb from golang array?如何从golang数组将数据写入influxdb?
【发布时间】:2017-08-03 01:35:06
【问题描述】:

问题是: 我在 PostgreSQL 中有一个数据库,我在 Golang 中读取所有数据并从中创建数组。问题是:我怎样才能把这个数组放到influxdb中?

【问题讨论】:

  • 您有要粘贴的代码示例吗?
  • 我在答案中发布了它。

标签: postgresql go influxdb


【解决方案1】:
package main

import (
"database/sql"
"log"
_ "./pq"
"fmt"

)

type DbInfo struct {
id string
person_id int
timestamp int
age string
gender string
attention string
interest int
happines int
surprise int
anger int
disgust int
fear string
sadness int
neutrall string

}

var DBObject DbInfo
var DbArray []DbInfo




func main() {


db, err := sql.Open("****", "postgres://postgres:********/cam?
sslmode=disable")
if err != nil {
    log.Fatal(err)
}
defer db.Close()
rows, err := db.Query(`SELECT avg(age), avg(id), avg(neutrall),avg(fear)  
 FROM public.stat`) //stringTimeDayAgoQuery )
if err != nil {
    log.Fatal(err)
}
defer rows.Close()
for rows.Next() {
    //err := rows.Scan(&DBObject.id, &DBObject.person_id, 
 &DBObject.timestamp,&DBObject.age, 
 &DBObject.gender,&DBObject.attention,&DBObject.interest,&DBObject.happines, 

   &DBObject.surprise,&DBObject.anger,&DBObject.disgust,&DBObject.fear, 
   &DBObject.sadness,&DBObject.neutrall)
    err := rows.Scan(&DBObject.age,&DBObject.id,&DBObject.neutrall, 
   &DBObject.fear)

    if err != nil {
        log.Fatal(err)
    }
    DbArray = append(DbArray, DBObject)
}
fmt.Println(DbArray)

} 在这段代码中。我从 postgreSQL 读取我的数据。我将它作为一个数组读取,现在我想将我的输出导入到 Influxdb。因为我想用Grafana,它不能用postgresql。

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2021-01-08
    • 1970-01-01
    • 2022-06-17
    • 2016-10-30
    • 1970-01-01
    • 2021-03-05
    • 1970-01-01
    相关资源
    最近更新 更多