Tablestore:Primeros pasos con Tunnel Service

Paso 1: Cree un túnel

1. Vaya a la página Tunnels.

   1. Inicie sesión en la consola de Tablestore.

   2. En la barra de navegación superior, seleccione un resource group y una región.

   3. En la página Overview, haga clic en el nombre de una instancia o en Manage Instance dentro de la columna Actions correspondiente.

   4. En la pestaña Instance Details, seleccione la pestaña Tables. Haga clic en el nombre de la tabla de datos deseada y luego en la pestaña Tunnels. También puede hacer clic en en la columna Actions de la tabla de datos y seleccionar Tunnels.

2. En la pestaña Tunnels, haga clic en Create Tunnel.

3. En el cuadro de diálogo Create Tunnel, configure los siguientes parámetros:

   Parámetro	Descripción
   Nombre del túnel	Nombre del túnel.
   Tipo de túnel	Tipo de túnel. Valores válidos: Full: Consume todos los datos existentes en la tabla de datos. Incremental: Consume solo los nuevos datos escritos en la tabla de datos. Differential: Consume primero todos los datos existentes en la tabla de datos y después los datos nuevos.
   Hora de inicio	Al crear un túnel Incremental o Full and Incremental, los datos escritos tras su creación se consideran incrementales de forma predeterminada. Para consumir datos incrementales desde un momento específico, configure la Start Time. También puede configurar una End Time según sea necesario. Los valores de Start Time y End Time deben ser marcas de tiempo de 64 bits en milisegundos y encontrarse dentro del rango [current system time - Stream expiration time + 5 minutes , current system time]. La End Time debe ser posterior a la Start Time. Importante La Stream expiration time es el periodo de retención del registro de cambios, con un máximo de 7 días. Esta duración se establece al habilitar la función Stream para una tabla de datos y no se puede modificar posteriormente.
   Hora de fin

4. Haga clic en OK.

   Una vez creado el túnel, haga clic en Show Channels a la derecha del túnel. Podrá consultar el contenido de los datos, supervisar la latencia de consumo y verificar el número de filas consumidas por cada partición de canal.

   Tras crear el túnel, su estado será Processing Full Data. La lista de particiones de canal incluye una partición Full con estado Open y una partición Incremental con estado Waiting. Puede hacer clic en Simulate Consumption en la columna Actions para ver los datos consumidos.

Paso 2: (Opcional) Previsualizar el formato de datos del túnel

Después de crear el túnel, simule el consumo de datos para previsualizar el formato de los registros.

1. Write data a la tabla o Delete data de ella.

2. En la pestaña Tunnels de la tabla, haga clic en Show Channels en la columna Actions del túnel.

3. En la columna Actions de una partición de canal, haga clic en View Simulated Export Records.

4. En el cuadro de diálogo View Simulated Export Records, haga clic en Start.

   El cuadro de diálogo muestra los registros de datos consumidos.

   Ejemplo de un registro de datos consumido

   A continuación se muestra un ejemplo de registro de datos consumido:

   {
     "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
   }

Paso 3: Iniciar el consumo de datos del túnel

1. En la pestaña Tunnels, copie el ID del túnel de la lista.

2. Use Tablestore SDK for Java o Tablestore SDK for Go para consumir datos del túnel rápidamente.

   Tras consumir los datos, consulte los registros con estadísticas de consumo y la última marca de tiempo de sincronización de cada partición de canal incremental. En la consola de Tablestore también puede supervisar la latencia de consumo y el número de filas consumidas por cada partición de canal.