Get started writing data

To write data to InfluxDB Cloud Dedicated using Python, use the influxdb_client_3 module. The following steps include setting up a Python virtual environment to scope dependencies to your current project.

1. Create a module directory and navigate into it–for example:

   mkdir influxdb_py_client && cd $_
   

2. Setup your Python virtual environment. Inside of your module directory:

   python -m venv envs/virtual-env
   

3. Activate the virtual environment.

   source ./envs/virtual-env/bin/activate
   

4. Install the client library package:

   pip install influxdb3-python
   

   The influxdb3-python package provides the influxdb_client_3 module and also installs the pyarrow package for working with Arrow data returned from queries.

5. In your terminal or editor, create a new file for your code–for example: write.py.

   touch write.py
   

6. Inside of write.py, enter the following sample code:

   from influxdb_client_3 import InfluxDBClient3
   import os
   
   # INFLUX_TOKEN is an environment variable you assigned to your
   # database WRITE token value.
   token = os.getenv('INFLUX_TOKEN')
   
   # host is the URL without protocol or trailing slash
   client = InfluxDBClient3(
       host='cluster-id.influxdb.io',
       org='',
       token=token,
       database='get-started'
   )
   
   lines = [
       "home,room=Living\ Room temp=21.1,hum=35.9,co=0i 1641024000",
       "home,room=Kitchen temp=21.0,hum=35.9,co=0i 1641024000",
       "home,room=Living\ Room temp=21.4,hum=35.9,co=0i 1641027600",
       "home,room=Kitchen temp=23.0,hum=36.2,co=0i 1641027600",
       "home,room=Living\ Room temp=21.8,hum=36.0,co=0i 1641031200",
       "home,room=Kitchen temp=22.7,hum=36.1,co=0i 1641031200",
       "home,room=Living\ Room temp=22.2,hum=36.0,co=0i 1641034800",
       "home,room=Kitchen temp=22.4,hum=36.0,co=0i 1641034800",
       "home,room=Living\ Room temp=22.2,hum=35.9,co=0i 1641038400",
       "home,room=Kitchen temp=22.5,hum=36.0,co=0i 1641038400",
       "home,room=Living\ Room temp=22.4,hum=36.0,co=0i 1641042000",
       "home,room=Kitchen temp=22.8,hum=36.5,co=1i 1641042000",
       "home,room=Living\ Room temp=22.3,hum=36.1,co=0i 1641045600",
       "home,room=Kitchen temp=22.8,hum=36.3,co=1i 1641045600",
       "home,room=Living\ Room temp=22.3,hum=36.1,co=1i 1641049200",
       "home,room=Kitchen temp=22.7,hum=36.2,co=3i 1641049200",
       "home,room=Living\ Room temp=22.4,hum=36.0,co=4i 1641052800",
       "home,room=Kitchen temp=22.4,hum=36.0,co=7i 1641052800",
       "home,room=Living\ Room temp=22.6,hum=35.9,co=5i 1641056400",
       "home,room=Kitchen temp=22.7,hum=36.0,co=9i 1641056400",
       "home,room=Living\ Room temp=22.8,hum=36.2,co=9i 1641060000",
       "home,room=Kitchen temp=23.3,hum=36.9,co=18i 1641060000",
       "home,room=Living\ Room temp=22.5,hum=36.3,co=14i 1641063600",
       "home,room=Kitchen temp=23.1,hum=36.6,co=22i 1641063600",
       "home,room=Living\ Room temp=22.2,hum=36.4,co=17i 1641067200",
       "home,room=Kitchen temp=22.7,hum=36.5,co=26i 1641067200"
   ]
   
   client.write(lines,write_precision='s')
   

   The sample does the following:

   1. Imports the InfluxDBClient3 object from the influxdb_client_3 module.

   2. Calls the InfluxDBClient3() constructor to instantiate an InfluxDB client configured with the following credentials:

      • host: InfluxDB Cloud Dedicated cluster hostname (URL without protocol or trailing slash)
      • org: an empty or arbitrary string (InfluxDB ignores this parameter)
      • token: an InfluxDB database token with write access to the target database. Store this in a secret store or environment variable to avoid exposing the raw token string.
      • database: the name of the InfluxDB Cloud Dedicated database to write to

   3. Defines a list of line protocol strings where each string represents a data record.

   4. Calls the client.write() method with the line protocol record list and write options.

      Because the timestamps in the sample line protocol are in second precision, the example passes the write_precision='s' option to set thetimestamp precision to seconds.

