Amazon Timestream for LiveAnalytics와 유사한 기능을 원하는 경우 Amazon Timestream for InfluxDB를 고려해 보세요. 간소화된 데이터 수집과 실시간 분석을 위한 10밀리초 미만의 쿼리 응답 시간을 제공합니다. 여기에서 자세히 알아보세요.

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

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는 세 가지 프라이머리 쓰기 엔드포인트를 지원합니다.

기본 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인 경우

호환성 API

호환성 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 인스턴스에 시계열 데이터를 효율적으로 수집할 수 있습니다.