ワンストップで完結する PolarDB-X の データ同期と管理を行う必要がある場合は、PolarDB-X インスタンスでカラムナストレージエンジンを有効にし、宛先の エンタープライズ、ベーシック、またはデータレイクハウスエディション クラスターにバインドできます。 他のデータ同期ソリューションと比較して、このワンストップソリューションは、低コスト、使いやすさ、および真のリアルタイム分析のためのリアルタイムデータ同期を特長としています。 このトピックでは、PolarDB-X インスタンスから AnalyticDB for MySQL エンタープライズ、ベーシック、またはデータレイクハウスエディション クラスターにデータをワンストップで同期する方法について説明します。
前提条件
エンタープライズ版、ベーシック版、またはデータレイクハウス版のクラスターと PolarDB-X 2.0 インスタンスは、同じリージョンにデプロイされ、同じ VPC に属しています。詳細については、「エンタープライズ版またはベーシック版のクラスターを作成する」および「PolarDB-X 2.0 インスタンスを作成する」をご参照ください。
PolarDB-X 2.0 インスタンスが Enterprise Edition で、バージョンが 5.4.19-16989811 以降であること。
説明インスタンスのバージョンを表示およびアップグレードする方法については、「インスタンスバージョンの表示とアップグレード」をご参照ください。
エンタープライズ、ベーシック、またはデータレイクハウスエディションでは、クラスターのカーネルバージョンは 3.2.0.0 以降である必要があります。
説明AnalyticDB for MySQL コンソール に移動し、[Cluster Information] ページを開きます。[Configuration Information] セクションで、カーネルバージョンを表示およびアップグレードしてください。
エンタープライズ版、ベーシック版、またはデータレイクハウス版クラスター用にデータベースアカウントが作成されます。
背景情報
AnalyticDB for MySQL は、レイクハウスアーキテクチャ上に構築されたリアルタイムデータウェアハウスであり、大量データに対して高性能なクエリを実現します。 PolarDB-X は、数百万の同時接続と数百ペタバイトのストレージをサポートする高性能なクラウドネイティブ分散データベースです。 PolarDB-X 2.0 インスタンスでカラムナストレージエンジンを有効にし、エンタープライズ、ベーシック、またはデータレイクハウスエディションのクラスターにバインドすると、エンタープライズ、ベーシック、またはデータレイクハウスエディションのクラスターは自動的にメタデータ検出タスクを作成します。 PolarDB-X 2.0 インスタンス内のカラムナテーブルのメタデータは、エンタープライズ、ベーシック、またはデータレイクハウスエディションのクラスターに自動的に同期され、そこで直接データ分析を実行できます。
PolarDB-X 2.0 インスタンスのデータのワンストップ同期には、次の利点があります:
リアルタイム同期: PolarDB-X 2.0 でデータを変更すると、数秒以内に エンタープライズ版、ベーシック版、またはデータレイクハウス版 のクラスターに変更が同期されます。数秒以内に エンタープライズ版、ベーシック版、またはデータレイクハウス版 のクラスターで更新されたデータを照会でき、真のリアルタイム分析が可能です。
使いやすさ:PolarDB-X 2.0 のデータとテーブルスキーマが変更されると、その変更はエンタープライズ版、ベーシック版、またはデータレイクハウス版 のクラスターに自動的に同期され、手動での管理は不要です。
高い費用対効果と低コスト:PolarDB-X 2.0 で列指向ストレージエンジンを有効にしても、追加料金は発生しません。エンタープライズ版、ベーシック版、またはデータレイクハウス版 クラスターでデータ分析を実行する場合、SQL 開発にジョブベースのリソースグループを使用できます。ジョブベースのリソースグループは、弾力的なコンピューティングリソースとストレージリソースをオンデマンドで低コストで提供します。
シナリオ
PolarDB-X 2.0 データのワンストップ同期は、次のシナリオに適用できます:
PolarDB-X 2.0 データのリアルタイム分析:オンラインビジネスに影響を与えることなく、PolarDB-X 2.0 のデータに対してリアルタイム分析を実行する。
複数データソースの共同分析:PolarDB-X 2.0 のデータと他のソースからのデータを関連付けて分析する。
複数インスタンスの PolarDB-X 2.0 データの分析:複数の PolarDB-X 2.0 インスタンスにまたがるデータの共同分析を実行する。
注意事項
データ同期中、PolarDB-X 2.0 インスタンスにあるものと同じ名前のデータベースとテーブルが、Enterprise、Basic、または Data Lakehouse Edition クラスターに作成されます。そのため、データ同期の際は、次の項目にご注意ください。
エンタープライズ版、ベーシック版、またはデータレイクハウス版のクラスターに同じ名前のデータベースまたはテーブルがすでに存在する場合、データ同期は失敗します。
エンタープライズ版、ベーシック版、またはデータレイクハウス版クラスターに同じ名前のデータベースが存在する場合、新しいデータベースは作成されません。テーブルは既存のデータベースに同期されます。
データ準備
この例では、PolarDB-X 2.0 データベースの名前を test_adb とし、このデータベースに person という名前のテーブルを作成します。例:
CREATE DATABASE test_adb MODE='AUTO'
CREATE TABLE person (
`id` bigint NOT NULL AUTO_INCREMENT,
`age` int(11) NOT NULL DEFAULT '0',
`name` char(60) NOT NULL DEFAULT '',
`city` char(60) NOT NULL DEFAULT '',
PRIMARY KEY (`id`),
INDEX `age_1` (`age`)
) PARTITION BY KEY(`id`) PARTITIONS 4;person テーブルにデータを挿入します。例:
INSERT INTO person VALUES (1,23,'Bob','Hangzhou'),(2,33,'Make','Wuhan');person テーブルの id カラムにカラムナインデックスを作成します。インデックス名は person_col_index です。
CREATE clustered columnar INDEX `person_col_index` ON person(`id`) PARTITION BY hash(`id`) partitions 4;手順
ステップ 1:PolarDB-X 2.0 のカラムナストレージエンジンを有効化
PolarDB-X コンソールにログインします。
ページの左上隅で、対象のインスタンスが配置されているリージョンを選択します。
[Instances] ページで [PolarDB-X 2.0] タブをクリックし、ターゲットインスタンスの ID をクリックします。
左側メニューで、[Columnar Engine] をクリックします。
[Create Columnar Engine] をクリックします。[Create Columnar Engine] ダイアログボックスで、[OK] をクリックします。
説明ページの右上隅にある
ボタンをクリックすると、カラムナストレージエンジン作成の [Task Progress] を表示できます。[Topology] セクションのノードの [Status] が [In Use] に変わると、カラムナストレージエンジンが有効になります。ページの右上隅にある [Enable ADB Lakehouse] をクリックします。
[ADB Lakehouse Cluster List] ダイアログボックスで、ターゲットの Enterprise Edition、Basic Edition、または Data Lakehouse Edition のクラスターを選択し、[OK] をクリックします。
説明バインドが成功すると、ターゲットの Enterprise Edition、Basic Edition、または Data Lakehouse Edition のクラスターは、対応するメタデータ検出タスクを自動的に作成します。
ステップ 2:Enterprise Edition、Basic Edition、または Data Lakehouse Edition のクラスターでデータ分析を実行
AnalyticDB for MySQL コンソール にログインします。
左上隅で、クラスターがデプロイされているリージョンを選択します。左側メニューで、[Clusters] をクリックし、ターゲットクラスターの ID をクリックします。
左側メニューで、 を選択します。
[Task List] セクションで、自動生成されたメタデータ検出タスクの実行ステータスを表示します。
タスクが正常に実行された後 (つまり、[Last Running Status] に [Success] と表示された後)、 ページに移動して、Enterprise Edition、Basic Edition、または Data Lakehouse Edition のクラスターに同期されたデータベースとテーブルを表示できます。
SELECT * FROM test_adb.person;返される結果:
+--------+---------+----------+----------+ | id | age | name | city | +--------+---------+----------+----------+ | 1 | 23 | Bob | Hangzhou | +--------+---------+----------+----------+ | 2 | 33 | Make | Wuhan | +--------+---------+----------+----------+