7. To execute the module and write line protocol to your InfluxDB Cloud Dedicated database, enter the following command in your terminal:

   python write.py
   

To write data to InfluxDB Cloud Dedicated using Go, use the InfluxDB v3 influxdb3-go client library package.

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

   mkdir influxdb_go_client && cd $_
   

2. Initialize a new Go module in the directory.

   go mod init influxdb_go_client
   

3. In your terminal or editor, create a new file for your code–for example: write.go.

   touch write.go
   

4. Inside of write.go, enter the following sample code:

   package main
   
   import (
     "context"
     "os"
     "fmt"
     "log"
   
     "github.com/InfluxCommunity/influxdb3-go/influxdb3"
   )
   
   // Write line protocol data to InfluxDB
   func WriteLineProtocol() error {
     // INFLUX_TOKEN is an environment variable you assigned to your
     // database WRITE token value.
     token := os.Getenv("INFLUX_TOKEN")
     database := os.Getenv("INFLUX_DATABASE")
   
     // Initialize a client with URL and token,
     // and set the timestamp precision for writes.
     client, err := influxdb3.New(influxdb3.ClientConfig{
       Host:     "https://cluster-id.influxdb.io",
       Token:    token,
       Database: database,
   	    WriteOptions: &influxdb3.WriteOptions{Precision: lineprotocol.Second},
     })
   
     // Close the client when the function returns.
     defer func(client *influxdb3.Client) {
       err := client.Close()
       if err != nil {
         panic(err)
       }
     }(client)
   
     // Define line protocol records to write.
     // Use a raw string literal (denoted by backticks)
     // to preserve backslashes and prevent interpretation
     // of escape sequences--for example, escaped spaces in tag values.
     lines := [...]string{
       `home,room=Living\ Room temp=21.1,hum=35.9,co=0i 1641124000`,
       `home,room=Kitchen temp=21.0,hum=35.9,co=0i 1641124000`,
       `home,room=Living\ Room temp=21.4,hum=35.9,co=0i 1641127600`,
       `home,room=Kitchen temp=23.0,hum=36.2,co=0i 1641127600`,
       `home,room=Living\ Room temp=21.8,hum=36.0,co=0i 1641131200`,
       `home,room=Kitchen temp=22.7,hum=36.1,co=0i 1641131200`,
       `home,room=Living\ Room temp=22.2,hum=36.0,co=0i 1641134800`,
       `home,room=Kitchen temp=22.4,hum=36.0,co=0i 1641134800`,
       `home,room=Living\ Room temp=22.2,hum=35.9,co=0i 1641138400`,
       `home,room=Kitchen temp=22.5,hum=36.0,co=0i 1641138400`,
       `home,room=Living\ Room temp=22.4,hum=36.0,co=0i 1641142000`,
       `home,room=Kitchen temp=22.8,hum=36.5,co=1i 1641142000`,
       `home,room=Living\ Room temp=22.3,hum=36.1,co=0i 1641145600`,
       `home,room=Kitchen temp=22.8,hum=36.3,co=1i 1641145600`,
       `home,room=Living\ Room temp=22.3,hum=36.1,co=1i 1641149200`,
       `home,room=Kitchen temp=22.7,hum=36.2,co=3i 1641149200`,
       `home,room=Living\ Room temp=22.4,hum=36.0,co=4i 1641152800`,
       `home,room=Kitchen temp=22.4,hum=36.0,co=7i 1641152800`,
       `home,room=Living\ Room temp=22.6,hum=35.9,co=5i 1641156400`,
       `home,room=Kitchen temp=22.7,hum=36.0,co=9i 1641156400`,
       `home,room=Living\ Room temp=22.8,hum=36.2,co=9i 1641160000`,
       `home,room=Kitchen temp=23.3,hum=36.9,co=18i 1641160000`,
       `home,room=Living\ Room temp=22.5,hum=36.3,co=14i 1641163600`,
       `home,room=Kitchen temp=23.1,hum=36.6,co=22i 1641163600`,
       `home,room=Living\ Room temp=22.2,hum=36.4,co=17i 1641167200`,
       `home,room=Kitchen temp=22.7,hum=36.5,co=26i 1641167200`,
     }
   
     // Iterate over the lines array and write each line
     // separately to InfluxDB
     for _, record := range lines {
       err = client.Write(context.Background(), []byte(record))
       if err != nil {
         log.Fatalf("Error writing line protocol: %v", err)
       }
     }
   
     if err != nil {
       panic(err)
     }
   
     fmt.Println("Data has been written successfully.")
     return nil
   }
   

   The sample does the following:

   1. Imports required packages.

   2. Defines a WriteLineProtocol() function that does the following:

      1. To instantiate the client, calls the influxdb3.New(influxdb3.ClientConfig) function and passes the following:

         • Host: the InfluxDB Cloud Dedicated cluster URL

         • Database: The name of your InfluxDB Cloud Dedicated database

         • Token: an InfluxDB database token with write access to the specified database. Store this in a secret store or environment variable to avoid exposing the raw token string.

         • WriteOptions: influxdb3.WriteOptions options for writing to InfluxDB.

           Because the timestamps in the sample line protocol are in second precision, the example passes the Precision: lineprotocol.Second option to set the timestamp precision to seconds.

      2. Defines a deferred function that closes the client when the function returns.

      3. Defines an array of line protocol strings where each string represents a data record.

      4. Iterates through the array of line protocol and calls the write client’s Write() method to write each line of line protocol separately to InfluxDB.

