Pour des fonctionnalités similaires à celles d'Amazon Timestream pour, pensez à Amazon Timestream LiveAnalytics pour InfluxDB. Il permet une ingestion simplifiée des données et des temps de réponse aux requêtes à un chiffre en millisecondes pour des analyses en temps réel. Pour en savoir plus, cliquez ici.

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Écrire des données dans votre cluster Timestream pour InfluxDB 3

Amazon Timestream pour InfluxDB 3 fournit des fonctionnalités robustes pour ingérer efficacement des données de séries chronologiques. Comprendre les méthodes appropriées pour écrire des données est essentiel pour optimiser les performances et garantir l'intégrité des données.

Timestream for InfluxDB 3 fournit plusieurs points de terminaison d'API HTTP pour écrire des données de séries chronologiques, offrant ainsi une flexibilité pour différentes méthodes d'intégration et une compatibilité avec les charges de travail InfluxDB existantes.

Vue d'ensemble du protocole de ligne

InfluxDB 3 est conçu pour un débit d'écriture élevé et utilise une syntaxe d'écriture efficace et lisible par l'homme appelée protocole de ligne. En tant que schema-on-write base de données, InfluxDB crée automatiquement la base de données logique, les tables et leurs schémas lorsque vous commencez à écrire des données, sans nécessiter de configuration manuelle. Une fois le schéma créé, InfluxDB valide les futures demandes d'écriture par rapport à celui-ci avant d'accepter de nouvelles données, tout en permettant l'évolution du schéma en fonction de l'évolution de vos besoins.

Structure du protocole de ligne

Le protocole de ligne comprend les éléments essentiels suivants :

Les valeurs des champs peuvent être de l'un des types de données suivants :

Le protocole de ligne suit cette syntaxe générale :

myTable,tag1=val1,tag2=val2 field1="v1",field2=1i 0000000000000000000

Exemple de point de données utilisant le protocole de ligne :

home,room=Living\ Room temp=21.1,hum=35.9,co=0i 1735545600

Cela crée un point dans le tableau « d'accueil » avec :

Présentation des points de terminaison de l'API

InfluxDB 3 prend en charge trois points de terminaison d'écriture principaux :

Utilisation de l'API d'écriture native v3

Le /api/v3/write_lp point de terminaison est l'API native InfluxDB 3 pour écrire les données du protocole de ligne.

Format de demande :

POST /api/v3/write_lp?db=DATABASE_NAME&precision=PRECISION&accept_partial=BOOLEAN&no_sync=BOOLEAN

Paramètres de requête :

Exemple de demande d'écriture :

curl -v "https://your-cluster-endpoint:8086/api/v3/write_lp?db=sensors&precision=s" \
  --header "Authorization: Bearer YOUR_TOKEN" \
  --data-raw "home,room=Living\ Room temp=21.1,hum=35.9,co=0i 1735545600
home,room=Kitchen temp=21.0,hum=35.9,co=0i 1735545600"

Modes de réponse en écriture

Mode standard (no_sync=faux)

Mode rapide (no_sync=vrai)

Gestion partielle de l'écriture

Le accept_partial paramètre contrôle le comportement lorsque les lots d'écriture contiennent des erreurs :

Quand accept_partial est true (par défaut) :

Lorsque accept_partial est false :

Compatibilité APIs

La compatibilité APIs permet une migration fluide des charges de travail InfluxDB v1 ou v2 existantes vers InfluxDB 3. Ces points de terminaison fonctionnent avec les bibliothèques clientes InfluxDB existantes, Telegraf et les intégrations tierces.

Différences importantes :

Compatibilité avec InfluxDB v2

Le /api/v2/write point de terminaison assure la rétrocompatibilité pour les clients v2 :

curl -i "https://your-cluster-endpoint:8086/api/v2/write?bucket=DATABASE_NAME&precision=s" \
  --header "Authorization: Bearer DATABASE_TOKEN" \
  --header "Content-type: text/plain; charset=utf-8" \
  --data-binary 'home,room=kitchen temp=72 1641024000'

Paramètres de l'API V2 :

Compatibilité avec InfluxDB v1

Le /write point de terminaison assure la rétrocompatibilité pour les clients v1 :

curl -i "https://your-cluster-endpoint:8086/write?db=DATABASE_NAME&precision=s" \
  --user "any:DATABASE_TOKEN" \
  --header "Content-type: text/plain; charset=utf-8" \
  --data-binary 'home,room=kitchen temp=72 1641024000'

Options d'authentification V1 :

Paramètres de l'API V1 :

Bibliothèques clientes et intégrations

Bibliothèques clientes officielles d'InfluxDB 3

Les bibliothèques clientes InfluxDB 3 fournissent des interfaces en langage natif pour la construction et l'écriture de séries chronologiques :

Exemple : client Python

from influxdb3 import InfluxDBClient3

client = InfluxDBClient3(
    host="your-cluster-endpoint:8086",
    token="YOUR_TOKEN",
    database="DATABASE_NAME"
)

# Write using line protocol
client.write("home,room=Living\\ Room temp=21.1,hum=35.9,co=0i")

# Write using Point objects
from influxdb3 import Point
point = Point("home") \
    .tag("room", "Living Room") \
    .field("temp", 21.1) \
    .field("hum", 35.9) \
    .field("co", 0)
    
client.write(point)

Exemple : Go client

import "github.com/InfluxCommunity/influxdb3-go/v2/influxdb3"

client, err := influxdb3.New(influxdb3.ClientConfig{
    Host: "your-cluster-endpoint:8086",
    Token: "YOUR_TOKEN",
    Database: "DATABASE_NAME",
})

point := influxdb3.NewPoint("home",
    map[string]string{"room": "Living Room"},
    map[string]any{
        "temp": 24.5,
        "hum":  40.5,
        "co":   15,
    },
    time.Now(),
)

err = client.WritePoints(context.Background(), []*influxdb3.Point{point})

Bibliothèques clientes héritées

Pour les charges de travail v1 et v2 existantes, vous pouvez continuer à utiliser les bibliothèques clientes existantes avec les points de terminaison de compatibilité :

Exemple : client Node.js v1 :

const Influx = require('influx')

const client = new Influx.InfluxDB({
  host: 'your-cluster-endpoint',
  port: 8086,
  protocol: 'https',
  database: 'DATABASE_NAME',
  username: 'ignored',
  password: 'DATABASE_TOKEN'
})

Bonnes pratiques en matière de rédaction de données

Lorsque vous rédigez des données, nous recommandons ce qui suit :

Différences importantes par rapport aux versions précédentes :

En tirant parti de l'API d'écriture appropriée et en suivant ces meilleures pratiques, vous pouvez ingérer efficacement des données de séries chronologiques dans votre instance Timestream for InfluxDB 3 tout en maintenant des performances élevées et l'intégrité des données.