Use Tablestore SDK for Go to query information about a tunnel - Tablestore

Después de crear un túnel, llame a la operación DescribeTunnel para consultar su información, como los detalles de los canales que contiene.

Requisitos previos

Se inicializó una instancia de TunnelClient.
Se creó un túnel para la tabla de datos. Para más información, consulte Create a tunnel.

Parámetros

Parámetros de solicitud

Parámetro	Descripción
TableName	El nombre de la tabla de datos cuya información del túnel desea consultar.
TunnelName	El nombre del túnel.

Parámetros de respuesta

Parámetro	Descripción
TunnelRPO	La hora más reciente en la que el túnel se usó para consumir datos incrementales. Corresponde al momento en que el canal más lento del túnel consumió datos. Valor predeterminado: 1 de enero de 1970 (UTC).
List<TunnelInfo>	La información del túnel. La respuesta incluye los siguientes datos: TunnelId: el identificador del túnel. TunnelName: el nombre del túnel. TunnelType: el tipo de túnel. Valores válidos: BaseData, Stream y BaseAndStream. El tipo BaseData indica que el túnel consume los datos completos de la tabla. El tipo Stream señala que el túnel consume datos incrementales. Por su parte, BaseAndStream significa que el túnel procesa datos diferenciales de la tabla. TableName: el nombre de la tabla de datos para la cual se creó el túnel. InstanceName: el nombre de la instancia donde se encuentra el túnel. Stage: la etapa del túnel. Valores válidos: InitBaseDataAndStreamShard, ProcessBaseData y ProcessStream. La etapa InitBaseDataAndStreamShard indica que el túnel se está inicializando. ProcessBaseData señala que el túnel consume datos completos. En cuanto a ProcessStream, muestra que el túnel procesa datos incrementales. Expired: indica si los datos caducaron. Si se devuelve true, comuníquese con el soporte técnico de Tablestore mediante DingTalk lo antes posible.
List<ChannelInfo>	La información de los canales del túnel. La respuesta incluye los siguientes datos: ChannelId: el identificador del canal. ChannelType: el tipo de canal. Valores válidos: Base y Stream. ChannelStatus: el estado del canal. Valores válidos: WAIT, OPEN, CLOSING, CLOSE y TERMINATED. ClientId: el identificador del cliente del túnel. De forma predeterminada, este valor concatena el nombre de host del cliente con una cadena aleatoria. El nombre de host se especifica mediante TunnelWorkerConfig. ChannelRPO: la hora más reciente en la que el canal consumió datos incrementales. Valor predeterminado: 1 de enero de 1970 (UTC). Este parámetro no surte efecto en los canales de tipo Base.
ResponseInfo	Otros campos devueltos en la solicitud, incluido RequestId, que identifica de manera única cada petición.

Ejemplos

A continuación se muestra un ejemplo de código para consultar la información de un túnel. Se obtiene la hora más reciente de consumo de datos incrementales y los detalles de sus canales:

req := &tunnel.DescribeTunnelRequest{
   TableName:  "<TABLE_NAME>",
   TunnelName: "TUNNEL_NAME",
}
resp, err := tunnelClient.DescribeTunnel(req)
if err != nil {
   log.Fatal("describe tunnel failed", err)
}
log.Println("tunnel id is", resp.Tunnel.TunnelId)

Referencias

Para conocer la operación de API que permite consultar la información de un túnel, consulte DescribeTunnel.
Si necesita usar Tunnel Service rápidamente para consumir datos, consulte Getting started.
Es posible consultar la información de todos los túneles de una tabla. Para más detalles, consulte Query information about all tunnels of a data table.
Elimine los túneles que ya no necesite. Para más información, consulte Delete a tunnel.