Escritura de datos de series temporales - Tablestore - Centro de documentación de Alibaba Cloud

Use Tablestore SDK for Java para escribir una o más filas de datos de series temporales y obtener información de error de las filas con errores.

Requisitos previos

Instale Tablestore SDK for Java e inicialice un cliente de series temporales.

Descripción

Llame a putTimeseriesData para escribir una o más filas de datos en una tabla de series temporales. Cada fila consta de identificadores de serie temporal, una marca de tiempo del punto de datos y campos de datos. La respuesta contiene las filas que no se pudieron escribir y su información de error.

public PutTimeseriesDataResponse putTimeseriesData(PutTimeseriesDataRequest request) throws TableStoreException, ClientException

El siguiente ejemplo escribe tres puntos de datos para la misma serie temporal en example_timeseries_table y comprueba el resultado de cada fila.

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());
}

Parámetros

PutTimeseriesDataRequest contiene los siguientes parámetros.

Nombre	Tipo	Descripción
timeseriesTableName (obligatorio)	`String`	Nombre de la tabla de series temporales.
rows (obligatorio)	`List<TimeseriesRow>`	Filas de datos de series temporales por escribir.
metaUpdateMode (opcional)	`PutTimeseriesDataRequest.MetaUpdateMode`	Modo de actualización de metadatos de series temporales. Valor predeterminado: `NORMAL`, que permite al servidor determinar si debe actualizar el índice de metadatos de la serie temporal. Si establece este parámetro en `IGNORE`, la escritura actual no actualiza el índice de metadatos. Esto puede afectar las consultas de metadatos de series temporales y las consultas SQL.

Filas de datos de series temporales

Cada elemento en rows[] es del tipo TimeseriesRow y contiene los siguientes parámetros.

Nombre	Tipo	Descripción
timeseriesKey (obligatorio)	`TimeseriesKey`	Identificadores de la serie temporal.
timeInUs (obligatorio)	`long`	Marca de tiempo del punto de datos en microsegundos desde 1970-01-01 00:00:00 UTC. El valor debe ser mayor o igual que `0`.
fields (obligatorio)	`SortedMap<String, ColumnValue>`	Campos de datos, que constan de uno o más nombres y valores de campo.

Identificadores de series temporales

rows[].timeseriesKey es del tipo TimeseriesKey y contiene los siguientes parámetros.

Nombre	Tipo	Descripción
measurementName (obligatorio)	`String`	Nombre de la medición. Tablestore SDK for Java 5.17.2 o posterior permite que este parámetro esté vacío.
dataSource (opcional)	`String`	Identificador del origen de datos. Este parámetro puede estar vacío.
tags (opcional)	`SortedMap<String, String>`	Etiquetas como pares clave-valor de cadena. Si no se especifica este parámetro, se usa un mapa vacío.

Respuesta

PutTimeseriesDataResponse contiene el siguiente campo específico de la operación.

Campo	Tipo	Descripción
`failedRows`	`List<PutTimeseriesDataResponse.FailedRowResult>`	Llame a `getFailedRows()` para obtener las filas que no se pudieron escribir. Se devuelve una lista vacía si todas las filas se escriben correctamente. También puede llamar a `isAllSuccess()` para determinar si se escribieron todas las filas.

Información de filas con errores

Cada elemento en failedRows[] es del tipo PutTimeseriesDataResponse.FailedRowResult y contiene los siguientes campos.

Campo	Tipo	Descripción
`index`	`int`	Llame a `getIndex()` para obtener el índice de la fila con errores en la lista `rows` de la solicitud.
`error`	`Error`	Llame a `getError()` para obtener el motivo del error.