Após criar um túnel, chame a operação DescribeTunnel para consultar informações sobre ele, como os detalhes dos canais associados.
Pré-requisitos
Instância do TunnelClient inicializada.
Túnel criado para a tabela de dados. Para mais informações, consulte Criar um túnel.
Parâmetros
Parâmetros de solicitação
|
Parâmetro |
Descrição |
|
TableName |
Nome da tabela de dados cujas informações do túnel serão consultadas. |
|
TunnelName |
Nome do túnel. |
Parâmetros de resposta
|
Parâmetro |
Descrição |
|
TunnelConsumePoint |
Momento mais recente em que o túnel consumiu dados incrementais. Esse horário corresponde ao ponto no tempo em que o canal mais lento do túnel consumiu dados. Valor padrão: 1º de janeiro de 1970 (UTC). |
|
TunnelInfo |
Informações detalhadas sobre o túnel. A resposta inclui os seguintes dados:
|
|
List<ChannelInfo> |
Detalhes sobre os canais presentes no túnel. A resposta contém as seguintes informações:
|
|
RequestId |
ID da solicitação. |
Exemplos
O código de exemplo abaixo demonstra como consultar informações de um túnel, incluindo o momento mais recente de consumo de dados incrementais e os detalhes dos canais associados:
// The most recent time when the tunnel is used to consume incremental data and the recovery point objective (RPO) take effect only if the tunnel is of the Stream type.
// Stream tunnel: The Stage parameter in TunnelInfo is ProcessStream. Stream channel: The ChannelType parameter in ChannelInfo is Stream.
private static void describeTunnel(TunnelClient client, String tableName, String tunnelName) {
DescribeTunnelRequest request = new DescribeTunnelRequest(tableName, tunnelName);
DescribeTunnelResponse resp = client.describeTunnel(request);
System.out.println("RequestId: " + resp.getRequestId());
// The most recent time when the tunnel is used to consume incremental data. The time is the point in time when the slowest channel in the tunnel is used to consume data. Default value: January 1, 1970 (UTC).
System.out.println("TunnelConsumePoint: " + resp.getTunnelConsumePoint());
System.out.println("TunnelInfo: " + resp.getTunnelInfo());
for (ChannelInfo ci : resp.getChannelInfos()) {
System.out.println("ChannelInfo::::::");
System.out.println("\tChannelId: " + ci.getChannelId());
// The type of the channel. Valid values: BaseData and Stream.
System.out.println("\tChannelType: " + ci.getChannelType());
// The ID of the tunnel client. By default, the client ID concatenates the hostname of the client and a random string.
System.out.println("\tClientId: " + ci.getClientId());
// The most recent time when the channel is used to consume incremental data.
System.out.println("\tChannelConsumePoint: " + ci.getChannelConsumePoint());
// The number of data entries that the channel synchronizes.
System.out.println("\tChannelCount: " + ci.getChannelCount());
}
}
Referências
Para obter detalhes sobre a operação de API usada na consulta de informações do túnel, consulte DescribeTunnel.
Para começar a usar rapidamente o Tunnel Service no consumo de dados, veja Guia de introdução.
É possível listar todos os túneis de uma tabela. Saiba mais em Consultar informações de todos os túneis de uma tabela de dados.
Para excluir um túnel desnecessário, consulte Excluir um túnel.