Tunnel Service adalah layanan terintegrasi yang dibangun di atas Tablestore dan menyediakan saluran terdistribusi untuk konsumsi data penuh serta inkremental secara real-time. Anda dapat membuat saluran data inkremental, penuh, atau inkremental-plus-penuh untuk tabel Anda, sehingga memungkinkan pemrosesan data historis maupun data baru dengan mudah.
| Jenis Terowongan | Nilai mode | Deskripsi |
|---|---|---|
| Full tunnel | base_data_only |
Mengonsumsi dan memproses hanya data penuh. |
| Incremental tunnel | stream_data_only |
Mengonsumsi dan memproses hanya data inkremental. |
| Differential tunnel | base_and_stream |
Mengonsumsi dan memproses data penuh terlebih dahulu, kemudian data inkremental. |
Setelah membuat tunnel, Anda dapat menggunakannya untuk mengonsumsi data historis dan inkremental yang diekspor dari tabel tertentu.
create_tunnel
Membuat tunnel untuk tabel data.
Sintaks perintah
create_tunnel -n name
Tabel berikut menjelaskan item konfigurasi.
|
Parameter |
Wajib |
Contoh |
Deskripsi |
|
|
Tidak |
|
Nama tabel data. |
|
|
Ya |
|
Nama tunnel. |
|
|
Tidak |
|
Tipe tunnel. Nilai default: |
Contoh
Buat tunnel bernama t1 untuk tabel data:
create_tunnel -n t1
Respons contoh:
New tunnel created, id is '9933470d-8a5e-4972-a5b0-b7ae6f836460'.
describe_tunnel
Menampilkan informasi tunnel dan informasi saluran terkait tunnel tersebut.
Sintaks perintah
describe_tunnel -n name
Tabel berikut menjelaskan item konfigurasi.
|
Parameter |
Wajib |
Contoh |
Deskripsi |
|
|
Tidak |
|
Nama tabel data. |
|
|
Ya |
|
Nama tunnel. |
|
|
Tidak |
|
File lokal tempat menyimpan hasil respons. |
Contoh
Tampilkan informasi tentang tunnel bernama t1:
describe_tunnel -n t1
Respons contoh:
Tunnel Info:
+--------------------------------------+------------+------------+---------------+---------+
| TunnelId | TunnelName | TunnelType | Stage | Expired |
+--------------------------------------+------------+------------+---------------+---------+
| 9933470d-8a5e-4972-a5b0-b7ae6f836460 | t1 | Stream | ProcessStream | false |
+--------------------------------------+------------+------------+---------------+---------+
Channel Info:
+-------------------------------------------------------+-------------+---------------+----------+-------------------------------+
| ChannelId | ChannelType | ChannelStatus | ClientId | ChannelRPO |
+-------------------------------------------------------+-------------+---------------+----------+-------------------------------+
| cfd2c05b-54b6-48ec-aa6f-feb427f0ca57_1635771329155688 | Stream | OPEN | | 1970-01-01 08:00:00 +0800 CST |
+-------------------------------------------------------+-------------+---------------+----------+-------------------------------+
consume_tunnel
Meniru konsumsi data tunnel. Setelah membuat tunnel, Anda dapat meniru konsumsi datanya untuk melihat pratinjau format data dalam tunnel tersebut.
Sintaks perintah
consume_tunnel -n name -m mock_consume
Tabel berikut menjelaskan item konfigurasi.
|
Parameter |
Wajib |
Contoh |
Deskripsi |
|
|
Tidak |
|
ID channel. Jika Anda tidak menentukan parameter ini, data di semua channel tunnel akan dikonsumsi. |
|
|
Tidak |
|
Nama tabel data. |
|
|
Ya |
|
Nama tunnel. |
|
|
Ya |
|
Mode konsumsi. Nilai default: |
Contoh
Tirukan konsumsi data tunnel bernama t1:
consume_tunnel -n t1 -m mock_consume
Setelah menjalankan perintah, catatan konsumsi data akan ditampilkan saat data ditulis ke tabel data. Respons contoh:
Starting consume tunnel 't1' of table 'mytable', it may take a few seconds to start, please wait...
null
drop_tunnel
Menghapus tunnel yang tidak lagi diperlukan.
Sintaks perintah
drop_tunnel -n name -y
Tabel berikut menjelaskan item konfigurasi.
|
Parameter |
Wajib |
Contoh |
Deskripsi |
|
|
Tidak |
|
Nama tabel data. |
|
|
Ya |
|
Nama tunnel. |
|
|
Ya |
N/A |
Menentukan bahwa informasi konfirmasi muncul. Anda harus menyertakan parameter ini dalam perintah. |
Contoh
Hapus tunnel bernama t1:
drop_tunnel -n t1 -y