5. In your editor, create a main.go file and enter the following sample code that calls the WriteLineProtocol() function:

   package main
   
   // Module main function
   func main() {	
     WriteLineProtocol()
   }
   

6. In your terminal, enter the following command to install the packages listed in imports, build the influxdb_go_client module, and execute the main() function:

   go mod tidy && go build && go run influxdb_go_client
   

   The program writes the line protocol to your InfluxDB Cloud Dedicated database.

1. If you haven’t already, follow the instructions for Downloading and installing Node.js and npm for your system.

2. In your terminal, enter the following command to create a influxdb_js_client project and package.json file:

   npm init -y -w influxdb_js_client
   

3. Change into the influxdb_js_client directory.

   cd influxdb_js_client
   

4. Install the @influxdata/influxdb3-client JavaScript client library as a dependency to your project:

   npm install --save @influxdata/influxdb3-client
   

5. In your terminal or editor, create a write.mjs file. The .mjs extension tells the Node.js interpreter that this is an ES6 module.

6. Inside of write.mjs, enter the following sample code:

   // write.mjs
   import { InfluxDBClient } from "@influxdata/influxdb3-client";
   
   /**
   * Set InfluxDB credentials.
   */
   const host = "https://cluster-id.influxdb.io";
   const database = "get-started";
   /**
   * INFLUX_TOKEN is an environment variable you assigned to your
   * database WRITE token value.
   */
   const token = process.env.INFLUX_TOKEN;
   
   /**
   * Write line protocol to InfluxDB using the JavaScript client library.
   */
   export async function writeLineProtocol() {
     /**
     * Instantiate an InfluxDBClient
     */
     const client = new InfluxDBClient({ host, token });
   
     /**
     * Define line protocol records to write.
     */
     const records = [
       `home,room=Living\\ Room temp=21.1,hum=35.9,co=0i 1641124000`,
       `home,room=Kitchen temp=21.0,hum=35.9,co=0i 1641124000`,
       `home,room=Living\\ Room temp=21.4,hum=35.9,co=0i 1641127600`,
       `home,room=Kitchen temp=23.0,hum=36.2,co=0 1641127600`,
       `home,room=Living\\ Room temp=21.8,hum=36.0,co=0i 1641131200`,
       `home,room=Kitchen temp=22.7,hum=36.1,co=0i 1641131200`,
       `home,room=Living\\ Room temp=22.2,hum=36.0,co=0i 1641134800`,
       `home,room=Kitchen temp=22.4,hum=36.0,co=0i 1641134800`,
       `home,room=Living\\ Room temp=22.2,hum=35.9,co=0i 1641138400`,
       `home,room=Kitchen temp=22.5,hum=36.0,co=0i 1641138400`,
       `home,room=Living\\ Room temp=22.4,hum=36.0,co=0i 1641142000`,
       `home,room=Kitchen temp=22.8,hum=36.5,co=1i 1641142000`,
       `home,room=Living\\ Room temp=22.3,hum=36.1,co=0i 1641145600`,
       `home,room=Kitchen temp=22.8,hum=36.3,co=1i 1641145600`,
       `home,room=Living\\ Room temp=22.3,hum=36.1,co=1i 1641149200`,
       `home,room=Kitchen temp=22.7,hum=36.2,co=3i 1641149200`,
       `home,room=Living\\ Room temp=22.4,hum=36.0,co=4i 1641152800`,
       `home,room=Kitchen temp=22.4,hum=36.0,co=7i 1641152800`,
       `home,room=Living\\ Room temp=22.6,hum=35.9,co=5i 1641156400`,
       `home,room=Kitchen temp=22.7,hum=36.0,co=9i 1641156400`,
       `home,room=Living\\ Room temp=22.8,hum=36.2,co=9i 1641160000`,
       `home,room=Kitchen temp=23.3,hum=36.9,co=18i 1641160000`,
       `home,room=Living\\ Room temp=22.5,hum=36.3,co=14i 1641163600`,
       `home,room=Kitchen temp=23.1,hum=36.6,co=22i 1641163600`,
       `home,room=Living\\ Room temp=22.2,hum=36.4,co=17i 1641167200`,
       `home,room=Kitchen temp=22.7,hum=36.5,co=26i 1641167200`,
     ];
   
     /**
     * Creates an array that contains separate write request promises
     * for all the records.
     */
     const writePromises = records.map((record) => {
       return client.write(record, database, "", { precision: "s" })
       .then(() => `Data has been written successfully: ${record}`,
             () => `Failed writing data: ${record}`);
     });
   
     /**
     * Wait for all the write promises to settle, and then output the results.
     */  
     const writeResults = await Promise.allSettled(writePromises);
     writeResults.forEach(write => console.log(write.value));
   
     /** Close the client to release resources. */
     await client.close();
   }
   

   The sample code does the following:

   1. Imports the InfluxDBClient class.

   2. Calls the new InfluxDBClient() constructor and passes a ClientOptions object to instantiate a client configured with InfluxDB credentials.

      • host: your InfluxDB Cloud Dedicated cluster URL
      • token: a database token with write access to the specified database. Store this in a secret store or environment variable to avoid exposing the raw token string.

   3. Defines a list of line protocol strings where each string represents a data record.

   4. Calls the client’s write() method for each record, defines the success or failure message to return, and collects the pending promises into the writePromises array. Each call to write() passes the following arguments:

      • record: the line protocol record
      • database: the name of the InfluxDB Cloud Dedicated database to write to
      • {precision}: a WriteOptions object that sets the precision value.

      Because the timestamps in the sample line protocol are in second precision, the example passes s as the precision value to set the write timestamp precision to seconds.

   5. Calls Promise.allSettled() with the promises array to pause execution until the promises have completed, and then assigns the array containing success and failure messages to a writeResults constant.

   6. Iterates over and prints the messages in writeResults.

   7. Closes the client to release resources.

