Amazon Timestream for LiveAnalytics に類似した機能をご希望の場合は Amazon Timestream for InfluxDB をご検討ください。リアルタイム分析に適した、シンプルなデータインジェストと 1 桁ミリ秒のクエリ応答時間を特徴としています。詳細については、こちらを参照してください。

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Timestream for InfluxDB 3 クラスターへのデータの書き込み

Amazon Timestream for InfluxDB 3 は、時系列データを効率的に取り込むための堅牢な機能を提供します。パフォーマンスを最大化し、データの完全性を確保するためには、データを書き込むための適切な方法を理解することが不可欠です。

Timestream for InfluxDB 3 は、時系列データを書き込むための複数の HTTP API エンドポイントを提供し、さまざまな統合方法と既存の InfluxDB ワークロードとの互換性に対する柔軟性を提供します。

ラインプロトコルの概要

InfluxDB 3 は、高い書き込みスループットを実現できるように設計されており、ラインプロトコルと呼ばれる効率的で人間が読める書き込み構文を使用します。スキーマオンライトデータベースとして、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 は 3 つのプライマリ書き込みエンドポイントをサポートしています。

ネイティブ v3 Write 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 のとき:

Compatibility API

Compatibility API を使用すると、既存の 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 インスタンスに効率的に取り込むことができます。