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

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

WriteRecords

Timestream に時系列データを書き込むことができます。システムに挿入する単一のデータポイントまたはデータポイントのバッチを指定できます。Timestream には、データベースへの書き込みを呼び出すときに指定したデータポイントのディメンション名とデータ型に基づいて、Timestream テーブルの列名とデータ型を自動検出する柔軟なスキーマが用意されています。

Timestream は、結果整合性のある読み込みセマンティクスをサポートしています。つまり、データのバッチを Timestream に書き込んだ直後にデータをクエリする場合、クエリ結果には最近完了した書き込みオペレーションの結果が反映されていない可能性があります。また、結果に古いデータが含まれている可能性もあります。少し時間が経ってからクエリリクエストを繰り返すと、結果で最新のデータが返されます。サービスクォータが適用されます。

詳細については、 コードサンプルを参照してください。

アップサート

WriteRecords リクエストで Version パラメータを使用して、データポイントを更新できます。Timestream は、各レコードのバージョン番号を追跡します。Version は、リクエストのレコードに対して指定されていない場合、デフォルトで 1 になります。Timestream が既存のレコードのメジャー値とその Version を更新するのは、そのレコードの Version 番号がより大きい書き込みリクエストを受信した場合です。メジャー値が既存のレコードの値と同じである更新リクエストを受信した場合、Timestream は Version の既存の値より大きければ Version を更新します。データポイントは、Version の値が増加し続ける限り、何度でも更新できます。

例えば、リクエストで Version を指定せずに新しいレコードを書き込むとします。Timestream はこのレコードを保存し、Version を 1 に設定します。ここで、このレコードを別のメジャー値を持つ同じレコードの WriteRecords リクエストで更新しようとしますが、以前と同様に Version を指定しないとします。この場合、更新されたレコードのバージョンが 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 を使用する方法の詳細については、以下を参照してください。