7. In your terminal or editor, create an index.mjs file.

8. Inside of index.mjs, enter the following sample code to import and call writeLineProtocol():

   // index.mjs
   import { writeLineProtocol } from "./write.mjs";
   
   /**
   * Execute the client functions.
   */
   async function main() {
     /** Write line protocol data to InfluxDB. */
     await writeLineProtocol();
   }
   
   main();
   

9. In your terminal, execute index.mjs to write to InfluxDB Cloud Dedicated:

   node index.mjs
   

1. If you haven’t already, follow the Microsoft.com download instructions to install .NET and the dotnet CLI.

2. In your terminal, create an executable C# project using the .NET console template.

   dotnet new console --name influxdb_csharp_client
   

3. Change into the generated influxdb_csharp_client directory.

   cd influxdb_csharp_client
   

4. Run the following command to install the latest version of the InfluxDB v3 C# client library.

   dotnet add package InfluxDB3.Client
   

5. In your editor, create a Write.cs file and enter the following sample code:

   // Write.cs
   
   using System;
   using System.Threading.Tasks;
   using InfluxDB3.Client;
   using InfluxDB3.Client.Query;
   
   namespace InfluxDBv3;
   
   public class Write
   {
     /**
       * Writes line protocol to InfluxDB using the C# .NET client
       * library.
       */ 
     public static async Task WriteLines()
     {
       // Set InfluxDB credentials
       const string host = "https://cluster-id.influxdb.io";
       string? database = "get-started";
   
       /**
         * INFLUX_TOKEN is an environment variable you assigned to your
         * database WRITE token value.
         */
       string? token = System.Environment
           .GetEnvironmentVariable("INFLUX_TOKEN");
   
       // Instantiate the InfluxDB client with credentials.
       using var client = new InfluxDBClient(
           host, token: token, database: database);
   
       /** 
         * Define an array of line protocol strings to write.
         * Include an additional backslash to preserve backslashes
         * and prevent interpretation of escape sequences---for example,
         * escaped spaces in tag values.
         */
       string[] lines = new string[] {
             "home,room=Living\\ Room temp=21.1,hum=35.9,co=0i 1641024000",
             "home,room=Kitchen temp=21.0,hum=35.9,co=0i 1641024000",
             "home,room=Living\\ Room temp=21.4,hum=35.9,co=0i 1641027600",
             "home,room=Kitchen temp=23.0,hum=36.2,co=0i 1641027600",
             "home,room=Living\\ Room temp=21.8,hum=36.0,co=0i 1641031200",
             "home,room=Kitchen temp=22.7,hum=36.1,co=0i 1641031200",
             "home,room=Living\\ Room temp=22.2,hum=36.0,co=0i 1641034800",
             "home,room=Kitchen temp=22.4,hum=36.0,co=0i 1641034800",
             "home,room=Living\\ Room temp=22.2,hum=35.9,co=0i 1641038400",
             "home,room=Kitchen temp=22.5,hum=36.0,co=0i 1641038400",
             "home,room=Living\\ Room temp=22.4,hum=36.0,co=0i 1641042000",
             "home,room=Kitchen temp=22.8,hum=36.5,co=1i 1641042000",
             "home,room=Living\\ Room temp=22.3,hum=36.1,co=0i 1641045600",
             "home,room=Kitchen temp=22.8,hum=36.3,co=1i 1641045600",
             "home,room=Living\\ Room temp=22.3,hum=36.1,co=1i 1641049200",
             "home,room=Kitchen temp=22.7,hum=36.2,co=3i 1641049200",
             "home,room=Living\\ Room temp=22.4,hum=36.0,co=4i 1641052800",
             "home,room=Kitchen temp=22.4,hum=36.0,co=7i 1641052800",
             "home,room=Living\\ Room temp=22.6,hum=35.9,co=5i 1641056400",
             "home,room=Kitchen temp=22.7,hum=36.0,co=9i 1641056400",
             "home,room=Living\\ Room temp=22.8,hum=36.2,co=9i 1641060000",
             "home,room=Kitchen temp=23.3,hum=36.9,co=18i 1641060000",
             "home,room=Living\\ Room temp=22.5,hum=36.3,co=14i 1641063600",
             "home,room=Kitchen temp=23.1,hum=36.6,co=22i 1641063600",
             "home,room=Living\\ Room temp=22.2,hum=36.4,co=17i 1641067200",
             "home,room=Kitchen temp=22.7,hum=36.5,co=26i 1641067200"
       };
   
       // Write each record separately.
       foreach (string line in lines)
       {
         // Write the record to InfluxDB with timestamp precision in seconds.
         await client.WriteRecordAsync(
             record: line, precision: WritePrecision.S);
         Console.WriteLine(
             "Data has been written successfully: {0,-30}", line);
       }
     }
   }
   

   The sample does the following:

   1. Calls the new InfluxDBClient() constructor to instantiate a client configured with InfluxDB credentials.

      • host: your InfluxDB Cloud Dedicated cluster URL
      • database: the name of the InfluxDB Cloud Dedicated database to write to
      • token: a database token with write access to the specified bucket. Store this in a secret store or environment variable to avoid exposing the raw token string.

      Instantiating the client with the using statement ensures that the client is disposed of when it’s no longer needed.

   2. Defines an array of line protocol strings where each string represents a data record.

   3. Calls the client’s WriteRecordAsync() method to write each line protocol record to InfluxDB.

      Because the timestamps in the sample line protocol are in second precision, the example passes the WritePrecision.S enum value to the precision: option to set thetimestamp precision to seconds.

