Tablestore：寫入時序資料

前提條件

安裝Tablestore Java SDK並初始化時序模型用戶端。

功能說明

調用 putTimeseriesData 方法向時序表寫入一行或多行時序資料。每行資料由時間軸標識、資料點時間和資料欄位組成；響應會返回寫入失敗的行及其錯誤資訊。

public PutTimeseriesDataResponse putTimeseriesData(PutTimeseriesDataRequest request) throws TableStoreException, ClientException

以下樣本向 example_timeseries_table 寫入同一時間軸的 3 個資料點，並檢查各行的寫入結果。

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 包含以下業務返回欄位。