Utiliser le SDK Tablestore pour Go afin de créer un tunnel - Tablestore

Prérequis

Initialisez une instance TunnelClient.
Créez une table de données. Pour plus d'informations, consultez Créer une table de données.

Paramètres

Paramètres de requête

Parameter	Description
TableName	Nom de la table de données pour laquelle vous souhaitez créer un tunnel.
TunnelName	Nom du tunnel.
Type	Type du tunnel. Valeurs possibles : BaseData, Stream et BaseAndStream. Le type BaseData permet de consommer les données complètes de la table. Le type Stream permet de consommer les données incrémentielles de la table. Le type BaseAndStream permet de consommer les données différentielles de la table. Si vous définissez ce paramètre sur Stream ou BaseAndStream, le système considère comme incrémentielles les données écrites dans la table après la création du tunnel. Pour consommer des données incrémentielles générées après un instant précis, configurez le paramètre startTime. Valeurs possibles du paramètre startTime : `[Heure système actuelle - Période de validité du flux + 5 minutes, Heure système actuelle]`. Unité : nanosecondes. Remarque La période de validité du flux correspond à la durée de conservation des journaux incrémentiels, exprimée en millisecondes. La durée maximale est de sept jours. Spécifiez cette période lors de l'activation du flux pour la table de données. Elle ne peut pas être modifiée ultérieurement. Vous pouvez également configurer le paramètre endTime pour les données incrémentielles à consommer. La valeur de endTime doit être supérieure à celle de startTime.

Paramètres de réponse

Parameter

Description

TunnelId

ID du tunnel.

ResponseInfo

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

Exemples

L'exemple de code suivant montre comment créer un tunnel de type BaseAndStream :

req := &tunnel.CreateTunnelRequest{
   TableName:  "<TABLE_NAME>",
   TunnelName: "<TUNNEL_NAME>",
   Type:       tunnel.TunnelTypeBaseStream, // Create a tunnel of the BaseAndStream type. 
}
resp, err := tunnelClient.CreateTunnel(req)
if err != nil {
   log.Fatal("create tunnel failed ", err)
}
log.Println("tunnel id is", resp.TunnelId)

FAQ

Que faire si le message d'erreur « OTSTrimmedDataAccess Requested stream data is already trimmed or does not exist » s'affiche lors de la consommation de données avec Tunnel Service ?

Références

Pour plus d'informations sur l'opération API permettant de créer un tunnel, consultez CreateTunnel.
Pour utiliser rapidement Tunnel Service afin de consommer des données, consultez Démarrage rapide.
Interrogez les informations relatives à tous les tunnels d'une table. Pour plus d'informations, consultez Interroger les informations relatives à tous les tunnels d'une table de données.
Interrogez les informations relatives à un tunnel. Pour plus d'informations, consultez Interroger les informations relatives à un tunnel.
Supprimez un tunnel dont vous n'avez plus besoin. Pour plus d'informations, consultez Supprimer un tunnel.
Utilisez Tunnel Service pour migrer des données. Pour plus d'informations, consultez Synchroniser des données entre des tables.
Realtime Compute for Apache Flink peut utiliser les tunnels de Tunnel Service comme source de données en continu pour calculer et analyser les données Tablestore. Pour plus d'informations, consultez Utiliser Realtime Compute for Apache Flink pour traiter les données Tablestore et Utiliser Realtime Compute for Apache Flink pour traiter les données Tablestore.
Tunnel Service est gratuit. Toutefois, le débit de lecture généré lors de la consommation de données via les tunnels est facturé. Pour plus d'informations, consultez Présentation de la facturation.