日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

通道服務

通道服務(Tunnel Service)是基于表格存儲數據接口上的全增量一體化服務。通道服務提供了增量、全量、增量加全量三種類型的分布式數據實時消費通道。通過為數據表建立數據通道,您可以簡單地實現對表中歷史存量和新增數據的消費處理。

創建通道

為數據表創建一個通道。

命令格式

create_tunnel -n name

配置項說明請參見下表。

配置項

是否必填

示例值

說明

-t,--table

mytable

數據表名稱。

-n,--name

t1

通道名稱。

-m,--mode

stream_data_only

通道類型。取值范圍如下:

  • base_data_only:全量類型。只能消費處理全量數據。

  • stream_data_only(默認):增量類型。只能消費處理增量數據。

  • base_and_stream:全量加增量類型。全量數據消費處理完成后,再消費處理增量數據。

示例

為數據表創建t1通道。

create_tunnel -n t1

返回結果如下:

New tunnel created, its id is '9933470d-8a5e-4972-a5b0-b7ae6f836460'.

獲取通道信息

獲取通道的Tunnel信息以及Channel信息。

命令格式

describe_tunnel -n name

配置項說明請參見下表。

配置項

是否必填

示例值

說明

-t,--table

mytable

數據表名稱。

-n,--name

t1

通道名稱。

-o,--output

D:\\otstest\\mytunnel.txt

將返回結果保存到本地文件中。

示例

獲取t1通道的信息。

describe_tunnel -n t1

返回結果如下:

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 -n name -m mock_consume

配置項說明請參見下表。

配置項

是否必填

示例值

說明

-c,--channel

cfd2c05b-54b6-48ec-aa6f-feb427f0ca57_1635771329155688

Channel ID。如果不設置此項,則表示消費所有Channel。

-t,--table

mytable

數據表名稱。

-n,--name

t1

通道名稱。

-m,--mode

mock_consume

消費模式。取值范圍如下:

  • shadow_copy(默認):復制線上Tunnel消費流量。

  • mock_consume:模擬消費數據,但不會更新斷點記錄信息。

  • real_consume:真實消費數據,會同時更新斷點記錄信息。不推薦使用此模式。

示例

在t1通道上模擬數據消費。

consume_tunnel -n t1 -m mock_consume

執行命令后,當向表中寫入數據時,屏幕中會顯示數據消費記錄,返回示例如下:

Starting consume tunnel 't1' of table 'mytable', it may take a few seconds to start, please wait...
{"Type":0,"Timestamp":1636360028961786,"SequenceInfo":{"Epoch":0,"Timestamp":1636360028961786,"RowIndex":1},"PrimaryKey":{"PrimaryKeys":[{"ColumnName":"uid","Value":"86"},{"ColumnName":"pid","Value":6771}]},"Columns":[{"Type":0,"Name":"name","Value":"redchen","Timestamp":1636360028962},{"Type":0,"Name":"country","Value":"china","Timestamp":1636360028962}]}

刪除通道

刪除不需要的通道。

命令格式

drop_tunnel -n name -y

配置項說明請參見下表。

配置項

是否必填

示例值

說明

-t,--table

mytable

數據表名稱。

-n,--name

t1

通道名稱。

-y,--yes

不涉及

顯示確認信息。命令中必須帶有此配置項。

示例

刪除t1通道。

drop_tunnel -n t1 -y