Für ähnliche Funktionen wie Amazon Timestream für sollten Sie Amazon Timestream for LiveAnalytics InfluxDB in Betracht ziehen. Es bietet eine vereinfachte Datenaufnahme und Antwortzeiten im einstelligen Millisekundenbereich für Analysen in Echtzeit. Erfahren Sie hier mehr.

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Daten in Ihren Timestream für InfluxDB 3-Cluster schreiben

Amazon Timestream for InfluxDB 3 bietet robuste Funktionen für die effiziente Erfassung von Zeitreihendaten. Das Verständnis der richtigen Methoden zum Schreiben von Daten ist für die Maximierung der Leistung und die Sicherstellung der Datenintegrität unerlässlich.

Timestream for InfluxDB 3 bietet mehrere HTTP-API-Endpunkte zum Schreiben von Zeitreihendaten und bietet Flexibilität für verschiedene Integrationsmethoden und Kompatibilität mit bestehenden InfluxDB-Workloads.

Übersicht über das Leitungsprotokoll

InfluxDB 3 ist für einen hohen Schreibdurchsatz konzipiert und verwendet eine effiziente, für Menschen lesbare Schreibsyntax, das Line-Protokoll. Als schema-on-write Datenbank erstellt InfluxDB automatisch die logische Datenbank, die Tabellen und ihre Schemas, wenn Sie mit dem Schreiben von Daten beginnen, ohne dass eine manuelle Einrichtung erforderlich ist. Sobald das Schema erstellt ist, validiert InfluxDB zukünftige Schreibanforderungen daran, bevor es neue Daten akzeptiert, und ermöglicht gleichzeitig die Schemaentwicklung, wenn sich Ihre Anforderungen ändern.

Struktur des Leitungsprotokolls

Das Leitungsprotokoll besteht aus den folgenden wesentlichen Elementen:

Feldwerte können einen der folgenden Datentypen haben:

Das Linienprotokoll folgt dieser allgemeinen Syntax:

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

Beispiel für einen Datenpunkt, der das Leitungsprotokoll verwendet:

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

Dadurch wird ein Punkt in der Tabelle „Home“ erstellt mit:

Übersicht über API-Endpunkte

InfluxDB 3 unterstützt drei primäre Schreibendpunkte:

Verwendung der nativen v3-Schreib-API

Der /api/v3/write_lp Endpunkt ist die native InfluxDB 3-API zum Schreiben von Leitungsprotokolldaten.

Format der Anfrage:

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

Parameter abfragen:

Beispiel für eine Schreibanfrage:

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"

Antwortmodi schreiben

Standardmodus (no_sync=false)

Schneller Modus (no_sync=true)

Verarbeitung teilweiser Schreibvorgänge

Der accept_partial Parameter steuert das Verhalten, wenn Schreibstapel Fehler enthalten:

Wann accept_partial ist true (Standard):

Wenn accept_partial false ist:

Kompatibilität APIs

Kompatibilität APIs ermöglicht eine nahtlose Migration vorhandener InfluxDB v1- oder v2-Workloads zu InfluxDB 3. Diese Endpunkte funktionieren mit bestehenden InfluxDB-Clientbibliotheken, Telegraf und Integrationen von Drittanbietern.

Wichtige Unterschiede:

InfluxDB v2-Kompatibilität

Der /api/v2/write Endpunkt bietet Abwärtskompatibilität für v2-Clients:

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'

V2-API-Parameter:

InfluxDB v1-Kompatibilität

Der /write Endpunkt bietet Abwärtskompatibilität für v1-Clients:

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'

V1-Authentifizierungsoptionen:

V1-API-Parameter:

Client-Bibliotheken und Integrationen

Offizielle InfluxDB 3-Clientbibliotheken

InfluxDB 3-Clientbibliotheken bieten Benutzeroberflächen in Muttersprache zum Konstruieren und Schreiben von Zeitreihendaten:

Beispiel: Python-Client

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)

Beispiel: 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})

Ältere Client-Bibliotheken

Für bestehende Workloads der Versionen 1 und 2 können Sie weiterhin ältere Clientbibliotheken mit den folgenden Kompatibilitätsendpunkten verwenden:

Beispiel: Node.js v1-Client:

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'
})

Bewährte Methoden für das Schreiben von Daten

Beim Schreiben von Daten empfehlen wir Folgendes:

Wichtige Unterschiede zu früheren Versionen:

Indem Sie die entsprechende Schreib-API nutzen und diese Best Practices befolgen, können Sie Zeitreihendaten effizient in Ihre Timestream for InfluxDB 3-Instance aufnehmen und gleichzeitig eine hohe Leistung und Datenintegrität aufrechterhalten.