Go SDK for Tablestore を使用してトンネルを作成する - Tablestore

データテーブルのデータをリアルタイムで消費する場合、CreateTunnel オペレーションを呼び出して、テーブルのトンネルを作成できます。1 つのデータテーブルに複数のトンネルを作成できます。トンネルを作成する際は、データテーブル名、トンネル名、およびトンネルタイプを指定する必要があります。

前提条件

TunnelClient インスタンスが初期化されている。
データテーブルが作成されている。詳細については、データテーブルを作成するをご参照ください。

パラメーター

リクエストパラメーター

パラメーター	説明
TableName	トンネルを作成するデータテーブルの名前。
TunnelName	トンネルの名前。
Type	トンネルのタイプ。有効な値：BaseData、Stream、および BaseAndStream。BaseData タイプは、トンネルがデータテーブルの全データを消費するために使用されることを指定します。Stream タイプは、トンネルがデータテーブルの増分データを消費するために使用されることを指定します。BaseAndStream タイプは、トンネルがデータテーブルの差分データを消費するために使用されることを指定します。このパラメーターを Stream または BaseAndStream に設定すると、システムはトンネルの作成後にデータテーブルに書き込まれたデータを増分と見なします。特定の時点以降に生成された増分データを消費する場合は、増分データの startTime パラメーターを設定する必要があります。 startTime パラメーターの有効な値：`[現在のシステム時刻 - ストリーム有効期間 + 5 分、現在のシステム時刻]`。単位：ナノ秒。説明ストリーム有効期間は、増分ログの有効期間（ミリ秒単位）です。増分ログの最大有効期間は 7 日間です。データテーブルの Stream を有効にする際に、Stream の有効期間を指定できます。指定した後は、Stream の有効期間を変更することはできません。消費する増分データの endTime パラメーターも設定できます。endTime パラメーターの値は、startTime パラメーターの値よりも大きい必要があります。

レスポンスパラメーター

パラメーター	説明
TunnelId	トンネルの ID。
ResponseInfo	レスポンスで返されるその他のフィールド。リクエストの RequestId フィールドを含みます。RequestId はリクエストを一意に識別します。

例

次のサンプルコードは、BaseAndStream タイプのトンネルを作成する方法の例を示しています。

req := &tunnel.CreateTunnelRequest{
   TableName:  "<TABLE_NAME>",
   TunnelName: "<TUNNEL_NAME>",
   Type:       tunnel.TunnelTypeBaseStream, // BaseAndStream タイプのトンネルを作成します。
}
resp, err := tunnelClient.CreateTunnel(req)
if err != nil {
   log.Fatal("create tunnel failed ", err)
}
log.Println("tunnel id is", resp.TunnelId)

FAQ

トンネルサービスを使用してデータを使用する際に「OTSTrimmedDataAccess 要求されたストリームデータは既に削除されているか、存在しません」というエラーメッセージが返された場合はどうすればよいですか？

参照

トンネルを作成するために呼び出すことができる API オペレーションについては、CreateTunnel をご参照ください。
トンネルサービスを使用してデータをすぐに使用したい場合は、はじめにをご参照ください。
テーブルのすべてのトンネルに関する情報をクエリできます。詳細については、データテーブルのすべてのトンネルに関する情報をクエリするをご参照ください。
トンネルに関する情報をクエリできます。詳細については、トンネルに関する情報をクエリするをご参照ください。
不要になったトンネルを削除できます。詳細については、トンネルを削除するをご参照ください。
トンネルサービスを使用してデータを移行できます。詳細については、Tablestore 内のあるテーブルから別のテーブルにデータを同期するをご参照ください。
Realtime Compute for Apache Flink は、トンネルサービスのトンネルをストリーミングデータのソースとして使用して、Tablestore データを計算および分析できます。詳細については、ワイドカラムモデルのチュートリアルおよびチュートリアル（時系列モデル）をご参照ください。
トンネルサービスは無料です。ただし、トンネルを使用してデータを消費する際に発生する読み取りスループットについては課金されます。詳細については、課金概要をご参照ください。