0
問題は次のとおりです。 私はPostgreSQLにデータベースを持っており、Golangのすべてのデータを読み込んで配列を作成しています。質問は:どのように私はこの配列を取って、それをinfluxdbに入れることができますか?golang配列からinfluxdbにデータを書き込む方法は?
問題は次のとおりです。 私はPostgreSQLにデータベースを持っており、Golangのすべてのデータを読み込んで配列を作成しています。質問は:どのように私はこの配列を取って、それをinfluxdbに入れることができますか?golang配列からinfluxdbにデータを書き込む方法は?
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では動作しません。
貼り付けるコードサンプルはありますか? – papey
私はそれを回答に掲載しました。 –