Documentation

InfluxDB Clustered

Use Go to query data

  • InfluxQL
  • SQL

Use the InfluxDB influxdb3-go Go client library package and SQL or InfluxQL to query data stored in InfluxDB. Execute queries and retrieve data over the Flight+gRPC protocol, and then process data using common Go tools.

Get started using Go to query InfluxDB

The following example shows how to use Go with the influxdb3-go module to create a client and query an InfluxDB Clustered database.

Install Go

Follow the Go download and installation instructions to install a recent version of the Go programming language for your system.

Create a Go module directory

  1. Inside of your project directory, create a new module directory and navigate into it.

    mkdir influxdb_go_client && cd $_

  2. Enter the following command to initialize a new Go module:

    go mod init influxdb_go_client

Install dependencies

In your terminal, enter the following command to download and install the client library:

go get github.com/InfluxCommunity/influxdb3-go

With the dependencies installed, you’re ready to query and analyze data stored in an InfluxDB database.

Execute a query

The following examples show how to create an InfluxDB client, use client query methods to select all fields in a measurement, and then access query result data and metadata.

In your influxdb_go_client module directory, create a file named query.go and enter one of the following samples to query using SQL or InfluxQL.

Replace the following configuration values in the sample code:

  • DATABASE_NAME: the name of the database to query
  • DATABASE_TOKEN: a database token with read permission on the specified database

SQL InfluxQL

Query using SQL

// query.go
package main

import (
    "context"
    "fmt"
    "io"
    "os"
    "text/tabwriter"
    "time"

    "github.com/InfluxCommunity/influxdb3-go/influxdb3/v1"
)

func Query() error {

    // Instantiate the client.
    client, err := influxdb3.New(influxdb3.ClientConfig{
        Host:       "https://cluster-host.com",
        Token:      "
DATABASE_TOKEN
",
        Database:   "
DATABASE_NAME
",
    })

    defer func(client *influxdb3.Client) {
        err := client.Close()
        if err != nil {
            panic(err)
        }
    }(client)

    query := `SELECT *
        FROM home
        WHERE time >= '2022-01-02T08:00:00Z'
        AND time <= '2022-01-02T20:00:00Z'`

    // Example 1: Query data and then read the schema and all data in the result stream.
    iterator, err := client.Query(context.Background(), query)

    fmt.Fprintln(os.Stdout, "Read all data in the stream:")
    data, err := iterator.Raw().Reader.Read()
    fmt.Fprintln(os.Stdout, data)

    if err != nil {
        panic(err)
    }

    // Example 2: Query data, view the result schema, and then process result data by row.
    iterator2, err = client.Query(context.Background(), query)
    fmt.Fprintln(os.Stdout, "View the query result schema:")
    schema := iterator2.Raw().Reader.Schema()
    fmt.Fprintln(os.Stdout, schema)

    w := tabwriter.NewWriter(io.Discard, 4, 4, 1, ' ', 0)
    w.Init(os.Stdout, 0, 8, 0, '\t', 0)

    fmt.Fprintln(w, "Process each row as key-value pairs:")
    for iterator2.Next() {
        row := iterator2.Value()
        // Use Go time package to format unix timestamp
        // as a time with timezone layout (RFC3339)
        time := (row["time"].(time.Time)).
            Format(time.RFC3339)
        fmt.Fprintf(w, "%s\t%s\t%d\t%.1f\t%.1f\n",
            time, row["room"], row["co"], row["hum"], row["temp"])
    }
    w.Flush()
}

The sample code does the following:

  1. Defines a main package for your module and imports packages you’ll use in your code.
  2. Defines a Query() function.
  3. Instantiates the influxdb3 client with InfluxDB credentials and assigns it to a client variable.
  4. Defines a deferred function that closes the client when Query() has finished executing.
  5. Defines an SQL query to execute.
  6. Calls the client’s Query(ctx context.Context, query string) method and passes the SQL string as the query argument. Query() returns the following:
    • *influxdb3.QueryIterator: A custom iterator for reading data from the query result stream.
    • error: A Flight request error.

Query using InfluxQL

// query.go

package main

import (
    "context"
    "fmt"
    "io"
    "os"
    "text/tabwriter"
    "time"

    "github.com/InfluxCommunity/influxdb3-go/influxdb3/v1"
)

