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

Prérequis

Une instance TunnelClient est initialisée.
Un tunnel est créé pour la table de données. Pour plus d'informations, consultez Créer un tunnel.

Paramètres

Paramètres de requête

Paramètre

Description

TableName

Nom de la table de données dont vous souhaitez interroger les informations de tunnel.

Paramètres de réponse

Paramètre

Description

List<TunnelInfo>

Informations relatives aux tunnels. La réponse inclut les éléments suivants :

TunnelId : ID du tunnel.
TunnelType : type de tunnel. Les valeurs valides sont BaseData, Stream et BaseAndStream. Le type BaseData indique que le tunnel sert à consommer les données complètes de la table de données. Le type Stream indique que le tunnel sert à consommer les données incrémentielles de la table de données. Le type BaseAndStream indique que le tunnel sert à consommer les données différentielles de la table de données.
TableName : nom de la table de données pour laquelle le tunnel est créé.
InstanceName : nom de l'instance dans laquelle se trouve le tunnel.
Stage : étape du tunnel. Les valeurs valides sont InitBaseDataAndStreamShard, ProcessBaseData et ProcessStream. L'étape InitBaseDataAndStreamShard indique que le tunnel est en cours d'initialisation. L'étape ProcessBaseData indique que le tunnel sert à consommer les données complètes. L'étape ProcessStream indique que le tunnel sert à consommer les données incrémentielles.
Expired : indique si les données ont expiré.

Si la valeur true est renvoyée, contactez le support technique Tablestore via DingTalk dès que possible.

ResponseInfo

Autres champs renvoyés dans la réponse, y compris le champ RequestId. RequestId identifie la requête de manière unique.

Exemples

L'exemple de code suivant montre comment interroger les informations sur tous les tunnels d'une table :

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

Références

Pour obtenir des informations sur l'opération API permettant d'interroger les informations sur tous les tunnels d'une table de données, consultez ListTunnel.
Si vous souhaitez utiliser rapidement Tunnel Service pour consommer des données, consultez Démarrage rapide.
Vous pouvez interroger les informations sur un tunnel. Pour plus d'informations, consultez Interroger les informations sur un tunnel.
Vous pouvez supprimer un tunnel dont vous n'avez plus besoin. Pour plus d'informations, consultez Supprimer un tunnel.