データサブスクリプションは、OceanBase Cloudが提供するデータベースのリアルタイム増分データを取得するサービスであり、OceanBaseデータベース(MySQL互換モードおよびOracle互換モードを含む)でのデータサブスクリプションをサポートしています。
説明
データサブスクリプションは許可リスト機能です。この機能を利用する場合は、テクニカルサポートにお問い合わせください。
操作手順
データサブスクリプションタスクを新規作成します。
OceanBase Cloudコンソールにログインします。
左側のナビゲーションバーで、データサービス > データサブスクリプション をクリックします。
データサブスクリプション ページで、右上の サブスクリプションタスクの新規作成 をクリックします。
タスク名を編集するテキストボックスに、カスタムしたサブスクリプションタスク名を入力します。
名前には漢字、数字、英字の組み合わせを推奨します。スペースを含めず、64文字以内で入力してください。
データ送信元の設定 ページで、各パラメータを設定します。
既に作成・保存されているデータソースを参照する必要がある場合、データ送信元 の右側にある データソースの参照 をクリックし、プルダウンリストから対象のデータソースを選択します。選択後、データ送信元ページの各設定が自動的に入力されます。現在の設定を新しいデータソースとして保存する場合は、右上の データソースの保存 アイコンをクリックします。
データソースの参照 のプルダウンリストで データソース管理 をクリックすると、データソース ページに移動し、データソースの表示・管理ができます。このページでは異なるタイプのデータソースを一元的に管理できます。詳細については、データソースモジュールのドキュメントを参照してください。
パラメータ説明クラウドプロバイダー 現在、**Alibaba Cloud**のみサポートしています。 リージョン データ送信元データベースが存在するリージョンを選択します。 データベースタイプ 現在、OceanBase MySQL CompatibleとOceanBase Oracle Compatibleのみサポートしています。 インスタンスタイプ 現在、**クラスタインスタンス(トランザクション型)**のみサポートしています。 インスタンス プルダウンリストから、OceanBaseデータベースのMySQLまたはOracle互換モードのテナントが存在するインスタンスIDまたは名前を選択します。 テナント プルダウンリストから、OceanBaseデータベースのMySQLまたはOracle互換モードのテナントIDまたは名前を選択します。 アカウント データサブスクリプション用のOceanBaseデータベースのユーザー名。 パスワード データベースユーザーのパスワード。 テストして続行 をクリックします。
タイプとオブジェクトの選択 本ページの サブスクリプションタイプ エリアで、サブスクライブするデータ送信元データベースのタイプを選択します。
サブスクリプションタイプは、データ変更 と 構造変更 です。
データ変更:選択したオブジェクトのINSERT、DELETE、UPDATEなどの増分データ更新をサブスクライブします。
構造変更:選択したオブジェクトの構造作成、変更、削除などの変更をサブスクライブします。
タイプとオブジェクトの選択 ページの 購読範囲の選択 エリアで、サブスクライブするデータ送信元データベースのオブジェクトを選択します。
データサブスクリプションは DB/テーブル購読 と データベース全体の購読 をサポートします。データベース内のテーブルサブスクリプションでは、1つまたは複数のデータベース内のテーブルをサブスクリプションオブジェクトとして選択できます。データベース単体サブスクリプションでは、データベース全体をサブスクリプションオブジェクトとして選択できます。データベースでデータベース内のテーブルサブスクリプションを選択した場合、そのデータベースはデータベース単体サブスクリプションの対象外となります。データベースでデータベース単体サブスクリプションを選択した場合、そのデータベースはデータベース内のテーブルサブスクリプションの対象外となります。
データベース内のテーブルサブスクリプション または データベース全体の購読 のいずれかの方法を選択した後、左側でサブスクライブするオブジェクトを選択し、> をクリックして右側のリストに追加します。データサブスクリプションでは、右側のリスト内の1つまたは複数のサブスクリプションオブジェクトできます。
次へ をクリックします。サブスクリプションオプション ページで、各パラメータを設定します。
パラメータ説明データ形式 サブスクライブ可能なメッセージ形式の設定です。ダウンストリームの消費プログラムは、対応するメッセージ形式に従ってデータを消費する必要があります。現在、Avro と Canal JSON をサポートしています。詳細については、メッセージ形式の説明を参照してください。 Topicのパーティショニング戦略 パーティショニングなし、テーブル名によるパーティション、および プライマリキーによるパーティション をサポートしています。実際の状況に応じて選択してください。 - パーティショニングなし:すべてのデータがシーケンス番号0のパーティションに書き込まれることを示します。
- テーブル名によるパーティション:テーブル名のHASHに基づいてパーティション化され、同じテーブル名のHASH値を持つデータは同一のパーティションに書き込まれます。
- プライマリキーによるパーティション:テーブルのプライマリキーのHASH値に基づいてパーティション化され、同じプライマリキーのHASH値を持つデータは同一のパーティションに書き込まれます。
Topicのパーティション数 パーティションの数を定義するために使用されます。パーティションが多いほど、データは分散されます。デフォルト値は4、最小値は1、最大値は256です。 注意
Topicのパーティショニング戦略が 非パーティション の場合、このパラメータは表示されません。
設定完了後、事前チェック をクリックします。
このページで 保存 をクリックすると、データサブスクリプションタスクの詳細ページに移動し、タスクを開始した後に事前チェックが実施されます。
事前チェックに成功したら、起動 をクリックします。
一時的にデータサブスクリプションタスクを開始する必要がない場合は、保存 をクリックして、データサブスクリプションタスクの詳細ページに移動します。後から必要に応じて開始できます。