要获得与亚马逊 Timestream 类似的功能 LiveAnalytics，可以考虑适用于 InfluxDB 的亚马逊 Timestream。适用于 InfluxDB 的 Amazon Timestream 提供简化的数据摄取和个位数毫秒级的查询响应时间，以实现实时分析。点击此处了解更多信息。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

向 Timestream for InfluxDB 3 集群写入数据

Amazon Timestream for InfluxDB 3 提供强大的功能，以高效摄取时间序列数据。了解正确的数据写入方法对于实现性能最大化并确保数据完整性至关重要。

Timestream for InfluxDB 3 提供多个 HTTP API 端点用于写入时间序列数据，既能灵活适配不同的集成方式，又能兼容现有的 InfluxDB 工作负载。

行协议概述

InfluxDB 3 专为高写入吞吐量而设计，并使用名为行协议的高效、人类可读的写入语法。作为 schema-on-write数据库，InfluxDB 会在您开始写入数据时自动创建逻辑数据库、表及其架构，无需任何手动设置。创建架构后，InfluxDB 会在接受新数据之前根据该架构验证未来的写入请求，同时仍允许在需求变化时进行架构演变。

行协议结构

行协议包含以下基本元素：

字段值可以是以下数据类型之一：

行协议遵循以下通用语法：

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

使用行协议的数据点示例：

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

这会在“home”表中创建包含以下内容的点：

API 端点概览

InfluxDB 3 支持三种主要写入端点：

使用原生 v3 写入 API

/api/v3/write_lp 端点是用于写入行协议数据的原生 InfluxDB 3 API。

请求格式：

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

查询参数：

示例写入请求：

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"

写入响应模式

标准模式（no_sync=false）

快速模式（no_sync=true）

部分写入处理

accept_partial 参数控制写入批处理包含错误时的行为：

当 accept_partial 为 true 时（默认）：

当 accept_partial 为 false 时：

兼容性 APIs

兼容性 APIs 允许将现有的 InfluxDB v1 或 v2 工作负载无缝迁移到 InfluxDB 3。这些端点可与现有的 InfluxDB 客户端库、Telegraf 以及第三方集成配合使用。

重要区别：

InfluxDB v2 兼容性

/api/v2/write 端点为 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'

V2 API 参数：

InfluxDB v1 兼容性

/write 端点为 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'

V1 身份验证选项：

V1 API 参数：

客户端库与集成

InfluxDB 3 官方客户端库

InfluxDB 3 客户端库提供用于构造和写入时间序列数据的本地语言接口：

示例：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)

示例：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})

旧版客户端库

对于现有的 v1 和 v2 工作负载，可继续将旧版客户端库与兼容性端点结合使用：

示例：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'
})

写入数据的最佳实践

写入数据时，我们建议执行以下步骤：

与先前版本的重要区别：

通过利用适当的写入 API 并遵循这些最佳实践，您可以在保持高性能和数据完整性的同时，高效地将时间序列数据摄取到 Timestream for InfluxDB 3 实例中。