changes log.Fatalln to log.Fatal move random seed inside for loop to make it random
parent
4d4207be7f
commit
9def65af1b
|
@ -61,16 +61,16 @@ const (
|
|||
password = "bumblebeetuna"
|
||||
)
|
||||
|
||||
|
||||
func main() {
|
||||
// Make client
|
||||
// Create a new HTTPClient
|
||||
c, err := client.NewHTTPClient(client.HTTPConfig{
|
||||
Addr: "http://localhost:8086",
|
||||
Addr: "http://localhost:8086",
|
||||
Username: username,
|
||||
Password: password,
|
||||
})
|
||||
|
||||
if err != nil {
|
||||
log.Fatalln("Error: ", err)
|
||||
log.Fatal(err)
|
||||
}
|
||||
|
||||
// Create a new point batch
|
||||
|
@ -78,9 +78,8 @@ func main() {
|
|||
Database: MyDB,
|
||||
Precision: "s",
|
||||
})
|
||||
|
||||
if err != nil {
|
||||
log.Fatalln("Error: ", err)
|
||||
log.Fatal(err)
|
||||
}
|
||||
|
||||
// Create a point and add to batch
|
||||
|
@ -90,16 +89,17 @@ func main() {
|
|||
"system": 53.3,
|
||||
"user": 46.6,
|
||||
}
|
||||
|
||||
pt, err := client.NewPoint("cpu_usage", tags, fields, time.Now())
|
||||
|
||||
if err != nil {
|
||||
log.Fatalln("Error: ", err)
|
||||
log.Fatal(err)
|
||||
}
|
||||
|
||||
bp.AddPoint(pt)
|
||||
|
||||
// Write the batch
|
||||
c.Write(bp)
|
||||
if err := c.Write(bp); err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
}
|
||||
|
||||
```
|
||||
|
@ -119,16 +119,21 @@ NOTE: You can specify a RetentionPolicy as part of the batch points. If not
|
|||
provided InfluxDB will use the database _default_ retention policy.
|
||||
|
||||
```go
|
||||
|
||||
func writePoints(clnt client.Client) {
|
||||
sampleSize := 1000
|
||||
rand.Seed(42)
|
||||
|
||||
bp, _ := client.NewBatchPoints(client.BatchPointsConfig{
|
||||
bp, err := client.NewBatchPoints(client.BatchPointsConfig{
|
||||
Database: "systemstats",
|
||||
Precision: "us",
|
||||
})
|
||||
if err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
|
||||
for i := 0; i < sampleSize; i++ {
|
||||
rand.Seed(uint64(i))
|
||||
|
||||
regions := []string{"us-west1", "us-west2", "us-west3", "us-east1"}
|
||||
tags := map[string]string{
|
||||
"cpu": "cpu-total",
|
||||
|
@ -148,23 +153,18 @@ func writePoints(clnt client.Client) {
|
|||
fields,
|
||||
time.Now(),
|
||||
)
|
||||
|
||||
if err != nil {
|
||||
log.Fatalln("Error: ", err)
|
||||
log.Fatal(err)
|
||||
}
|
||||
|
||||
bp.AddPoint(pt)
|
||||
|
||||
}
|
||||
|
||||
err := clnt.Write(bp)
|
||||
if err != nil {
|
||||
if err := clnt.Write(bp); err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
}
|
||||
```
|
||||
|
||||
|
||||
### Querying Data
|
||||
|
||||
One nice advantage of using **InfluxDB** the ability to query your data using familiar
|
||||
|
|
Loading…
Reference in New Issue