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