Gunakan Tablestore SDK untuk Go untuk membuat terowongan - Tablestore

Untuk mengonsumsi data dalam tabel secara real-time, Anda dapat memanggil operasi CreateTunnel untuk membuat terowongan. Beberapa terowongan dapat dibuat untuk satu tabel. Saat membuat terowongan, tentukan nama tabel, nama terowongan, dan jenis terowongan.

Prasyarat

Instance TunnelClient telah diinisialisasi.
Tabel telah dibuat. Untuk informasi lebih lanjut, lihat Buat Tabel.

Parameter

Parameter permintaan

Parameter	Deskripsi
TableName	Nama tabel data untuk mana Anda ingin membuat terowongan.
TunnelName	Nama terowongan.
Type	Jenis terowongan. Nilai yang valid: BaseData, Stream, dan BaseAndStream. Jenis BaseData menentukan bahwa terowongan digunakan untuk mengonsumsi seluruh data dari tabel data. Jenis Stream menentukan bahwa terowongan digunakan untuk mengonsumsi data tambahan dari tabel data. Jenis BaseAndStream menentukan bahwa terowongan digunakan untuk mengonsumsi data diferensial dari tabel data. Jika Anda mengatur parameter ini ke Stream atau BaseAndStream, sistem akan menganggap data yang ditulis ke tabel data setelah terowongan dibuat sebagai tambahan. Jika Anda ingin mengonsumsi data tambahan yang dihasilkan setelah titik waktu tertentu, Anda harus mengonfigurasi parameter startTime untuk data tambahan tersebut. Nilai yang valid untuk parameter startTime: `[Waktu sistem saat ini - Periode validitas Stream + 5 menit, Waktu sistem saat ini]`. Unit: nanodetik. Catatan Periode validitas Stream adalah periode validitas log tambahan dalam milidetik. Periode validitas maksimum log tambahan adalah tujuh hari. Anda dapat menentukan periode validitas Stream saat Anda mengaktifkan Stream untuk tabel data. Anda tidak dapat mengubah periode validitas Stream setelah Anda menentukannya. Anda juga dapat mengonfigurasi parameter endTime untuk data tambahan yang ingin Anda konsumsi. Nilai parameter endTime harus lebih besar dari nilai parameter startTime.

Parameter respons

Parameter	Deskripsi
TunnelId	ID terowongan.
ResponseInfo	Bidang lainnya yang dikembalikan dalam respons, termasuk bidang RequestId dalam permintaan. RequestId secara unik mengidentifikasi permintaan.

Contoh

Kode berikut menunjukkan cara membuat terowongan tipe BaseAndStream:

req := &tunnel.CreateTunnelRequest{
   TableName:  "<TABLE_NAME>",
   TunnelName: "<TUNNEL_NAME>",
   Type:       tunnel.TunnelTypeBaseStream, // Buat terowongan tipe BaseAndStream.
}
resp, err := tunnelClient.CreateTunnel(req)
if err != nil {
   log.Fatal("gagal membuat terowongan ", err)
}
log.Println("ID terowongan adalah", resp.TunnelId)

FAQ

Apa yang harus dilakukan jika pesan kesalahan "OTSTrimmedDataAccess Requested stream data is already trimmed or does not exist" muncul saat menggunakan Layanan Terowongan untuk mengonsumsi data?

Referensi

Untuk detail tentang operasi API yang dapat dipanggil untuk membuat terowongan, lihat CreateTunnel.
Untuk segera menggunakan Layanan Terowongan dalam mengonsumsi data, lihat Memulai.
Untuk memeriksa informasi semua terowongan dari sebuah tabel, lihat Kueri Informasi Semua Terowongan dari Tabel.
Untuk memeriksa informasi sebuah terowongan, lihat Kueri Informasi Sebuah Terowongan.
Untuk menghapus terowongan yang tidak diperlukan, lihat Hapus Terowongan.
Untuk migrasi data menggunakan Layanan Terowongan, lihat Sinkronisasi Data Antar Tabel.
Realtime Compute for Apache Flink dapat menggunakan terowongan dari Layanan Terowongan sebagai sumber data streaming untuk menghitung dan menganalisis data Tablestore. Untuk informasi lebih lanjut, lihat Gunakan Realtime Compute for Apache Flink untuk Memproses Data Tablestore.
Layanan Terowongan tidak dikenakan biaya. Namun, throughput baca yang dihasilkan saat menggunakan terowongan untuk mengonsumsi data akan dikenakan biaya. Untuk informasi lebih lanjut, lihat Ikhtisar Penagihan.