Go

写入新数据

首先，我们需要准备一个 Series，它代表了一行数据。Series 中有三种字段类型可供使用：

KindDescription
Tag索引列，有助于更有效率地检索数据
Field值存储列, 用于数据分析、聚合、计算等
Timestamp时间戳列，每一个时序表都必须有一个时间戳列

然后，您可以将一个 Series 添加到 Metric 中，然后创建一个 InsertRequest 对象并调用 client.Insert 将数据存储到 GreptimeDB 中。

Metric 可以通过 metric.SetTimePrecision 更改 Timestamp 精度。以下是支持的选项：

PrecisionDescription
time.Second
time.Milliseconddefault
time.Microsecond
time.Nanosecond

go

  1. func Insert() {
  2.     series := greptime.Series{}              // Create one row of data
  3.     series.AddStringTag("host", "localhost") // add index column, for query efficiency
  4.     series.AddFloatField("cpu", 0.90)        // add value column
  5.     series.AddIntField("memory", 1024)       // add value column
  6.     series.SetTimestamp(time.Now())          // requird
  8.     metric := greptime.Metric{} // Create a Metric and add the Series
  9.     metric.AddSeries(series)
  10.     // metric.SetTimePrecision(time.Second)  // default is Millisecond
  11.     // metric.SetTimestampAlias("timestamp") // default is 'ts'
  14.     // Create an InsertRequest using fluent style
  15.     // the specified table will be created automatically if it's not exist
  16.     insertRequest := greptime.InsertRequest{}
  17.     // if you want to specify another database, you can specify it via: `WithDatabase(database)`
  18.     insertRequest.WithTable("monitor").WithMetric(metric) // .WithDatabase(database)
  20.     // Fire the real Insert request and Get the affected number of rows
  21.     n, err := client.Insert(context.Background(), insertRequest)
  22.     if err != nil {
  23.         fmt.Printf("fail to insert, err: %+v\n", err)
  24.         return
  25.     }
  26.     fmt.Printf("AffectedRows: %d\n", n)
  27. }