func InfluxQL() error {

    // Instantiate the client.
    client, err := influxdb3.New(influxdb3.ClientConfig{
        Host:       "https://cluster-host.com",
        Token:      "
DATABASE_TOKEN
",
        Database:   "
DATABASE_NAME
",
    })

    defer func(client *influxdb3.Client) {
        err := client.Close()
        if err != nil {
            panic(err)
        }
    }(client)

    query := `SELECT *
        FROM home
        WHERE time >= 1641124000s
        AND time <= 1641124000s + 8h`

    queryOptions := influxdb3.QueryOptions{
        QueryType: influxdb3.InfluxQL,
    }

    // Example 1: Query data and then read the schema and all data in the result stream.
    iterator, err := client.QueryWithOptions(context.Background(), &queryOptions, query)

    fmt.Fprintln(os.Stdout, "Read all data in the stream:")
    data, err := iterator.Raw().Reader.Read()
    fmt.Fprintln(os.Stdout, data)

    if err != nil {
        panic(err)
    }

    // Example 2: Query data, view the result schema, and then process result data row by row.
    iterator2, err = client.QueryWithOptions(context.Background(), &queryOptions, query)

    fmt.Fprintln(os.Stdout, "View the query result schema:")
    schema := iterator2.Raw().Reader.Schema()
    fmt.Fprintln(os.Stdout, schema)

    w := tabwriter.NewWriter(io.Discard, 4, 4, 1, ' ', 0)
    w.Init(os.Stdout, 0, 8, 0, '\t', 0)

    fmt.Fprintln(w, "Process each row as key-value pairs:")
    for iterator2.Next() {
        row := iterator2.Value()
        // Use Go time package to format unix timestamp
        // as a time with timezone layout (RFC3339)
        time := (row["time"].(time.Time)).
            Format(time.RFC3339)
        fmt.Fprintf(w, "%s\t%s\t%d\t%.1f\t%.1f\n",
            time, row["room"], row["co"], row["hum"], row["temp"])
    }
    w.Flush()
}

The sample code does the following:

  1. Defines a main package for your module and imports packages you’ll use in your code.

  2. Defines a Query() function.

  3. Instantiates the influxdb3 client with InfluxDB credentials and assigns it to a client variable.

  4. Defines a deferred function that closes the client when Query() has finished executing.

  5. Defines an InfluxQL query to execute.

  6. Calls the following client method:

    QueryWithOptions(ctx context.Context, options *QueryOptions, query string)

    and passes the following arguments:

    • options: A QueryOptions struct with the QueryType property set to influxdb3.InfluxQL.
    • query: A string. The SQL or InfluxQL query to execute. QueryWithOptions returns the following:
      • *influxdb3.QueryIterator: A custom iterator that provides access to query result data and metadata.
      • error: A Flight request error.

Run the example

  1. In your influxdb_go_client module directory, create a file named main.go.

  2. In main.go, enter the following sample code to define a main() executable function that calls the Query() function:

    package main

func main() {
  Query()
}

  3. In your terminal, enter the following command to install the necessary packages, build the module, and run the program:

    go build && go run influxdb_go_client

    The program executes the main() function that writes the data and prints the query results to the console.

Flight client query flight go sql influxql

Was this page helpful?

Thank you for your feedback!

© 2024 InfluxData, Inc.

What is your InfluxDB cluster URL?

Enter your InfluxDB cluster URL and we’ll update code examples for you.

Enter cluster URL

Thank you for your feedback!

Let us know what we can do better:

Thank you!

No thanks

Select a new date

Select a date in your bucket's retention period.

Update

The future of Flux

Flux is going into maintenance mode. You can continue using it as you currently are without any changes to your code.

Read more

InfluxDB v3 enhancements and InfluxDB Clustered is now generally available

New capabilities, including faster query performance and management tooling advance the InfluxDB v3 product line. InfluxDB Clustered is now generally available.

InfluxDB v3 performance and features

The InfluxDB v3 product line has seen significant enhancements in query performance and has made new management tooling available. These enhancements include an operational dashboard to monitor the health of your InfluxDB cluster, single sign-on (SSO) support in InfluxDB Cloud Dedicated, and new management APIs for tokens and databases.

Learn about the new v3 enhancements

InfluxDB Clustered general availability

InfluxDB Clustered is now generally available and gives you the power of InfluxDB v3 in your self-managed stack.

Talk to us about InfluxDB Clustered