Para obtener capacidades similares a las de Amazon Timestream, considere Amazon Timestream LiveAnalytics para InfluxDB. Ofrece una ingesta de datos simplificada y tiempos de respuesta a las consultas en milisegundos de un solo dígito para realizar análisis en tiempo real. Obtenga más información aquí.

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Escritura de datos en su clúster de Timestream para InfluxDB 3

Amazon Timestream para InfluxDB 3 ofrece capacidades sólidas para ingerir datos de serie temporal de manera eficiente. Comprender los métodos adecuados para escribir datos es fundamental para maximizar el rendimiento y garantizar la integridad de los datos.

Timestream para InfluxDB 3 ofrece varios puntos de conexión de la API HTTP para escribir datos de serie temporal, lo que brinda flexibilidad para los diferentes métodos de integración y la compatibilidad con las cargas de trabajo de InfluxDB existentes.

Descripción general del protocolo de línea

InfluxDB 3 está diseñado para un alto rendimiento de escritura y utiliza una sintaxis de escritura eficiente y legible por humanos llamada protocolo de línea. Como schema-on-write base de datos, InfluxDB crea automáticamente la base de datos lógica, las tablas y sus esquemas cuando comienza a escribir datos, sin necesidad de ninguna configuración manual. Una vez que se crea el esquema, InfluxDB valida las solicitudes de escritura futuras con respecto a él antes de aceptar datos nuevos, mientras permite la evolución del esquema a medida que cambien sus necesidades.

Estructura del protocolo de línea

El protocolo de línea consta de los siguientes elementos indispensables:

Los valores de campo pueden ser uno de los siguientes tipos de datos:

El protocolo de línea sigue esta sintaxis general:

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

Ejemplo de punto de datos que utiliza el protocolo de línea:

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

Esto crea un punto en la tabla “inicial” con:

Información general de los puntos de conexión de la API

InfluxDB 3 admite tres puntos de conexión de escritura principales:

Uso de la API de escritura nativa v3

El punto de conexión /api/v3/write_lp es la API nativa de InfluxDB 3 para escribir los datos de protocolo de línea.

Formato de solicitudes:

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

Parámetros de consulta:

Ejemplo de solicitud de escritura:

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"

Modos de respuesta de escritura

Modo estándar (no_sync = falso)

Modo rápido (no_sync = verdadero)

Gestión de escritura parcial

El parámetro accept_partial controla el comportamiento cuando los lotes de escritura tienen errores:

Cuándo accept_partial es true (predeterminado):

Cuando accept_partial es false:

Compatibilidad APIs

La compatibilidad APIs permite una migración perfecta de las cargas de trabajo existentes de InfluxDB v1 o v2 a InfluxDB 3. Estos puntos de conexión funcionan con las bibliotecas de clientes de InfluxDB existentes, Telegraf y las integraciones de agentes externos.

Diferencias más destacadas:

Compatibilidad con InfluxDB v2

El punto de conexión /api/v2/write ofrece compatibilidad con versiones anteriores para los clientes de la 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'

Parámetro de la API v2:

Compatibilidad con InfluxDB v1

El punto de conexión /write ofrece compatibilidad con versiones anteriores para los clientes de la 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'

Opciones de autenticación de la v1:

Parámetro de la API v1:

Integraciones y bibliotecas de los clientes

Bibliotecas de cliente oficiales de InfluxDB 3

En las bibliotecas del cliente de InfluxDB 3 se ofrecen interfaces en el idioma nativo para construir y escribir datos de serie temporal:

Ejemplo: cliente 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)

Ejemplo: cliente Go

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

Bibliotecas heredadas de los clientes

Para las cargas de trabajo de las v1 y v2 existentes, puede seguir utilizando las bibliotecas heredadas de los clientes con los siguientes puntos de conexión de compatibilidad:

Ejemplo: cliente de 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'
})

Prácticas recomendadas para la escritura de datos

Al escribir los datos, recomendamos lo siguiente:

Diferencias importantes de las versiones anteriores:

Al utilizar la API de escritura adecuada y seguir estas prácticas recomendadas, puede ingerir datos de serie temporal de manera eficiente a la instancia de Timestream para InfluxDB 3 y, al mismo tiempo, mantener un alto rendimiento y la integridad de los datos.