6. In your editor, open the Program.cs file and replace its contents with the following:

   // Program.cs
   
   using System;
   using System.Threading.Tasks;
   
   namespace InfluxDBv3;
   
   public class Program
   {
     public static async Task Main()
     {
       await Write.WriteLineProtocol();
     }
   }
   

   The Program class shares the same InfluxDBv3 namespace as the Write class you defined in the preceding step and defines a Main() function that calls Write.WriteLineProtocol(). The dotnet CLI recognizes Program.Main() as the entry point for your program.

7. To build and execute the program and write the line protocol to your InfluxDB Cloud Dedicated database, enter the following command in your terminal:

   dotnet run
   

The tutorial assumes using Maven version 3.9 and Java version >= 15.

1. If you haven’t already, follow the instructions to download and install the Java JDK and Maven for your system.

2. In your terminal or editor, use Maven to generate a project–for example:

   mvn org.apache.maven.plugins:maven-archetype-plugin:3.1.2:generate \
   -DarchetypeArtifactId="maven-archetype-quickstart" \
   -DarchetypeGroupId="org.apache.maven.archetypes" -DarchetypeVersion="1.4" \
   -DgroupId="com.influxdbv3" -DartifactId="influxdb_java_client"
   -Dversion="1.0"
   

   Maven creates the <artifactId> directory (./influxdb_java_client) that contains a pom.xml and scaffolding for your com.influxdbv3.influxdb_java_client Java application.

