本ページでは、Realtime Compute で Table Store 結果テーブルを作成する方法について説明します。 また、Table Store フィールドタイプと Realtime Compute フィールドタイプ間のマッピングについても説明します。

Table Store の概要

Table Store は、 Alibaba Cloud の Apsara システム上に構築された分散 NoSQL データストレージサービスです。 このサービスは、99.99％ の高可用性と 99.999999999％ のデータ信頼性を提供できるように設計されています。 Table Store はデータシャーディングと負荷分散技術を使用して、データスケーリングとアクセス並列処理の観点からシームレスな拡張を実行します。 また、大量の構造化データの保存およびリアルタイムアクセスをサポートしています。

DDL 定義

Realtime Compute は、結果テーブルとしての Table Store の作成をサポートしています。 サンプルコードは次のとおりです。

CREATE TABLE stream_test_hotline_agent (
 name varchar,
 age BIGINT,
 birthday BIGINT,
 primary key(name,age)
) WITH (
 type='ots',
 instanceName='<yourInstanceName>',
 tableName='<yourTableName>',
 accessId='<yourAccessId>',
 accessKey='<yourAccessSecret>',
 endPoint='<yourEndpoint>',
 valueColumns='birthday'
);
注
  • Table Store への接続には、データストレージの登録方法の使用を推奨します。 詳細については、「Table Store リソースの登録」をご参照ください。
  • 宣言されたプライマリキーは、valueColumns パラメーターの値と異なる必要があります。 プライマリキー以外の任意のフィールドを使用できます。

WITH パラメーター

名称 説明 備考
instanceName インスタンス名。 なし
tableName テーブル名。 なし
endPoint インスタンスにアクセスするためのエンドポイント。 「エンドポイント」をご参照ください。
accessId AccessKey ID。 なし
accessKey AccessKey Secret。 なし
valueColumns 挿入するフィールドの列名。 複数入力する場合は、コンマ (,) で区切ります。 2 つのフィールドを挿入する場合は 'ID,NAME' の形式にします。
bufferSize 重複排除後のバッファーサイズ。 オプション。 デフォルト値: 5000。これは 5,000 の入力データレコードがあると出力が開始することを示します。
batchWriteTimeoutMs 書き込みのタイムアウト期間。 単位: ミリ秒。 オプション。 デフォルト値: 5000。 この値は、5000ミリ秒 (5 秒) 以内にデータがTable Store に書き込まれない場合、すべてのバッファーされたデータが書き込まれることを示します。
batchSize 一度に書き込めるレコードの数。 オプション。 デフォルト値: 100。
retryIntervalMs 再試行間隔 (ミリ秒単位)。 オプション。 デフォルト値: 1000
maxRetryTimes 再試行の最大回数。 オプション。 デフォルト値: 100。
ignoreDelete 削除操作を無視するかどうか。 デフォルト値: false 。

フィールドタイプマッピング

Table Store フィールドタイプ Realtime Compute のフィールドタイプ
INTEGER BIGINT
STRING VARCHAR
BOOLEAN BOOLEAN
DOUBLE DOUBLE
注 Table Store 結果テーブルには、宣言された primary key が必要です。 出力データは、Update モードで Table Store 結果テーブルに追加されます。