Use Tablestore SDK for Go to query information about all tunnels of a data table - Tablestore

Después de crear un túnel, llame a la operación ListTunnel para consultar la información de todos los túneles de una tabla. Esta información incluye el nombre, el tipo, el identificador y la etapa del túnel, así como si los datos están caducados.

Requisitos previos

Se inicializó una instancia de TunnelClient.
Se creó un túnel para la tabla de datos. Para obtener 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 de túneles desea consultar.

Parámetros de respuesta

Parámetro

Descripción

List<TunnelInfo>

La información de los túneles. La respuesta incluye lo siguiente:

TunnelId: el identificador del túnel.
TunnelType: el tipo de túnel. Valores válidos: BaseData, Stream y BaseAndStream. El tipo BaseData indica que el túnel se usa para consumir los datos completos de la tabla. El tipo Stream señala que el túnel consume los datos incrementales de la tabla. Por su parte, BaseAndStream significa que el túnel procesa los datos diferenciales de la tabla.
TableName: el nombre de la tabla de datos para la que 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 se utiliza para consumir los datos completos. ProcessStream muestra que el túnel procesa los datos incrementales.
Expired: indica si los datos están caducados.

Si se devuelve true, comuníquese con el soporte técnico de Tablestore mediante DingTalk lo antes posible.

ResponseInfo

Otros campos devueltos en la solicitud, incluido el campo RequestId. Este último identifica la solicitud de forma única.

Ejemplos

A continuación se muestra un ejemplo de código para consultar la información de todos los túneles de una tabla:

req := &tunnel.ListTunnelRequest{
    TableName: "<TABLE_NAME>",
}
resp, err := tunnelClient.ListTunnel(req)
if err != nil {
    log.Fatal("List tunnel failed", err)
} else {
    for i := 0; i < len(resp.Tunnels); i++ {
        log.Println(resp.Tunnels[i].TableName, resp.Tunnels[i].TunnelName, resp.Tunnels[i].TunnelId)
    }
}

Referencias

Para conocer la operación de API que permite consultar la información de todos los túneles de una tabla de datos, consulte ListTunnel.
Si necesita usar rápidamente Tunnel Service para consumir datos, consulte Getting started.
También es posible consultar la información de un túnel específico. Para obtener más detalles, consulte Query information about a tunnel.
Cuando un túnel ya no sea necesario, elimínelo. Para más información, consulte Delete a tunnel.