3. In your terminal or editor, change into the ./influxdb_java_client directory–for example:

   cd ./influxdb_java_client
   

4. In your editor, open the pom.xml Maven configuration file and add the com.influxdb.influxdb3-java client library into dependencies.

   ...
   <dependencies>
     ...
     <dependency>
     <groupId>com.influxdb</groupId>
     <artifactId>influxdb3-java</artifactId>
     <version>0.1.0</version>
     </dependency>
     ...
   </dependencies>
   

5. To validate your pom.xml, run Maven’s validate command–for example, enter the following in your terminal:

   mvn validate
   

6. In your editor, navigate to the ./influxdb_java_client/src/main/java/com/influxdbv3 directory and create a Write.java file.

7. In Write.java, enter the following sample code:

   // Write.java
   package com.influxdbv3;
   
   import java.util.List;
   import com.influxdb.v3.client.InfluxDBClient;
   import com.influxdb.v3.client.write.WriteOptions;
   import com.influxdb.v3.client.write.WritePrecision;
   
   /**
     * Writes line protocol to InfluxDB using the Java client
     * library.
     */ 
   public final class Write {
       /**
       * Write data to InfluxDB v3.
       */
       private Write() {
           //not called
       }
   
       /**
         * @throws Exception
         */
       public static void writeLineProtocol() throws Exception {
   
           // Set InfluxDB credentials
           final String host = "https://cluster-id.influxdb.io";
           final String database = "get-started";
   
           /**
             * INFLUX_TOKEN is an environment variable you assigned to your
             * database WRITE token value.
             */
           final char[] token = (System.getenv("INFLUX_TOKEN")).
           toCharArray();
   
           // Instantiate the InfluxDB client.
           try (InfluxDBClient client = InfluxDBClient.getInstance(host,
           token, database)) {
               // Create a list of line protocol records.
               final List<String> records = List.of(
                 "home,room=Living\\ Room temp=21.1,hum=35.9,co=0i 1641024000",
                 "home,room=Kitchen temp=21.0,hum=35.9,co=0i 1641024000",
                 "home,room=Living\\ Room temp=21.4,hum=35.9,co=0i 1641027600",
                 "home,room=Kitchen temp=23.0,hum=36.2,co=0i 1641027600",
                 "home,room=Living\\ Room temp=21.8,hum=36.0,co=0i 1641031200",
                 "home,room=Kitchen temp=22.7,hum=36.1,co=0i 1641031200",
                 "home,room=Living\\ Room temp=22.2,hum=36.0,co=0i 1641034800",
                 "home,room=Kitchen temp=22.4,hum=36.0,co=0i 1641034800",
                 "home,room=Living\\ Room temp=22.2,hum=35.9,co=0i 1641038400",
                 "home,room=Kitchen temp=22.5,hum=36.0,co=0i 1641038400",
                 "home,room=Living\\ Room temp=22.4,hum=36.0,co=0i 1641042000",
                 "home,room=Kitchen temp=22.8,hum=36.5,co=1i 1641042000",
                 "home,room=Living\\ Room temp=22.3,hum=36.1,co=0i 1641045600",
                 "home,room=Kitchen temp=22.8,hum=36.3,co=1i 1641045600",
                 "home,room=Living\\ Room temp=22.3,hum=36.1,co=1i 1641049200",
                 "home,room=Kitchen temp=22.7,hum=36.2,co=3i 1641049200",
                 "home,room=Living\\ Room temp=22.4,hum=36.0,co=4i 1641052800",
                 "home,room=Kitchen temp=22.4,hum=36.0,co=7i 1641052800",
                 "home,room=Living\\ Room temp=22.6,hum=35.9,co=5i 1641056400",
                 "home,room=Kitchen temp=22.7,hum=36.0,co=9i 1641056400",
                 "home,room=Living\\ Room temp=22.8,hum=36.2,co=9i 1641060000",
                 "home,room=Kitchen temp=23.3,hum=36.9,co=18i 1641060000",
                 "home,room=Living\\ Room temp=22.5,hum=36.3,co=14i 1641063600",
                 "home,room=Kitchen temp=23.1,hum=36.6,co=22i 1641063600",
                 "home,room=Living\\ Room temp=22.2,hum=36.4,co=17i 1641067200",
                 "home,room=Kitchen temp=22.7,hum=36.5,co=26i 1641067200"
               );
   
               /**
                * Write each record separately to InfluxDB with timestamp
                * precision in seconds.
                * If no error occurs, print a success message.
                * */
               for (String record : records) {
                   client.writeRecord(record, new WriteOptions(null, null,
                   WritePrecision.S));
                   System.out.printf("Data has been written successfully:
                   %s%n", record);
               }
           }
       }
   }
   

   The sample code does the following:

   1. Imports the following classes:

      • java.util.List;
      • com.influxdb.v3.client.InfluxDBClient
      • com.influxdb.v3.client.write.WriteParameters
      • com.influxdb.v3.client.write.WritePrecision

   2. Calls InfluxDBClient.getInstance() to instantiate a client configured with InfluxDB credentials.

      • host: your InfluxDB Cloud Dedicated cluster URL
      • database: the name of the InfluxDB Cloud Dedicated database to write to
      • token: a database token with write access to the specified database. Store this in a secret store or environment variable to avoid exposing the raw token string.

   3. Defines a list of line protocol strings where each string represents a data record.

   4. Calls the client’s writeRecord() method to write each record separately to InfluxDB.

      Because the timestamps in the sample line protocol are in second precision, the example passes the WritePrecision.S enum value as the precision argument to set the write timestamp precision to seconds.

8. In your editor, open the App.java file (created by Maven) and replace its contents with the following sample code:

   // App.java
   
   package com.influxdbv3;
   
   /**
   * Execute the client functions.
   *
   */
   public class App {
   
       /**
       * @param args
       * @throws Exception
       */
       public static void main(final String[] args) throws Exception {
           // Write data to InfluxDB v3.
           Write.writeLineProtocol();
       }
   }
   

   • The App class and Write class are part of the same com.influxdbv3 package (your project groupId).
   • App defines a main() function that calls Write.writeLineProtocol().

9. In your terminal or editor, use Maven to to install dependencies and compile the project code–for example:

   mvn compile
   

10. In your terminal or editor, execute App.main() to write to InfluxDB–for example, using Maven:

    mvn exec:java -Dexec.mainClass="com.influxdbv3.App"