BladePipe
Introduction
BladePipe は、リアルタイムのエンドツーエンドデータレプリケーションツールであり、30以上のデータベース、メッセージキュー、検索エンジン、キャッシングシステム、リアルタイムデータウェアハウス、データレイクなどの間で、超低レイテンシーでデータを移動します。効率性、安定性、スケーラビリティ、多様なデータベースエンジンとの互換性、ワンストップ管理、強化されたセキュリティ、複雑なデータ変換を特徴としています。BladePipe はデータサイロを解消し、データの価値を高めます。
Features
BladePipe は視覚化された管理インターフェースを提供し、スキーマ移行、データ移行、同期、検証と修正 などを実現する DataJob を簡単に作成できます。さらに、パラメータ設定によってより詳細でカスタマイズされた設定をサポートします。現在、BladePipe は以下のソース DataSource から StarRocks へのデータ移動をサポートしています。
| Source DataSource | Schema Migration | Data Migration | Data Sync | Verification & Correction |
|---|---|---|---|---|
| MySQL/MariaDB/AuroraMySQL | Yes | Yes | Yes | Yes |
| Oracle | Yes | Yes | Yes | Yes |
| PostgreSQL/AuroraPostgreSQL | Yes | Yes | Yes | Yes |
| SQL Server | Yes | Yes | Yes | Yes |
| Kafka | No | No | Yes | No |
| AutoMQ | No | No | Yes | No |
| TiDB | Yes | Yes | Yes | Yes |
| Hana | Yes | Yes | Yes | Yes |
| PolarDB for MySQL | Yes | Yes | Yes | Yes |
| Db2 | Yes | Yes | Yes | Yes |
サポートされている機能とパラメータ設定の詳細については、BladePipe Connections を参照してください。
Installation
Example
MySQL インスタンスを例にとり、MySQL から StarRocks へのデータ移行方法を説明します。
Add DataSources
-
BladePipe Cloud にログインします。DataSource > Add DataSource をクリックします。
-
StarRocks を Type として選択し、セットアップフォームに記入します。
- Client Address：MySQL クライアントに提供される StarRocks のポート。BladePipe はこれを介してデータベースのメタデータをクエリします。
- Account: StarRocks データベースのユーザー名。StarRocks にデータを書き込むには INSERT 権限が必要です。GRANT に記載された指示に従って、データベースユーザーに INSERT 権限を付与してください。
- Http Address：BladePipe からのリクエストを受け取るために 使用されるポート。
-
Test Connection をクリックします。接続が成功したら、Add DataSource をクリックして DataSource を追加します。
-
上記の手順に従って MySQL DataSource を追加します。
Create DataJob
-
DataJob > Create DataJob をクリックします。
-
ソースとターゲットの DataSource を選択し、Test Connection をクリックして、ソースとターゲットの DataSource への接続が両方とも成功していることを確認します。
-
DataJob Type に Incremental を選択し、Full Data オプションを選択します。
-
レプリケートするテーブルを選択します。スキーマ移行後に自動的に作成されるターゲット StarRocks テーブルにはプライマリキーがあるため、プライマリキーのない ソーステーブルは現在サポートされていません。
-
レプリケートするカラムを選択します。
-
DataJob の作成を確認します。
-
DataJob は自動的に実行されます。BladePipe は以下の DataTasks を自動的に実行します:
- Schema Migration: ソーステーブルのスキーマがターゲットインスタンスに移行されます。
- Full Data: ソーステーブルの既存のすべてのデータがターゲットインスタンスに完全に移行されます。
- Incremental: 継続的なデータ変更がターゲットインスタンスに継続的に同期されます（レイテンシーは1分未満）。
