Get started writing data

Use Telegraf to consume line protocol, and then write it to InfluxDB Cloud Dedicated.

1. If you haven’t already, follow the instructions to download and install Telegraf.

2. Copy and save the home sensor data sample to a file on your local system–for example, home.lp.

   cat <<- EOF > home.lp
   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
   EOF

3. Run the following command to generate a Telegraf configuration file (./telegraf.conf) that enables the inputs.file and outputs.influxdb_v2 plugins:

   telegraf --sample-config \
     --input-filter file \
     --output-filter influxdb_v2 \
     > telegraf.conf

4. In your editor, open ./telegraf.conf and configure the following:

   • file input plugin: In the [[inputs.file]].files list, replace "/tmp/metrics.out" with your sample data filename. If Telegraf can’t find a file when started, it stops processing and exits.

     [[inputs.file]]
       ## Files to parse each interval.  Accept standard unix glob matching rules,
       ## as well as ** to match recursive files and directories.
       files = ["home.lp"]

   • output-influxdb_v2 output plugin: In the [[outputs.influxdb_v2]] section, replace the default values with the following configuration for your InfluxDB Cloud Dedicated database:

     [[outputs.influxdb_v2]]
       # InfluxDB cluster URL
       urls = ["${INFLUX_HOST}"]
     
       # INFLUX_TOKEN is an environment variable you assigned to your database token
       token = "${INFLUX_TOKEN}"
     
       # An empty string (InfluxDB ignores this parameter)
       organization = ""
     
       # Database name
       bucket = "get-started"

     The example configuration uses the following InfluxDB credentials:

     • urls: an array containing your INFLUX_HOST environment variable
     • token: your INFLUX_TOKEN environment variable
     • organization: an empty string (InfluxDB ignores this parameter)
     • bucket: the name of the database to write to

5. To write the data, start the telegraf daemon with the following options:

   • --config: Specifies the path of the configuration file.
   • --once: Runs a single Telegraf collection cycle for the configured inputs and outputs, and then exits.

   Enter the following command in your terminal:

   telegraf --once --config ./telegraf.conf

   If the write is successful, the output is similar to the following:

   2023-05-31T20:09:08Z D! [agent] Starting service inputs
   2023-05-31T20:09:19Z D! [outputs.influxdb_v2] Wrote batch of 52 metrics in 348.008167ms
   2023-05-31T20:09:19Z D! [outputs.influxdb_v2] Buffer fullness: 0 / 10000 metrics

Telegraf and its plugins provide many options for reading and writing data. To learn more, see how to use Telegraf to write data.

Write data with your existing workloads that already use the InfluxDB v1 /write API endpoint.

To write data to InfluxDB using the InfluxDB v1 HTTP API, send a request to the InfluxDB API /write endpoint using the POST request method.

POST https://cluster-id.a.influxdb.io/write

Include the following with your request:

• Headers:
  • Authorization: Bearer <INFLUX_TOKEN>
  • Content-Type: text/plain; charset=utf-8
  • Accept: application/json
• Query parameters:
  • db: InfluxDB database name
  • precision:timestamp precision (default is ns)
• Request body: Line protocol as plain text

The following example uses cURL and the InfluxDB v1 API to write line protocol to InfluxDB:

