Tablestore:Memulai dengan Tunnel Service

Langkah 1: Membuat tunnel

1. Buka halaman Tunnels.

   1. Masuk ke Tablestore console.

   2. Pada bilah navigasi atas, pilih kelompok sumber daya dan Wilayah.

   3. Pada halaman Overview, klik nama instans atau klik Manage Instance di kolom Actions instans tersebut.

   4. Pada tab Instance Details, klik tab Tables. Klik nama tabel data yang dituju, lalu klik tab Tunnels. Atau, klik di kolom Actions tabel data tersebut dan pilih Tunnels.

2. Pada tab Tunnels, klik Create Tunnel.

3. Pada kotak dialog Create Tunnel, konfigurasikan parameter berikut:

   Parameter	Deskripsi
   Tunnel name	Nama tunnel.
   Tunnel type	Jenis tunnel. Nilai yang valid: Full: Mengonsumsi semua data yang ada di tabel data. Incremental: Hanya mengonsumsi data baru yang ditulis ke tabel data. Differential: Mengonsumsi semua data yang ada di tabel data, diikuti oleh semua data baru.
   Start time	Saat membuat tunnel Incremental atau Full and Incremental, data yang ditulis setelah tunnel dibuat dianggap sebagai data inkremental secara default. Untuk mengonsumsi data inkremental dari titik waktu tertentu, konfigurasikan Start Time. Anda juga dapat mengonfigurasi End Time sesuai kebutuhan. Nilai untuk Start Time dan End Time harus berupa timestamp 64-bit dalam milidetik dan berada dalam rentang [waktu sistem saat ini - Stream expiration time + 5 menit , waktu sistem saat ini]. End Time harus lebih akhir daripada Start Time. Penting Stream expiration time adalah periode retensi untuk log perubahan, dengan maksimum 7 hari. Durasi ini ditetapkan saat Anda mengaktifkan fitur Stream untuk tabel data. Pengaturan ini tidak dapat diubah setelah ditetapkan.
   End time

4. Klik OK.

   Setelah tunnel dibuat, klik Show Channels di sisi kanan tunnel. Anda dapat melihat konten data, memantau latensi konsumsi, serta memeriksa jumlah baris yang telah dikonsumsi untuk setiap partisi channel.

   Setelah tunnel dibuat, statusnya adalah Processing Full Data. Daftar partisi channel berisi satu partisi Full dengan status Open dan satu partisi Incremental dengan status Waiting. Anda dapat mengklik Simulate Consumption di kolom Actions untuk melihat data yang telah dikonsumsi.

Langkah 2: (Opsional) Pratinjau format data tunnel

Setelah membuat tunnel, Anda dapat mensimulasikan konsumsi data untuk melihat pratinjau format catatan data.

1. Tulis data ke atau hapus data dari tabel.

2. Pada tab Tunnels tabel, klik Show Channels di kolom Actions untuk tunnel tersebut.

3. Di kolom Actions partisi channel, klik View Simulated Export Records.

4. Pada kotak dialog View Simulated Export Records, klik Start.

   Kotak dialog akan menampilkan catatan data yang telah dikonsumsi.

   Contoh catatan data yang dikonsumsi

   Contoh berikut menunjukkan catatan data yang dikonsumsi:

   {
     "sequenceInfo": {
       "epoch": 0,
       "rowIndex": 0,
       "timestamp": 0
     },
     "recordType": "PUT",
     "columns": [
       {
         "actionType": "PUT",
         "name": "create_time",
         "type": "STRING",
         "value": "2024-02-18 22:10:07"
       },
       {
         "actionType": "PUT",
         "name": "modified_time",
         "type": "STRING",
         "value": "2024-02-18 22:10:07"
       },
       {
         "actionType": "PUT",
         "name": "num",
         "type": "INTEGER",
         "value": 29
       },
       {
         "actionType": "PUT",
         "name": "order_status",
         "type": "STRING",
         "value": "00"
       },
       {
         "actionType": "PUT",
         "name": "price",
         "type": "DOUBLE",
         "value": 400
       },
       {
         "actionType": "PUT",
         "name": "sku_id",
         "type": "STRING",
         "value": "9000000007"
       },
       {
         "actionType": "PUT",
         "name": "total_price",
         "type": "DOUBLE",
         "value": 11600
       },
       {
         "actionType": "PUT",
         "name": "user_id",
         "type": "STRING",
         "value": "1000000042"
       }
     ],
     "primaryKey": [
       {
         "name": "order_id",
         "type": "STRING",
         "value": "90fb478c-1360-11f0-a34d-00163e30a2a9"
       }
     ],
     "timestamp": 0
   }

Langkah 3: Mulai mengonsumsi data dari tunnel

1. Pada tab Tunnels, salin ID tunnel dari daftar.

2. Gunakan Tablestore SDK for Java atau Tablestore SDK for Go untuk mengonsumsi data dari tunnel secara cepat.

   Setelah data dikonsumsi, Anda dapat melihat log yang berisi statistik konsumsi dan timestamp sinkronisasi terbaru untuk setiap partisi channel inkremental. Di Konsol Tablestore, Anda juga dapat memantau latensi konsumsi dan jumlah baris yang telah dikonsumsi untuk setiap partisi channel.