Para recursos semelhantes aos do Amazon Timestream para, considere o Amazon Timestream LiveAnalytics para InfluxDB. Ele oferece ingestão de dados simplificada e tempos de resposta de consulta de um dígito em milissegundos para análises em tempo real. Saiba mais aqui.

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Gravar dados em seu cluster Timestream para InfluxDB 3

O Amazon Timestream para InfluxDB 3 fornece recursos robustos para ingerir dados de séries temporais com eficiência. Compreender os métodos adequados para gravar dados é essencial para maximizar o desempenho e garantir a integridade dos dados.

O Timestream para InfluxDB 3 fornece vários endpoints de API HTTP para gravar dados de séries temporais, oferecendo flexibilidade para diferentes métodos de integração e compatibilidade com workloads existentes do InfluxDB.

Visão geral do protocolo de linha

O InfluxDB 3 foi projetado para alta taxa de gravação e usa uma sintaxe de gravação eficiente e legível por humanos chamada protocolo de linha. Como schema-on-write banco de dados, o InfluxDB cria automaticamente o banco de dados lógico, as tabelas e seus esquemas quando você começa a gravar dados, sem exigir nenhuma configuração manual. Depois que o esquema é criado, o InfluxDB valida futuras solicitações de gravação antes de aceitar novos dados, enquanto ainda permite a evolução do esquema conforme suas necessidades mudam.

Estrutura do protocolo de linha

O protocolo de linha consiste nos seguintes elementos essenciais:

Os valores de campo podem ser um dos seguintes tipos de dados:

O protocolo de linha segue esta sintaxe geral:

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

Exemplo de ponto de dados usando protocolo de linha:

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

Isso cria um ponto na tabela “inicial” com:

Visão geral dos endpoints de API

O InfluxDB 3 é compatível com três endpoints primários de gravação:

Utilização da API de gravação Native v3

O endpoint /api/v3/write_lp é a API nativa do InfluxDB 3 para escrever dados de protocolo de linha.

Formato de solicitação:

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

Parâmetros de consulta:

Exemplo de solicitação de gravação:

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"

Gravar modos de resposta

Modo padrão (no_sync=false)

Modo rápido (no_sync=true)

Manipulação parcial de gravação

O parâmetro accept_partial controla o comportamento quando os lotes de gravação contêm erros:

Quando accept_partial é true (padrão):

Quando accept_partial for false:

Compatibilidade APIs

A compatibilidade APIs permite a migração perfeita das cargas de trabalho existentes do InfluxDB v1 ou v2 para o InfluxDB 3. Esses endpoints funcionam com bibliotecas de clientes do InfluxDB existentes, Telegraf e integrações de terceiros.

Diferenças importantes:

Compatibilidade com o InfluxDB v2

O endpoint /api/v2/write fornece compatibilidade com versões anteriores para clientes 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 da API V2:

Compatibilidade com o InfluxDB v1

O endpoint /write fornece compatibilidade com versões anteriores para clientes 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'

Opções de autenticação V1:

Parâmetros da API do V1:

Bibliotecas e integrações de clientes

Bibliotecas de clientes oficiais do InfluxDB 3

As bibliotecas de cliente do InfluxDB 3 fornecem interfaces de linguagem nativa para construir e gravar dados de séries temporais:

Exemplo: cliente do 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)

Exemplo: 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 de cliente legadas

Para workloads v1 e v2 existentes, você pode continuar usando bibliotecas de cliente legadas com os endpoints de compatibilidade:

Exemplo: cliente 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áticas recomendadas para gravação de dados

Ao gravar dados, recomendamos o seguinte:

Diferenças importantes em relação às versões anteriores:

Ao aproveitar a API de gravação apropriada e seguir essas práticas recomendadas, você pode ingerir com eficiência dados de séries temporais em sua instância Timestream for InfluxDB 3, mantendo o alto desempenho e a integridade dos dados.