すべてのプロダクト
Search
ドキュメントセンター

Tablestore:トンネルサービスの使用開始

最終更新日:May 15, 2025

Tablestore コンソールでトンネルサービスの使用を開始できます。

手順

ステップ 1: トンネルを作成する

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

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

    2. 上部のナビゲーションバーで、リソースグループとリージョンを選択します。

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

    4. [インスタンスの詳細] タブで、[テーブル] タブをクリックします。次に、データテーブル名をクリックし、[トンネル] タブを選択します。または、fig_001 をクリックし、データテーブルの [アクション] 列のショートカットメニューから [トンネル] を選択することもできます。

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

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

    パラメーター

    説明

    トンネル名

    トンネルの名前。

    タイプ

    トンネルのタイプ。有効値:

    • [完全]: 完全データのみを消費および処理できます。

    • [増分]: 増分データのみを消費および処理できます。

    • [差分]: 完全データが消費および処理された後、増分データが消費および処理されます。

    開始時間

    [タイプ] パラメーターを [増分] または [差分] に設定した場合、システムは、トンネルが作成された後にデータテーブルに書き込まれたデータを増分と見なします。特定の時点以降にデータテーブルに書き込まれた増分データを消費する場合、増分データの [開始時間] パラメーターを設定します。ビジネス要件に基づいて、増分データの [終了時間] パラメーターを設定することもできます。

    [開始時間] および [終了時間] パラメーターの有効値の範囲: [現在のシステム時間 - ストリームの有効期間 + 5分、現在のシステム時間]。2 つのパラメーターの値は、ミリ秒単位の 64 ビット タイムスタンプです。[終了時間] パラメーターの値は、[開始時間] パラメーターの値よりも大きくなければなりません。

    重要

    ストリームの有効期間は、増分ログの有効期間(ミリ秒単位)です。ストリームの有効期間の最大値は 7 日間です。データテーブルのストリームを有効にする際に、ストリームの有効期間を指定できます。ストリームの有効期間を指定した後は、変更できません。

    終了時間

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

    トンネルが作成された後、トンネルの [アクション] 列の [チャネルの表示] をクリックします。トンネル内のデータコンテンツ、消費レイテンシの監視情報、各チャネルで消費されたデータ行数を確認できます。

    image

ステップ 2: (オプション) トンネル内のデータ形式をプレビューする

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

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

  2. テーブルの [トンネル] タブで、トンネルの [アクション] 列の [チャネルの表示] をクリックします。

  3. チャネルの [アクション] 列で、[シミュレートされたエクスポート レコードの表示] をクリックします。

  4. [シミュレートされたエクスポート レコードの表示] ダイアログボックスで、[開始] をクリックします。

    消費されたデータの情報が、次の図のようにダイアログボックスに表示されます。

    image

    消費されたデータ形式の例

    消費されたデータ形式の例を次に示します。

    {
      "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. Java 用 Tablestore SDK または Go 用 Tablestore SDK を使用して、トンネルを使用してデータをすばやく消費します。

    データ消費後、消費統計や増分チャネルの最新の同期時間などの増分データ消費ログを表示できます。また、Tablestore コンソールで、各チャネルの消費レイテンシと消費されたデータ行数を確認することもできます。

開発統合

Tablestore CLI または Tablestore SDK を使用して、トンネル操作を実行できます。

機能

呼び出し方法

トンネルを作成する

Tablestore SDK を使用する: Java および Go

Tablestore CLI を使用する

データテーブルのすべてのトンネルに関する情報を照会する

Tablestore SDK を使用する: Java および Go

Tablestore CLI を使用する

トンネルに関する情報を照会する

Tablestore SDK を使用する: Java および Go

Tablestore CLI を使用する

トンネルを使用してデータ消費をシミュレートする

Tablestore CLI を使用する

トンネルを削除する

Tablestore SDK を使用する: Java および Go

Tablestore CLI を使用する