Tablestore:トンネルサービスのクイックスタート

ステップ 1：トンネルの作成

1. トンネル ページに移動します。

   1. Tablestore コンソールにログインします。

   2. 上部メニューで、リソースグループとリージョンを選択します。

   3. 概要 ページで、インスタンス名をクリックするか、インスタンスの 操作 列の インスタンスの管理 をクリックします。

   4. インスタンスの詳細 タブで、テーブルリスト タブをクリックします。対象のデータテーブルの名前をクリックし、トンネル タブをクリックします。または、データテーブルの操作列にあるをクリックしてトンネルを選択します。

2. トンネル タブで、トンネルの作成 をクリックします。

3. トンネルの作成 ダイアログボックスで、次のパラメーターを設定します:

   パラメータ	説明
   [トンネル名]	トンネルの名前です。
   [トンネルタイプ]	トンネルのタイプです。有効な値： [完全]：データテーブル内の既存のデータをすべて消費します。 [増分]：データテーブルに新たに書き込まれたデータのみを消費します。 [差分]：データテーブル内の既存のデータをすべて消費した後、新しいデータをすべて消費します。
   [開始時刻]	[インクリメンタル] または [差分] トンネルを作成する場合、トンネル作成後に書き込まれたデータは、デフォルトでインクリメンタルデータと見なされます。特定の時点からインクリメンタルデータを消費するには、[開始時刻] を設定します。必要に応じて [終了時刻] も設定できます。 開始時刻と終了時刻の値は、いずれもミリ秒単位の 64 ビットタイムスタンプで、[current system time - Stream expiration time + 5 minutes, current system time] の範囲内にある必要があります。終了時刻は開始時刻より後である必要があります。 重要 ストリームの有効期限は、変更ログの保持期間です。最大 7 日です。この期間は、データテーブルでストリーム機能を有効化する際に設定します。この設定は、一度設定すると変更できません。
   [終了時刻]

4. OK をクリックします。

   トンネルが作成されたら、トンネルの右側にあるチャンネルリストの表示をクリックすると、チャネルパーティションごとにデータ内容を表示し、消費レイテンシーをモニタリングし、消費された行数を確認できます。

   トンネルの作成後、ステータスは "Processing Full Data" になります。チャネルパーティションのリストには、ステータスが "Open" の フル パーティションが 1 つと、ステータスが "Waiting" の インクリメンタル パーティションが 1 つ含まれます。[操作] 列で [シミュレートされたエクスポートレコードの表示] をクリックすると、消費されたデータを確認できます。

ステップ 2：（オプション）トンネルデータ形式のプレビュー

トンネルの作成後、データ消費をシミュレートして、データレコードの形式をプレビューできます。

1. テーブルにデータを書き込むか、テーブルからデータを削除します。

2. テーブルのトンネルタブで、目的のトンネルの操作列にあるチャンネルリストの表示をクリックします。

3. チャネルパーティションの操作列で、同期のシミュレーション をクリックします。

4. 同期のシミュレーション ダイアログボックスで、開始 をクリックします。

   ダイアログボックスに、消費されたデータレコードが表示されます。

   消費されたデータレコードの例

   次に、消費されたデータレコードの例を示します。

   {
     "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
   }

ステップ 3：トンネルからのデータ消費の開始

1. トンネル タブで、一覧からトンネル ID をコピーします。

2. Tablestore SDK for Java または Tablestore SDK for Go を使用して、トンネルからデータをすばやく消費できます。

   データが消費されると、消費統計や各インクリメンタルチャネルパーティションの最新の同期タイムスタンプが含まれるログを確認できます。Tablestore コンソールでは、各チャネルパーティションの消費レイテンシーと消費された行数も監視できます。