response=$(curl --silent \
  "https://cluster-id.a.influxdb.io
/write?db=get-started&precision=s" \
  --header "Authorization: Bearer 
DATABASE_TOKEN
" \
  --header "Content-type: text/plain; charset=utf-8" \
  --header "Accept: application/json" \
  --write-out "\n%{response_code}" \
  --data-binary "
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
")

# Extract the response body (all but the last line)
response_body=$(echo "$response" | head -n -1)

# Extract the HTTP status code (the last line)
response_code=$(echo "$response" | tail -n 1)

echo "$response_code"
if [[ $response_body ]]; then
  echo "$response_body"
fi

Replace the following:

• DATABASE_TOKEN: a database token with sufficient permissions to the specified database

If successful, the output is an HTTP 204 No Content status code; otherwise, the error status code and failure message.

204

To write data to InfluxDB using the InfluxDB v2 HTTP API, send a request to the InfluxDB API /api/v2/write endpoint using the POST request method.

POST https://cluster-id.a.influxdb.io/api/v2/write

Include the following with your request:

• Headers:
  • Authorization: Bearer <INFLUX_TOKEN>
  • Content-Type: text/plain; charset=utf-8
  • Accept: application/json
• Query parameters:
  • bucket: InfluxDB database name
  • precision:timestamp precision (default is ns)
• Request body: Line protocol as plain text

The following example uses cURL and the InfluxDB v2 API to write line protocol to InfluxDB:

response=$(curl --silent --write-out "%{response_code}:-%{errormsg}" \
  "https://cluster-id.a.influxdb.io
/api/v2/write?bucket=get-started&precision=s" \
  --header "Authorization: Bearer 
DATABASE_TOKEN
" \
  --header "Content-Type: text/plain; charset=utf-8" \
  --header "Accept: application/json" \
  --data-binary "
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
")

# Format the response code and error message output.
response_code=${response%%:-*}
errormsg=${response#*:-}

# Remove leading and trailing whitespace from errormsg
errormsg=$(echo "${errormsg}" | tr -d '[:space:]')

echo "$response_code"
if [[ $errormsg ]]; then
  echo "$errormsg"
fi

Replace the following:

• DATABASE_TOKEN: a database token with sufficient permissions to the specified database

If successful, the output is an HTTP 204 No Content status code; otherwise, the error status code and failure message.

204

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 -p influxdb_py_client && cd influxdb_py_client

2. Setup your Python virtual environment. Inside of your module directory, enter the following command:

   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 hostname without protocol or trailing slash
   client = InfluxDBClient3(
       host='cluster-id.a.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`**: a
     [database token](/influxdb3/cloud-dedicated/admin/tokens/#database-tokens)
     with write access to the specified 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 the
   [timestamp precision](/influxdb3/cloud-dedicated/reference/glossary/#timestamp-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:

<!--pytest.mark.skip-->

```bash
python write.py

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

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

   mkdir -p influxdb_go_client && cd influxdb_go_client

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/v2/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.a.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`**: a
          [database token](/influxdb3/cloud-dedicated/admin/tokens/#database-tokens)
          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](/influxdb3/cloud-dedicated/reference/glossary/#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.
</code></pre>
<ol start="5">
<li>
<p>In your editor, create a <code>main.go</code> file and enter the following sample code
that calls the <code>WriteLineProtocol()</code> function:</p>


<div class="highlight"><pre tabindex="0" class="chroma"><code class="language-go" data-lang="go"><span class="line"><span class="cl"><span class="kn">package</span><span class="w"> </span><span class="nx">main</span><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="c1">// Module main function</span><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="kd">func</span><span class="w"> </span><span class="nf">main</span><span class="p">()</span><span class="w"> </span><span class="p">{</span><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="w">  </span><span class="nf">WriteLineProtocol</span><span class="p">()</span><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="p">}</span></span></span></code></pre></div>
</li>
<li>
<p>To install dependencies and write the data to your InfluxDB Cloud Dedicated
database, enter the following command into your terminal:</p>
<!--pytest.mark.skip-->


<div class="highlight"><pre tabindex="0" class="chroma"><code class="language-bash" data-lang="bash"><span class="line"><span class="cl">go mod tidy <span class="o">&amp;&amp;</span> go run influxdb_go_client</span></span></code></pre></div>
</li>
</ol>
<p>If successful, the output is the success message; otherwise, error details and
the failure message.</p>

</div>


<!------------------------------- END GO CONTENT ------------------------------>

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 directory for your project:

   mkdir -p influxdb_js_client && cd influxdb_js_client

3. Inside of influxdb_js_client, enter the following command to initialize a package. This example configures the package to use ECMAScript modules (ESM).

   npm init -y; npm pkg set type="module"

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.js file.

   touch write.js

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

   // write.js
   import { InfluxDBClient } from '@influxdata/influxdb3-client';
   
   /**
    * Set InfluxDB credentials.
    */
   const host = 'cluster-id.a.influxdb.io

‘; const database = ‘get-started’; /** * INFLUX_TOKEN is an environment variable you assigned to your * 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](/influxdb3/cloud-dedicated/admin/tokens/#database-tokens)
      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](/influxdb3/cloud-dedicated/reference/glossary/#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.
</code></pre>
<ol start="7">
<li>
<p>In your terminal or editor, create an <code>index.js</code> file.</p>
</li>
<li>
<p>Inside of <code>index.js</code>, enter the following sample code to import and call
<code>writeLineProtocol()</code>:</p>


<div class="highlight"><pre tabindex="0" class="chroma"><code class="language-js" data-lang="js"><span class="line"><span class="cl"><span class="c1">// index.js
</span></span></span><span class="line"><span class="cl"><span class="kr">import</span> <span class="p">{</span> <span class="nx">writeLineProtocol</span> <span class="p">}</span> <span class="nx">from</span> <span class="s1">&#39;./write.js&#39;</span><span class="p">;</span>
</span></span><span class="line"><span class="cl">
</span></span><span class="line"><span class="cl"><span class="cm">/**
</span></span></span><span class="line"><span class="cl"><span class="cm"> * Execute the client functions.
</span></span></span><span class="line"><span class="cl"><span class="cm"> */</span>
</span></span><span class="line"><span class="cl"><span class="kr">async</span> <span class="kd">function</span> <span class="nx">main</span><span class="p">()</span> <span class="p">{</span>
</span></span><span class="line"><span class="cl">  <span class="cm">/** Write line protocol data to InfluxDB. */</span>
</span></span><span class="line"><span class="cl">  <span class="kr">await</span> <span class="nx">writeLineProtocol</span><span class="p">();</span>
</span></span><span class="line"><span class="cl"><span class="p">}</span>
</span></span><span class="line"><span class="cl">
</span></span><span class="line"><span class="cl"><span class="nx">main</span><span class="p">();</span></span></span></code></pre></div>
</li>
<li>
<p>In your terminal, execute <code>index.js</code> to write to InfluxDB Cloud Dedicated:</p>
<!--pytest.mark.skip-->


<div class="highlight"><pre tabindex="0" class="chroma"><code class="language-bash" data-lang="bash"><span class="line"><span class="cl">node index.js</span></span></code></pre></div>
</li>
</ol>

</div>


If successful, the output is the success message; otherwise, error details and
the failure message.

<!---------------------------- END NODE.JS CONTENT --------------------------->

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 3 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.a.influxdb.io
   

“; string? database = “get-started”;

    /**
      * INFLUX_TOKEN is an environment variable you assigned to your
      * 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](/influxdb3/cloud-dedicated/admin/tokens/#database-tokens)
      with _write_ access to the specified database. _Store this in a secret
      store or environment variable to avoid exposing the raw token string._

    _The `using` statement ensures that the program disposes of the
    client 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](https://github.com/InfluxCommunity/influxdb3-csharp/blob/main/Client/Write/WritePrecision.cs)
    to the `precision:` option to set
    the[timestamp precision](/influxdb3/cloud-dedicated/reference/glossary/#timestamp-precision)
    to seconds.**
</code></pre>
<ol start="6">
<li>
<p>In your editor, open the <code>Program.cs</code> file and replace its contents with the
following:</p>


<div class="highlight"><pre tabindex="0" class="chroma"><code class="language-c#" data-lang="c#"><span class="line"><span class="cl"><span class="c1">// Program.cs</span>
</span></span><span class="line"><span class="cl">
</span></span><span class="line"><span class="cl"><span class="k">using</span> <span class="nn">System</span><span class="p">;</span>
</span></span><span class="line"><span class="cl"><span class="k">using</span> <span class="nn">System.Threading.Tasks</span><span class="p">;</span>
</span></span><span class="line"><span class="cl">
</span></span><span class="line"><span class="cl"><span class="k">namespace</span> <span class="nn">InfluxDBv3</span><span class="p">;</span>
</span></span><span class="line"><span class="cl">
</span></span><span class="line"><span class="cl"><span class="kd">public</span> <span class="k">class</span> <span class="nc">Program</span>
</span></span><span class="line"><span class="cl"><span class="p">{</span>
</span></span><span class="line"><span class="cl">  <span class="kd">public</span> <span class="kd">static</span> <span class="kd">async</span> <span class="n">Task</span> <span class="n">Main</span><span class="p">()</span>
</span></span><span class="line"><span class="cl">  <span class="p">{</span>
</span></span><span class="line"><span class="cl">    <span class="k">await</span> <span class="n">Write</span><span class="p">.</span><span class="n">WriteLineProtocol</span><span class="p">();</span>
</span></span><span class="line"><span class="cl">  <span class="p">}</span>
</span></span><span class="line"><span class="cl"><span class="p">}</span></span></span></code></pre></div>
<p>The <code>Program</code> class shares the same <code>InfluxDBv3</code> namespace as the <code>Write</code>
class you defined in the preceding step and defines a <code>Main()</code> function that
calls <code>Write.WriteLineProtocol()</code>. The <code>dotnet</code> CLI recognizes
<code>Program.Main()</code> as the entry point for your program.</p>
</li>
<li>
<p>To build and execute the program and write the line protocol to your
InfluxDB Cloud Dedicated database, enter the following command in your terminal:</p>
<!--pytest.mark.skip-->


<div class="highlight"><pre tabindex="0" class="chroma"><code class="language-bash" data-lang="bash"><span class="line"><span class="cl">dotnet run</span></span></code></pre></div>
</li>
</ol>
<p>If successful, the output is the success message; otherwise, error details and
the failure message.</p>
<!---------------------------- END C# CONTENT --------------------------->

</div>

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 check your pom.xml for problems, 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 3.
       */
       private Write() {
           //not called
       }
   
       /**
         * @throws Exception
         */
       public static void writeLineProtocol() throws Exception {
   
           // Set InfluxDB credentials
           final String host = "https://cluster-id.a.influxdb.io

“; final String database = “get-started”;

        /**
          * INFLUX_TOKEN is an environment variable you assigned to your
          * 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](/influxdb3/cloud-dedicated/admin/tokens/#database-tokens)
      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](https://github.com/InfluxCommunity/influxdb3-java/blob/main/src/main/java/com/influxdb/v3/client/write/WritePrecision.java)
    as the `precision` argument to set the write
    [timestamp precision](/influxdb3/cloud-dedicated/reference/glossary/#timestamp-precision)
    to seconds.**
</code></pre>
<ol start="8">
<li>
<p>In your editor, open the <code>App.java</code> file (created by Maven) and replace its
contents with the following sample code:</p>


<div class="highlight"><pre tabindex="0" class="chroma"><code class="language-java" data-lang="java"><span class="line"><span class="cl"><span class="c1">// App.java</span><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="kn">package</span><span class="w"> </span><span class="nn">com.influxdbv3</span><span class="p">;</span><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="cm">/**
</span></span></span><span class="line"><span class="cl"><span class="cm">* Execute the client functions.
</span></span></span><span class="line"><span class="cl"><span class="cm">*
</span></span></span><span class="line"><span class="cl"><span class="cm">*/</span><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="kd">public</span><span class="w"> </span><span class="kd">class</span> <span class="nc">App</span><span class="w"> </span><span class="p">{</span><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="w">    </span><span class="cm">/**
</span></span></span><span class="line"><span class="cl"><span class="cm">    * @param args
</span></span></span><span class="line"><span class="cl"><span class="cm">    * @throws Exception
</span></span></span><span class="line"><span class="cl"><span class="cm">    */</span><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="w">    </span><span class="kd">public</span><span class="w"> </span><span class="kd">static</span><span class="w"> </span><span class="kt">void</span><span class="w"> </span><span class="nf">main</span><span class="p">(</span><span class="kd">final</span><span class="w"> </span><span class="n">String</span><span class="o">[]</span><span class="w"> </span><span class="n">args</span><span class="p">)</span><span class="w"> </span><span class="kd">throws</span><span class="w"> </span><span class="n">Exception</span><span class="w"> </span><span class="p">{</span><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="w">        </span><span class="c1">// Write data to InfluxDB 3.</span><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="w">        </span><span class="n">Write</span><span class="p">.</span><span class="na">writeLineProtocol</span><span class="p">();</span><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="w">    </span><span class="p">}</span><span class="w">
</span></span></span><span class="line"><span class="cl"><span class="p">}</span></span></span></code></pre></div>
<ul>
<li>The <code>App</code> class and <code>Write</code> class are part of the same <code>com.influxdbv3</code>
package (your project <strong>groupId</strong>).</li>
<li><code>App</code> defines a <code>main()</code> function that calls <code>Write.writeLineProtocol()</code>.</li>
</ul>
</li>
<li>
<p>In your terminal or editor, use Maven to install dependencies and compile
the project code&ndash;for example:</p>
<!--pytest.mark.skip-->


<div class="highlight"><pre tabindex="0" class="chroma"><code class="language-bash" data-lang="bash"><span class="line"><span class="cl">mvn compile</span></span></code></pre></div>
</li>
<li>
<p>In your terminal or editor, execute <code>App.main()</code> to write to InfluxDB&ndash;for
example, using Maven:</p>
<!--pytest.mark.skip-->


<div class="highlight"><pre tabindex="0" class="chroma"><code class="language-bash" data-lang="bash"><span class="line"><span class="cl">mvn exec:java -Dexec.mainClass<span class="o">=</span><span class="s2">&#34;com.influxdbv3.App&#34;</span></span></span></code></pre></div>
</li>
</ol>
<p>If successful, the output is the success message; otherwise, error details and
the failure message.</p>
<!---------------------------- END JAVA CONTENT --------------------------->

</div>