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

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

WriteRecords

시계열 데이터를 Timestream에 쓸 수 있습니다. 시스템에 삽입할 단일 데이터 포인트 또는 데이터 포인트 배치를 지정할 수 있습니다. Timestream은 데이터베이스에 쓰기를 간접적으로 호출할 때 지정하는 데이터 요소의 차원 이름 및 데이터 유형을 기반으로 Timestream 테이블의 열 이름 및 데이터 유형을 자동으로 탐지하는 유연한 스키마를 제공합니다.

Timestream은 최종 일관성 읽기 시맨틱을 지원합니다. 즉, Timestream에 데이터 배치를 작성한 직후 데이터를 쿼리할 때 쿼리 결과에 최근에 완료된 쓰기 작업의 결과가 반영되지 않을 수 있습니다. 결과에는 일부 오래된 데이터도 포함될 수 있습니다. 잠시 후 쿼리 요청을 반복하면 결과가 최신 데이터를 반환합니다. 서비스 할당량이 적용됩니다.

자세한 내용은 코드 샘플을 참조하세요.

업서트

WriteRecords 요청에서 Version 파라미터를 사용하여 데이터 포인트를 업데이트할 수 있습니다. Timestream은 각 레코드와 함께 버전 번호를 추적합니다. 요청의 레코드에 지정되지 않은 경우 1은 기본적으로 Version으로 설정됩니다. Timestream은 기존 레코드에 대해 더 높은 Version 번호가 포함된 쓰기 요청을 수신하면 해당 레코드의 측정값과 Version을 함께 업데이트합니다. 측정값이 기존 레코드의 값과 동일한 업데이트 요청을 수신하면 Timestream은 기존 Version 값보다 큰 경우 Version을 계속 업데이트합니다. Version 값이 지속적으로 증가하는 한 원하는 횟수만큼 데이터 포인트를 업데이트할 수 있습니다.

예를 들어 요청에 Version을 표시하지 않고 새 레코드를 작성한다고 가정해 보겠습니다. Timestream은 이 레코드를 저장하고 Version을 1로 설정합니다. 이제 측정값이 다른 동일한 레코드의 WriteRecords 요청으로 이 레코드를 업데이트하려고 하지만 이전과 마찬가지로 Version을 제공하지 않는다고 가정해 보겠습니다. 이 경우 업데이트된 레코드의 버전이 기존 버전 값보다 크지 않으므로 Timestream은 RejectedRecordsException과 함께 이 업데이트를 거부합니다.

그러나 Version을 2로 설정하여 업데이트 요청을 다시 보내면 Timestream은 레코드 값을 성공적으로 업데이트하고 Version은 2로 설정됩니다. 다음으로, 동일한 레코드와 동일한 측정값이 있지만 Version이 3으로 설정된 WriteRecords 요청을 전송했다고 가정해 보겠습니다. 이 경우 Timestream은 Version만 3으로 업데이트합니다. 추가 업데이트 시 3보다 큰 버전 번호를 전송해야 하거나 업데이트 요청에 RejectedRecordsException이 수신됩니다.

구문 요청

{
   "CommonAttributes": { 
      "Dimensions": [ 
         { 
            "DimensionValueType": "string",
            "Name": "string",
            "Value": "string"
         }
      ],
      "MeasureName": "string",
      "MeasureValue": "string",
      "MeasureValues": [ 
         { 
            "Name": "string",
            "Type": "string",
            "Value": "string"
         }
      ],
      "MeasureValueType": "string",
      "Time": "string",
      "TimeUnit": "string",
      "Version": number
   },
   "DatabaseName": "string",
   "Records": [ 
      { 
         "Dimensions": [ 
            { 
               "DimensionValueType": "string",
               "Name": "string",
               "Value": "string"
            }
         ],
         "MeasureName": "string",
         "MeasureValue": "string",
         "MeasureValues": [ 
            { 
               "Name": "string",
               "Type": "string",
               "Value": "string"
            }
         ],
         "MeasureValueType": "string",
         "Time": "string",
         "TimeUnit": "string",
         "Version": number
      }
   ],
   "TableName": "string"
}

요청 파라미터

모든 작업에 공통되는 파라미터에 대한 자세한 설명은 공통 파라미터를 참조하세요.

요청은 JSON 형식으로 다음 데이터를 받습니다.

응답 구문

{
   "RecordsIngested": { 
      "MagneticStore": number,
      "MemoryStore": number,
      "Total": number
   }
}

응답 요소

작업이 성공하면 서비스가 HTTP 200 응답을 반송합니다.

다음 데이터는 서비스에 의해 JSON 형식으로 반환됩니다.

오류

모든 작업에 공통되는 오류에 대한 내용은 일반적인 오류 섹션을 참조하세요.

참고

언어별 AWS SDK 중 하나에서 이 API를 사용하는 방법에 대한 자세한 내용은 다음을 참조하세요.