Puede llamar a la operación CreateTunnel para crear uno o más túneles en una tabla. Al crear un túnel, debe especificar el nombre de la tabla, el nombre del túnel y el tipo de túnel.
Requisitos previos
Se inicializó una instancia de TunnelClient.
Se creó una tabla de datos. Para obtener más información, consulte Create a data table.
Parámetros
Parámetros de solicitud
Parámetro | Descripción |
TableName | Nombre de la tabla de datos para la que desea crear un túnel. |
TunnelName | Nombre del túnel. |
Type | Tipo del 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 indica que el túnel se usa para consumir los datos incrementales de la tabla. El tipo BaseAndStream indica que el túnel se usa para consumir los datos diferenciales de la tabla. Si establece este parámetro en Stream o BaseAndStream, el sistema considera incrementales los datos escritos en la tabla después de crear el túnel. Si desea consumir los datos incrementales generados a partir de un momento específico, configure el parámetro startTime para dichos datos.
|
Parámetros de respuesta
|
Parámetro |
Descripción |
|
TunnelId |
Identificador del túnel. |
|
ResponseInfo |
Otros campos devueltos en la respuesta, incluido el campo RequestId de la solicitud. RequestId identifica de forma única la solicitud. |
Ejemplos
A continuación se muestra un ejemplo de código para crear un túnel de tipo 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)
Preguntas frecuentes
Referencias
Para obtener información sobre la operación de API que permite crear un túnel, consulte CreateTunnel.
Si desea usar rápidamente Tunnel Service para consumir datos, consulte Getting started.
Es posible consultar la información de todos los túneles de una tabla. Para obtener más información, consulte Query information about all tunnels of a data table.
También puede consultar la información de un túnel específico. Para obtener más información, consulte Query information about a tunnel.
Si ya no necesita un túnel, puede eliminarlo. Para obtener más información, consulte Delete a tunnel.
Tunnel Service sirve para migrar datos. Para obtener más información, consulte Synchronize data between tables.
Realtime Compute for Apache Flink utiliza los túneles de Tunnel Service como origen de datos de streaming para calcular y analizar la información de Tablestore. Para obtener más información, consulte Use Realtime Compute for Apache Flink to process Tablestore data y Use Realtime Compute for Apache Flink to process Tablestore data.
El uso de Tunnel Service no genera cargos. Sin embargo, se cobra por el rendimiento de lectura generado al consumir datos mediante los túneles. Para obtener más información, consulte Billing overview.