O Tablestore SDK for Go encapsula o framework de consumo automático de dados e diversas operações de API do Tunnel Service, como as operações de gerenciamento.
Início rápido
Antes de usar o Tunnel Service para consumir dados de uma tabela de dados em tempo real, crie um tunnel para a tabela. Em seguida, use o tunnel para consumir os dados da tabela. Para mais informações, consulte Primeiros passos.
Operações de gerenciamento
Para criar um tunnel para uma tabela de dados, especifique o nome da tabela, o nome e o tipo do tunnel. Para mais informações, consulte Criar um tunnel.
Após criar um tunnel, gerencie-o de acordo com as necessidades do seu negócio.
Operação | Descrição |
Consultar informações de todos os tunnels de uma tabela de dados | Consulta informações de todos os tunnels de uma tabela de dados. |
Consulta as informações de canal de um tunnel. Um canal corresponde a um shard da operação Stream do Tablestore. | |
Exclui um tunnel de uma tabela de dados. |
Framework de consumo de dados
No framework de consumo automático de dados, os clientes de tunnel verificam heartbeats regularmente para detectar canais ativos, atualizar o status dos canais e das tarefas de ChannelConnect, além de inicializar, executar e encerrar tarefas de processamento de dados.
Os clientes de tunnel oferecem os seguintes recursos para processar dados completos e incrementais: balanceamento de carga, recuperação de falhas, checkpoints e sincronização de informações de partição, que garante a sequência do consumo de dados nas partições. Os clientes de tunnel permitem que você se concentre apenas na lógica de processamento de cada registro. Para mais informações, consulte Como o framework de consumo de dados funciona.
Referências
Para mais informações sobre o Tunnel Service, consulte Visão geral.
Use o Tunnel Service para migrar dados. Para mais informações, consulte Sincronizar dados entre tabelas.
O Realtime Compute for Apache Flink pode usar os tunnels do Tunnel Service como fonte de dados de streaming para computar e analisar dados do Tablestore. Para mais informações, consulte Usar o Realtime Compute for Apache Flink para processar dados do Tablestore.
Não há cobrança pelo Tunnel Service. No entanto, o throughput de leitura gerado ao usar tunnels para consumir dados é cobrado. Para mais informações, consulte Visão geral do faturamento.