Gunakan Tablestore SDK untuk Java untuk menanyakan informasi tentang sebuah terowongan - Tablestore

Setelah membuat terowongan, Anda dapat memanggil operasi DescribeTunnel untuk menanyakan informasi terkait, seperti detail saluran di dalam terowongan.

Prasyarat

Instance TunnelClient telah diinisialisasi.
Terowongan telah dibuat untuk tabel data. Untuk informasi lebih lanjut, lihat Buat Sebuah Terowongan.

Parameter

Parameter permintaan

Parameter	Deskripsi
NamaTabel	Nama dari tabel data yang ingin Anda tanyakan informasi terowongannya.
NamaTerowongan	Nama dari terowongan.

Parameter respons

Parameter	Deskripsi
TunnelConsumePoint	Waktu terbaru ketika terowongan digunakan untuk mengonsumsi data inkremental. Waktu ini adalah titik waktu ketika saluran paling lambat di dalam terowongan digunakan untuk mengonsumsi data. Nilai default: 1 Januari 1970 (UTC).
TunnelInfo	Informasi tentang terowongan. Informasi berikut termasuk dalam respons: TunnelId: ID dari terowongan. TunnelType: jenis dari terowongan. Nilai valid: BaseData, Stream, dan BaseAndStream. Jenis BaseData menunjukkan bahwa terowongan digunakan untuk mengonsumsi data penuh dari tabel data. Jenis Stream menunjukkan bahwa terowongan digunakan untuk mengonsumsi data inkremental dari tabel data. Jenis BaseAndStream menunjukkan bahwa terowongan digunakan untuk mengonsumsi data diferensial dari tabel data. NamaTabel: nama dari tabel data untuk mana terowongan dibuat. NamaInstansi: nama dari instansi tempat terowongan berada. Tahap: tahap dari terowongan. Nilai valid: InitBaseDataAndStreamShard, ProcessBaseData, dan ProcessStream. Tahap InitBaseDataAndStreamShard menunjukkan bahwa terowongan sedang diinisialisasi. Tahap ProcessBaseData menunjukkan bahwa terowongan sedang digunakan untuk mengonsumsi data penuh. Tahap ProcessStream menunjukkan bahwa terowongan sedang digunakan untuk mengonsumsi data inkremental. Kedaluwarsa: menunjukkan apakah data sudah kedaluwarsa. Jika true dikembalikan, hubungi dukungan teknis Tablestore secepat mungkin menggunakan DingTalk.
List<ChannelInfo>	Informasi tentang saluran di dalam terowongan. Informasi berikut termasuk dalam respons: ChannelId: ID dari saluran. ChannelType: jenis dari saluran. Nilai valid: BaseData dan Stream. ChannelStatus: status dari saluran. Nilai valid: WAIT, OPEN, CLOSING, CLOSE, dan TERMINATED. ClientId: ID dari klien terowongan. Secara default, ID klien menggabungkan nama host dari klien dan string acak. Nama host klien dapat ditentukan menggunakan TunnelWorkerConfig. ChannelConsumePoint: waktu terbaru ketika saluran digunakan untuk mengonsumsi data inkremental. Nilai default: 1 Januari 1970 (UTC). Parameter ini tidak berlaku untuk saluran jenis BaseData. ChannelCount: jumlah entri data yang disinkronkan oleh saluran.
RequestId	ID dari permintaan.

Contoh

Berikut adalah contoh kode yang mengilustrasikan cara menanyakan informasi tentang sebuah terowongan, termasuk waktu terakhir penggunaan terowongan untuk mengonsumsi data inkremental dan detail saluran di dalam terowongan:

// Waktu terbaru ketika terowongan digunakan untuk mengonsumsi data inkremental dan recovery point objective (RPO) hanya berlaku jika terowongan adalah jenis Stream. 
// Terowongan Stream: Parameter Stage dalam TunnelInfo adalah ProcessStream. Saluran Stream: Parameter ChannelType dalam ChannelInfo adalah 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());
    // Waktu terbaru ketika terowongan digunakan untuk mengonsumsi data inkremental. Waktu ini adalah titik waktu ketika saluran paling lambat di dalam terowongan digunakan untuk mengonsumsi data. Nilai default: 1 Januari 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());
        // Jenis dari saluran. Nilai valid: BaseData dan Stream. 
        System.out.println("\tChannelType: " + ci.getChannelType());
        // ID dari klien terowongan. Secara default, ID klien menggabungkan nama host dari klien dan string acak. 
        System.out.println("\tClientId: " + ci.getClientId());
        // Waktu terbaru ketika saluran digunakan untuk mengonsumsi data inkremental. 
        System.out.println("\tChannelConsumePoint: " + ci.getChannelConsumePoint());
        // Jumlah entri data yang disinkronkan oleh saluran. 
        System.out.println("\tChannelCount: " + ci.getChannelCount());
    }
}

Referensi

Untuk informasi tentang operasi API yang dapat dipanggil untuk menanyakan informasi terowongan, lihat DescribeTunnel.
Untuk memulai dengan cepat menggunakan Layanan Terowongan guna mengonsumsi data, lihat Memulai.
Anda dapat menanyakan informasi tentang semua terowongan dari sebuah tabel. Untuk informasi lebih lanjut, lihat Menanyakan Informasi tentang Semua Terowongan dari Sebuah Tabel Data.
Anda dapat menghapus terowongan yang tidak lagi diperlukan. Untuk informasi lebih lanjut, lihat Hapus Sebuah Terowongan.