如需與 Amazon Timestream for LiveAnalytics 類似的功能，請考慮使用 Amazon Timestream for InfluxDB。它提供簡化的資料擷取和單一位數毫秒查詢回應時間，以進行即時分析。在這裡進一步了解。

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

將資料寫入您的 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

這會在「主」資料表中建立一個點，其中包含：

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 相容性

端點為 v2 /api/v2/write 用戶端提供回溯相容性：

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 相容性

端點為 v1 /write 用戶端提供回溯相容性：

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 執行個體，同時維持高效能和資料完整性。