Tablestore:Get started with Tunnel Service

Étape 1 : Créer un tunnel

1. Accédez à la page Tunnels.

   1. Connectez-vous à la console Tablestore.

   2. Dans la barre de navigation supérieure, sélectionnez un groupe de ressources et une région.

   3. Sur la page Overview, cliquez sur le nom d'une instance ou sur Manage Instance dans la colonne Actions de l'instance concernée.

   4. Dans l'onglet Instance Details, cliquez sur l'onglet Tables. Cliquez sur le nom de la table de données cible, puis sur l'onglet Tunnels. Vous pouvez également cliquer sur dans la colonne Actions de la table de données et sélectionner Tunnels.

2. Dans l'onglet Tunnels, cliquez sur Create Tunnel.

3. Dans la boîte de dialogue Create Tunnel, configurez les paramètres suivants :

   Paramètre	Description
   Nom du tunnel	Nom attribué au tunnel.
   Type de tunnel	Type du tunnel. Valeurs valides : Full : consomme toutes les données existantes dans la table de données. Incremental : consomme uniquement les nouvelles données écrites dans la table de données. Differential : consomme d'abord toutes les données existantes, puis toutes les nouvelles données.
   Heure de début	Lorsque vous créez un tunnel de type Incremental ou Full and Incremental, les données écrites après la création du tunnel sont considérées par défaut comme des données incrémentielles. Pour consommer des données incrémentielles à partir d'un moment précis, configurez l'Start Time. Vous pouvez également définir une End Time si nécessaire. Les valeurs de l'heure de début et de l'heure de fin doivent être des horodatages 64 bits en millisecondes, compris dans l'intervalle [heure système actuelle - durée d'expiration du Stream + 5 minutes , heure système actuelle]. L'heure de fin doit être postérieure à l'heure de début. Important La durée d'expiration du Stream correspond à la période de rétention du journal des modifications, avec un maximum de 7 jours. Cette durée est définie lors de l'activation de la fonctionnalité Stream pour une table de données. Ce paramètre ne peut plus être modifié une fois défini.
   Heure de fin

4. Cliquez sur OK.

   Une fois le tunnel créé, cliquez sur Show Channels à droite du tunnel. Vous pouvez ainsi consulter le contenu des données, surveiller la latence de consommation et vérifier le nombre de lignes consommées pour chaque partition de canal.

   Après la création, le statut du tunnel passe à Processing Full Data. La liste des partitions de canal contient une partition Full avec le statut Open et une partition Incremental avec le statut Waiting. Cliquez sur Simulate Consumption dans la colonne Actions pour visualiser les données consommées.

Étape 2 : (Facultatif) Prévisualiser le format des données du tunnel

Après avoir créé le tunnel, simulez la consommation de données pour prévisualiser le format des enregistrements.

1. Écrivez des données dans la table ou supprimez des données de celle-ci.

2. Dans l'onglet Tunnels de la table, cliquez sur Show Channels dans la colonne Actions du tunnel.

3. Dans la colonne Actions d'une partition de canal, cliquez sur View Simulated Export Records.

4. Dans la boîte de dialogue View Simulated Export Records, cliquez sur Start.

   La boîte de dialogue affiche les enregistrements de données consommés.

   Exemple d'enregistrement de données consommé

   L'exemple suivant présente un enregistrement de données consommé :

   {
     "sequenceInfo": {
       "epoch": 0,
       "rowIndex": 0,
       "timestamp": 0
     },
     "recordType": "PUT",
     "columns": [
       {
         "actionType": "PUT",
         "name": "create_time",
         "type": "STRING",
         "value": "2024-02-18 22:10:07"
       },
       {
         "actionType": "PUT",
         "name": "modified_time",
         "type": "STRING",
         "value": "2024-02-18 22:10:07"
       },
       {
         "actionType": "PUT",
         "name": "num",
         "type": "INTEGER",
         "value": 29
       },
       {
         "actionType": "PUT",
         "name": "order_status",
         "type": "STRING",
         "value": "00"
       },
       {
         "actionType": "PUT",
         "name": "price",
         "type": "DOUBLE",
         "value": 400
       },
       {
         "actionType": "PUT",
         "name": "sku_id",
         "type": "STRING",
         "value": "9000000007"
       },
       {
         "actionType": "PUT",
         "name": "total_price",
         "type": "DOUBLE",
         "value": 11600
       },
       {
         "actionType": "PUT",
         "name": "user_id",
         "type": "STRING",
         "value": "1000000042"
       }
     ],
     "primaryKey": [
       {
         "name": "order_id",
         "type": "STRING",
         "value": "90fb478c-1360-11f0-a34d-00163e30a2a9"
       }
     ],
     "timestamp": 0
   }

Étape 3 : Démarrer la consommation des données du tunnel

1. Dans l'onglet Tunnels, copiez l'ID du tunnel depuis la liste.

2. Utilisez le SDK Tablestore pour Java ou le SDK Tablestore pour Go pour consommer rapidement les données du tunnel.

   Une fois les données consommées, consultez les journaux contenant les statistiques de consommation et le dernier horodatage de synchronisation pour chaque partition de canal incrémentiel. Dans la console Tablestore, surveillez également la latence de consommation et le nombre de lignes consommées pour chaque partition de canal.