Use Tablestore SDK for Go to create a tunnel - Tablestore - Alibaba Cloud Dokümantasyon Merkezi

Bir tablo için bir veya daha fazla tünel oluşturmak amacıyla CreateTunnel işlemini çağırabilirsiniz. Tünel oluştururken tablo adını, tünel adını ve tünel türünü belirtmeniz gerekir.

Önkoşullar

Bir TunnelClient örneği başlatılmıştır.
Bir veri tablosu oluşturulmuştur. Daha fazla bilgi için bkz. Veri tablosu oluşturma.

Parametreler

İstek parametreleri

Parametre	Açıklama
TableName	Tünel oluşturmak istediğiniz veri tablosunun adı.
TunnelName	Tünelin adı.
Type	Tünelin türü. Geçerli değerler: BaseData, Stream ve BaseAndStream. BaseData türü, tünelin veri tablosunun tam verilerini tüketmek için kullanıldığını belirtir. Stream türü, tünelin veri tablosunun artımlı verilerini tüketmek için kullanıldığını belirtir. BaseAndStream türü, tünelin veri tablosunun diferansiyel verilerini tüketmek için kullanıldığını belirtir. Bu parametreyi Stream veya BaseAndStream olarak ayarlarsanız sistem, tünel oluşturulduktan sonra veri tablosuna yazılan verileri artımlı olarak kabul eder. Belirli bir zaman noktasından sonra oluşan artımlı verileri tüketmek istiyorsanız artımlı veriler için startTime parametresini yapılandırmanız gerekir. startTime parametresinin geçerli değerleri: `[Geçerli sistem saati - Akış geçerlilik süresi + 5 dakika, Geçerli sistem saati]`. Birim: nanosaniye. Not Akış geçerlilik süresi, artımlı günlüklerin milisaniye cinsinden geçerlilik süresidir. Artımlı günlüklerin maksimum geçerlilik süresi yedi gündür. Veri tablosu için Akışı etkinleştirirken Akış geçerlilik süresini belirtebilirsiniz. Akış geçerlilik süresini belirttiğinizde bu değeri değiştiremezsiniz. Tüketmek istediğiniz artımlı veriler için endTime parametresini de yapılandırabilirsiniz. endTime parametresinin değeri startTime parametresinin değerinden büyük olmalıdır.

Yanıt parametreleri

Parametre	Açıklama
TunnelId	Tünelin kimliği.
ResponseInfo	Yanıta dahil edilen diğer alanlar; isteğin RequestId alanı da buna dahildir. RequestId, isteği benzersiz şekilde tanımlar.

Örnekler

Aşağıdaki örnek kod, BaseAndStream türünde bir tünelin nasıl oluşturulacağını göstermektedir:

req := &tunnel.CreateTunnelRequest{
   TableName:  "<TABLE_NAME>",
   TunnelName: "<TUNNEL_NAME>",
   Type:       tunnel.TunnelTypeBaseStream, // Create a tunnel of the BaseAndStream type. 
}
resp, err := tunnelClient.CreateTunnel(req)
if err != nil {
   log.Fatal("create tunnel failed ", err)
}
log.Println("tunnel id is", resp.TunnelId)

SSS

Tünel Hizmeti'ni kullanarak veri tüketirken "OTSTrimmedDataAccess Requested stream data is already trimmed or does not exist" hata mesajı alınırsa ne yapılmalı?

İlgili Konular

Tünel oluşturmak için çağırabileceğiniz API işlemi hakkında bilgi almak için bkz. CreateTunnel.
Veri tüketmek amacıyla Tünel Hizmeti'ni hızlıca kullanmak istiyorsanız bkz. Başlangıç.
Bir tabloya ait tüm tünellerin bilgilerini sorgulayabilirsiniz. Daha fazla bilgi için bkz. Veri tablosundaki tüm tünellerin bilgilerini sorgulama.
Bir tünelin bilgilerini sorgulayabilirsiniz. Daha fazla bilgi için bkz. Tünel bilgilerini sorgulama.
Artık ihtiyaç duymadığınız bir tüneli silebilirsiniz. Daha fazla bilgi için bkz. Tünel silme.
Veri geçişi yapmak için Tünel Hizmeti'ni kullanabilirsiniz. Daha fazla bilgi için bkz. Tablolar arasında veri senkronize etme.
Realtime Compute for Apache Flink, Tablestore verilerini hesaplamak ve analiz etmek amacıyla akış verisi kaynağı olarak Tünel Hizmeti'nin tünellerini kullanabilir. Daha fazla bilgi için bkz. Tablestore verilerini işlemek için Realtime Compute for Apache Flink kullanma ve Tablestore verilerini işlemek için Realtime Compute for Apache Flink kullanma.
Tünel Hizmeti için ücret alınmaz. Ancak, tünelleri kullanarak veri tükettiğinizde oluşan okuma aktarım hızı için ücretlendirilirsiniz. Daha fazla bilgi için bkz. Faturalandırmaya genel bakış.