Query tunnel information - Tablestore SDK for Java - Tablestore

Ön koşullar

Tablestore SDK for Java yükleyin ve TunnelClient'ı başlatın.

Özellik açıklaması

Bir tünel hakkında bilgi sorgulamak için describeTunnel yöntemini çağırın. Yanıt; tünel yapılandırmasını, genel artımlı tüketim noktasını ve kurtarma noktası hedefini (RPO) ile tüneldeki her bir kanalın durumunu ve tüketim ilerlemesini içerir.

DescribeTunnelResponse describeTunnel(DescribeTunnelRequest request)
        throws TableStoreException, ClientException

Aşağıdaki örnek, example_table tablosunun example_tunnel tüneliyle ilgili bilgileri sorgular ve tünel aşamasını, her bir kanalın durumunu ve tüketim ilerlemesini yazdırır:

String tableName = "example_table";
String tunnelName = "example_tunnel";

DescribeTunnelRequest request =
        new DescribeTunnelRequest(tableName, tunnelName);
DescribeTunnelResponse response = tunnelClient.describeTunnel(request);

TunnelInfo tunnelInfo = response.getTunnelInfo();
System.out.printf(
        "name=%s, type=%s, stage=%s%n",
        tunnelInfo.getTunnelName(),
        tunnelInfo.getTunnelType(),
        tunnelInfo.getStage());

for (ChannelInfo channelInfo : response.getChannelInfos()) {
    System.out.printf(
            "channelId=%s, type=%s, status=%s, count=%d%n",
            channelInfo.getChannelId(),
            channelInfo.getChannelType(),
            channelInfo.getChannelStatus(),
            channelInfo.getChannelCount());
}

Parametreler

request parametresi DescribeTunnelRequest türündedir ve aşağıdaki parametreleri içerir:

Ad	Tür	Açıklama
tableName (gerekli)	`String`	Tablo adı.
tunnelName (gerekli)	`String`	Tünel adı.

Dönüş değerleri

Dönüş değeri DescribeTunnelResponse türündedir ve aşağıdaki alanları içerir:

Ad	Tür	Açıklama
tunnelConsumePoint	`Date`	Tünelin en son artımlı tüketim noktası. Değer, tüneldeki en yavaş kanalın tüketim noktasıdır. Varsayılan değer: 1 Ocak 1970, 00:00:00 (UTC). Bu alanı elde etmek için `getTunnelConsumePoint()` yöntemini çağırın.
tunnelRpo	`long`	Tünelin artımlı tüketim RPO'su; geçerli zaman ile en yavaş kanalın tüketim noktası arasındaki farktır. Birim: milisaniye. Bu alanı elde etmek için `getTunnelRpo()` yöntemini çağırın.
tunnelInfo	`TunnelInfo`	Tünel bilgileri. Bu alanı elde etmek için `getTunnelInfo()` yöntemini çağırın. Alanlar, Tünelleri listele tarafından döndürülen `TunnelInfo` nesnelerindeki alanlarla aynıdır.
channelInfos	`List<ChannelInfo>`	Tüneldeki kanal listesi. Tünel henüz herhangi bir kanalı başlatmamışsa boş bir liste döndürülür. Bu alanı elde etmek için `getChannelInfos()` yöntemini çağırın.

Not

tunnelConsumePoint ve tunnelRpo yalnızca artımlı tüketime uygulanır. Artımlı tüketim başlamadıysa veya tünel yalnızca tam verileri tüketiyorsa tunnelConsumePoint varsayılan değere sahiptir. Bu durumda, tüketim gecikmesini belirlemek için tunnelRpo kullanmayın.

Kanal bilgileri

channelInfos[] dizisindeki her öğe ChannelInfo türündedir ve aşağıdaki alanları içerir:

Ad	Tür	Açıklama
channelId	`String`	Kanal kimliği.
channelType	`ChannelType`	Kanal türü. Geçerli değerler: Tam veri kanalını gösteren `BaseData` ve artımlı veri kanalını gösteren `Stream`.
channelStatus	`ChannelStatus`	Kanal durumu. Geçerli değerler: Bekliyor anlamına gelen `WAIT`, açık anlamına gelen `OPEN`, kapanıyor anlamına gelen `CLOSING`, kapalı anlamına gelen `CLOSE` ve sonlandırılmış anlamına gelen `TERMINATED`.
clientId	`String`	Kanalı tüketen istemcinin kimliği. Kanala atanmış bir istemci yoksa bu alan boş olabilir. İstemci kimliği, `TunnelWorkerConfig.clientTag` temel alınarak oluşturulur. İstemci tanımlayıcısını özelleştirmek için `setClientTag()` yöntemini çağırabilirsiniz.
channelConsumePoint	`Date`	Kanalın en son artımlı tüketim noktası. Varsayılan değer: 1 Ocak 1970, 00:00:00 (UTC). Bu alan tam veri kanalları için geçerli değildir.
channelRpo	`long`	Kanalın artımlı tüketim RPO'su; geçerli zaman ile `channelConsumePoint` arasındaki farktır. Birim: milisaniye. Bu alan tam veri kanalları için geçerli değildir.
channelCount	`long`	Kanal tarafından senkronize edilen satır sayısı.