Go client library
Use the InfluxDB Go client library to integrate InfluxDB into Go scripts and applications.
This guide presumes some familiarity with Go and InfluxDB. If just getting started, see Get started with InfluxDB.
Before you begin
Add the client package your to your project dependencies.
# Add InfluxDB Go client package to your project go.mod go get github.com/influxdata/influxdb-client-go/v2
Ensure that InfluxDB is running and you can connect to it. For information about what URL to use to connect to InfluxDB Cloud, see InfluxDB URLs.
Boilerplate for the InfluxDB Go Client Library
Use the Go library to write and query data from InfluxDB.
In your Go program, import the necessary packages and specify the entry point of your executable program.
package main import ( "context" "fmt" "time" "github.com/influxdata/influxdb-client-go/v2" )
Define variables for your InfluxDB bucket, organization, and token.
bucket := "example-bucket" org := "example-org" token := "example-token" // Store the URL of your InfluxDB instance url := "https://cloud2.influxdata.com"
Create the the InfluxDB Go client and pass in the
url
andtoken
parameters.client := influxdb2.NewClient(url, token)
Create a write client with the
WriteAPIBlocking
method and pass in theorg
andbucket
parameters.writeAPI := client.WriteAPIBlocking(org, bucket)
To query data, create an InfluxDB query client and pass in your InfluxDB
org
.queryAPI := client.QueryAPI(org)
Write data to InfluxDB with Go
Use the Go library to write data to InfluxDB.
Create a point and write it to InfluxDB using the
WritePoint
method of the API writer struct.Close the client to flush all pending writes and finish.
p := influxdb2.NewPoint("stat", map[string]string{"unit": "temperature"}, map[string]interface{}{"avg": 24.5, "max": 45}, time.Now()) writeAPI.WritePoint(context.Background(), p) client.Close()
Complete example write script
package main
import (
"context"
"fmt"
"time"
"github.com/influxdata/influxdb-client-go/v2"
)
func main() {
bucket := "example-bucket"
org := "example-org"
token := "example-token"
// Store the URL of your InfluxDB instance
url := "https://cloud2.influxdata.com"
// Create new client with default option for server url authenticate by token
client := influxdb2.NewClient(url, token)
// User blocking write client for writes to desired bucket
writeAPI := client.WriteAPIBlocking(org, bucket)
// Create point using full params constructor
p := influxdb2.NewPoint("stat",
map[string]string{"unit": "temperature"},
map[string]interface{}{"avg": 24.5, "max": 45},
time.Now())
// Write point immediately
writeAPI.WritePoint(context.Background(), p)
// Ensures background processes finishes
client.Close()
}
Was this page helpful?
Thank you for your feedback!
Support and feedback
Thank you for being part of our community! We welcome and encourage your feedback and bug reports for InfluxDB and this documentation. To find support, use the following resources:
InfluxDB Cloud and InfluxDB Enterprise customers can contact InfluxData Support.