O Tablestore SDK for Go encapsula o framework de consumo automático de dados e várias operações de API, como as operações de gerenciamento do Tunnel Service.
Início rápido
Antes de usar o Tunnel Service para consumir dados de uma tabela de dados em tempo real, crie um túnel para a tabela. Em seguida, use o túnel para consumir os dados da tabela. Para mais informações, consulte Getting started.
Operações de gerenciamento
Para criar um túnel para uma tabela de dados, especifique o nome da tabela, além do nome e do tipo do túnel. Para mais informações, consulte Create a tunnel.
Após criar um túnel, gerencie-o de acordo com as necessidades do seu negócio.
|
Operação |
Descrição |
|
Consulte informações sobre todos os túneis de uma tabela de dados. |
|
|
Consulte as informações de canal de um túnel. Um canal corresponde a um shard para a operação Stream do Tablestore. |
|
|
Exclua um túnel de uma tabela de dados. |
Framework de consumo de dados
O framework de consumo automático de dados funciona da seguinte forma: o Tunnel Client detecta canais ativos por meio de detecção periódica de heartbeat, atualiza o status dos canais e do ChannelConnect, e inicializa, executa e encerra tarefas de processamento de dados.
O Tunnel Client ajuda a resolver problemas comuns no processamento de dados completos e incrementais, como balanceamento de carga, recuperação de falhas, checkpoints e sincronização de informações de partição para garantir a ordem de consumo dessas informações. Ao usar o Tunnel Client, os desenvolvedores precisam apenas focar na lógica de processamento de cada registro. Para mais informações, consulte Tunnel clients.
Referências
Para obter uma visão geral do Tunnel Service, consulte Overview.
Use o Tunnel Service para migrar dados. Para mais informações, consulte Synchronize data from one table to another table in Tablestore.
O Real-time Compute for Apache Flink pode usar túneis de dados do Tunnel Service como entrada para dados de streaming, a fim de computar e analisar dados do Tablestore. Para mais informações, consulte Tutorial for the Wide Column model e Tutorial (TimeSeries model).
O Tunnel Service em si não gera taxas adicionais. Ao consumir dados do Tunnel Service, o Tablestore cobra taxas com base no throughput de leitura real. Para mais informações, consulte Billing overview.