Tablestore:時系列データの書き込み

前提条件

Tablestore SDK for Java をインストールし、時系列クライアントを初期化します。

説明

putTimeseriesData を呼び出して、時系列テーブルに 1 行以上のデータを書き込みます。各行は、時系列識別子、データポイントのタイムスタンプ、およびデータフィールドで構成されます。レスポンスには、書き込みに失敗した行とそのエラー情報が含まれます。

public PutTimeseriesDataResponse putTimeseriesData(PutTimeseriesDataRequest request) throws TableStoreException, ClientException

次の例では、同一の時系列に対する 3 つのデータポイントを example_timeseries_table に書き込み、各行の結果を確認します。

TimeseriesClient timeseriesClient = client.asTimeseriesClient();

String tableName = "example_timeseries_table";
List<TimeseriesRow> rows = new ArrayList<>();

Map<String, String> tags = new HashMap<>();
tags.put("region", "cn-hangzhou");
tags.put("host", "host_0");
TimeseriesKey timeseriesKey = new TimeseriesKey("cpu", "source_0", tags);

long baseTimeInUs = System.currentTimeMillis() * 1000L;
for (int i = 0; i < 3; i++) {
    TimeseriesRow row = new TimeseriesRow(timeseriesKey, baseTimeInUs + i * 1000L);
    row.addField("cpu_usage", ColumnValue.fromDouble(10.0 + i));
    row.addField("status", ColumnValue.fromString("ok"));
    rows.add(row);
}

PutTimeseriesDataRequest request = new PutTimeseriesDataRequest(tableName);
request.setRows(rows);
PutTimeseriesDataResponse response = timeseriesClient.putTimeseriesData(request);

for (PutTimeseriesDataResponse.FailedRowResult result : response.getFailedRows()) {
    System.out.println(result.getIndex());
    System.out.println(result.getError());
}

パラメーター

PutTimeseriesDataRequest には、次のパラメーターが含まれます。

レスポンス

PutTimeseriesDataResponse には、オペレーション固有のフィールドとして、次のものが含まれます。