InfluxDB 3 JavaScript Client

The JavaScript Client that provides a simple and convenient way to interact with InfluxDB 3. This package supports both writing data to InfluxDB and querying data using the FlightSQL client, which allows you to execute SQL queries against InfluxDB IOx.

We offer this Getting Started: InfluxDB 3.0 Javascript Client Library video to learn more about the library and see code examples.

Installation

To write or query InfluxDB 3, add @influxdata/influxdb3-client as a dependency to your project using your favorite package manager.

npm install --save @influxdata/influxdb3-client
yarn add @influxdata/influxdb3-client
pnpm add @influxdata/influxdb3-client
Copy

If you target Node.js, use @influxdata/influxdb3-client. It provides main (CJS), module (ESM), and browser (UMD) exports.

Usage

Set environment variables:

• INFLUX_HOST - InfluxDB address, eg. https://us-east-1-1.aws.cloud2.influxdata.com/
• INFLUX_TOKEN - access token
• INFLUX_DATABASE - database (bucket) name, eg. my-database

export INFLUX_HOST="<url>"
export INFLUX_DATABASE="<database>"
export INFLUX_TOKEN="<token>"
Copy

$env:INFLUX_HOST = "<url>"
$env:INFLUX_DATABASE = "<database>"
$env:INFLUX_TOKEN = "<token>"
Copy

set INFLUX_HOST=<url>
set INFLUX_DATABASE=<database>
set INFLUX_TOKEN=<token>
Copy

Create a client

To get started with influxdb client import @influxdata/influxdb3-client package.

import {InfluxDBClient, Point} from '@influxdata/influxdb3-client'
Copy

Assign values for environment variables, and then instantiate InfluxDBClient inside of an asynchronous function. Please note that token is a mandatory parameter. Make sure to close the client when it's no longer needed for writing or querying.

const host = process.env.INFLUX_HOST
const token = process.env.INFLUX_TOKEN
const database = process.env.INFLUX_DATABASE

async function main() {
    const client = new InfluxDBClient({host, token, database})

    // code goes here

    client.close()
}

main()
Copy

You can also use a provided no argument constructor for InfluxDBClient instantiation using environment variables:

async function main() {
    const client = new InfluxDBClient()

    // code goes here

    client.close()
}

main()
Copy

You can also instantiate InfluxDBClient with a connection string:

async function main() {
    const client = new InfluxDBClient('https://us-east-1-1.aws.cloud2.influxdata.com/?token=my-token&database=my-database')

    // code goes here

    client.close()
}

main()
Copy

Write data

To write data to InfluxDB, call client.write with data in line-protocol format and the database (or bucket) name.

const line = `stat,unit=temperature avg=20.5,max=45.0`
await client.write(line, database)
Copy

Query data

To query data stored in InfluxDB, call client.query with an SQL query and the database (or bucket) name. To change to using InfluxQL add a QueryOptions object with the type 'influxql' (e.g. client.query(query, database, { type: 'influxql'})).

// Execute query
const query = `
    SELECT *
    FROM "stat"
    WHERE
    time >= now() - interval '5 minute'
    AND
    "unit" IN ('temperature')
`
const queryResult = await client.query(query, database)

for await (const row of queryResult) {
    console.log(`avg is ${row.avg}`)
    console.log(`max is ${row.max}`)
}
Copy

or use a typesafe PointValues structure with client.queryPoints

const queryPointsResult = client.queryPoints(
    query,
    database,
    queryOptions
)

for await (const row of queryPointsResult) {
    console.log(`avg is ${row.getField('avg', 'float')}`)
    console.log(`max is ${row.getField('max', 'float')}`)
    console.log(`lp: ${row.asPoint('stat').toLineProtocol()}`)
}
Copy

Examples

For more advanced usage, see examples.

Feedback

If you need help, please use our Community Slack or Community Page.

New features and bugs can be reported on GitHub: https://github.com/InfluxCommunity/influxdb3-js

Contribution

To contribute to this project, fork the GitHub repository and send a pull request based on the main branch.

Development

Update the Flight Client

For now, we're responsible for generating the Flight client. However, its Protobuf interfaces may undergo changes over time.

To regenerate the Flight client, use the yarn flight command to execute the provided script. The script will clone the Flight Protobuf repository and generate new TypeScript files in ./src/generated/flight.

Generate files for mock server

To generate files needed for the mock server used in some tests, run the yarn flight:test command.

License

The InfluxDB 3 JavaScript Client is released under the MIT License.