Consulta de información de túneles - Tablestore - Centro de documentación de Alibaba Cloud

Use Tablestore SDK for Java para consultar la configuración, la etapa, los estados de los canales y el progreso de consumo incremental de un túnel.

Requisitos previos

Instale Tablestore SDK for Java y initialize TunnelClient.

Descripción de la función

Llame a describeTunnel para consultar información sobre un túnel. La respuesta incluye la configuración del túnel, el punto de consumo incremental general y el objetivo de punto de recuperación (RPO), así como el estado y el progreso de consumo de cada canal en el túnel.

DescribeTunnelResponse describeTunnel(DescribeTunnelRequest request)
        throws TableStoreException, ClientException

El ejemplo a continuación consulta información sobre el túnel example_tunnel de la tabla example_table e imprime la etapa del túnel, junto con el estado y el progreso de consumo de cada canal:

String tableName = "example_table";
String tunnelName = "example_tunnel";

DescribeTunnelRequest request =
        new DescribeTunnelRequest(tableName, tunnelName);
DescribeTunnelResponse response = tunnelClient.describeTunnel(request);

TunnelInfo tunnelInfo = response.getTunnelInfo();
System.out.printf(
        "name=%s, type=%s, stage=%s%n",
        tunnelInfo.getTunnelName(),
        tunnelInfo.getTunnelType(),
        tunnelInfo.getStage());

for (ChannelInfo channelInfo : response.getChannelInfos()) {
    System.out.printf(
            "channelId=%s, type=%s, status=%s, count=%d%n",
            channelInfo.getChannelId(),
            channelInfo.getChannelType(),
            channelInfo.getChannelStatus(),
            channelInfo.getChannelCount());
}

Parámetros

request es de tipo DescribeTunnelRequest y contiene los siguientes parámetros:

Nombre	Tipo	Descripción
tableName (obligatorio)	`String`	El nombre de la tabla.
tunnelName (obligatorio)	`String`	El nombre del túnel.

Valores de retorno

El valor de retorno es de tipo DescribeTunnelResponse y contiene los siguientes campos:

Nombre	Tipo	Descripción
tunnelConsumePoint	`Date`	El punto de consumo incremental más reciente del túnel. Este valor corresponde al punto de consumo del canal más lento del túnel. Valor predeterminado: 00:00:00 del 1 de enero de 1970 (UTC). Llame a `getTunnelConsumePoint()` para obtener este campo.
tunnelRpo	`long`	El RPO de consumo incremental del túnel, que representa la diferencia entre la hora actual y el punto de consumo del canal más lento. Unidad: milisegundos. Llame a `getTunnelRpo()` para obtener este campo.
tunnelInfo	`TunnelInfo`	La información del túnel. Llame a `getTunnelInfo()` para obtener este campo. Los campos son los mismos que los de los objetos `TunnelInfo` devueltos por List tunnels.
channelInfos	`List<ChannelInfo>`	La lista de canales del túnel. Si el túnel no ha inicializado ningún canal, se devuelve una lista vacía. Llame a `getChannelInfos()` para obtener este campo.

Nota

tunnelConsumePoint y tunnelRpo aplican únicamente al consumo incremental. Si el consumo incremental no ha comenzado o si el túnel solo consume datos completos, tunnelConsumePoint toma el valor predeterminado. En este caso, no use tunnelRpo para determinar la latencia de consumo.

Información de canales

Cada elemento en channelInfos[] es de tipo ChannelInfo y contiene los siguientes campos:

Nombre	Tipo	Descripción
channelId	`String`	El ID del canal.
channelType	`ChannelType`	El tipo de canal. Valores válidos: `BaseData` y `Stream`, que indican un canal de datos completos y un canal de datos incrementales, respectivamente.
channelStatus	`ChannelStatus`	El estado del canal. Valores válidos: `WAIT`, `OPEN`, `CLOSING`, `CLOSE` y `TERMINATED`, que indican en espera, abierto, cerrándose, cerrado y terminado, respectivamente.
clientId	`String`	El ID del cliente que consume el canal. Este campo puede estar vacío si no hay ningún cliente asignado al canal. El ID del cliente se genera a partir de `TunnelWorkerConfig.clientTag`. Llame a `setClientTag()` para personalizar el identificador del cliente.
channelConsumePoint	`Date`	El punto de consumo incremental más reciente del canal. Valor predeterminado: 00:00:00 del 1 de enero de 1970 (UTC). Este campo no aplica a los canales de datos completos.
channelRpo	`long`	El RPO de consumo incremental del canal, que representa la diferencia entre la hora actual y `channelConsumePoint`. Unidad: milisegundos. Este campo no aplica a los canales de datos completos.
channelCount	`long`	El número de filas sincronizadas por el canal.