MariaDBまたはPerconaデータ購読の作成

ダウンロード

フォーカスモード

フォントサイズ

最終更新日: 2026-10-16 19:45:50

AI翻訳

本シナリオでは、DTSを使用してMariaDB、Perconaのデータ購読タスクを作成する操作手順を紹介します。MariaDB、Perconaのデータ購読操作は同一であるため、以下ではMariaDBを例として紹介します。
前提条件
購読対象のソースデータベースを準備し、データベースのバージョンが要件を満たしていることを確認してください。詳細はデータ購読がサポートするデータベースをご参照ください。
ソースインスタンスでBinlogを有効にしました。
ソースインスタンスに購読アカウントを作成しました。必要なアカウント権限は以下の通りです：REPLICATION CLIENT、REPLICATION SLAVE、PROCESS、および全オブジェクトのSELECT権限。
具体的な権限付与ステートメントは以下の通りです：
create user 'アカウント' IDENTIFIED BY 'パスワード';
grant SELECT, REPLICATION CLIENT,REPLICATION SLAVE,PROCESS on *.* to 'アカウント'@'%';
flush privileges;
制約事項
購読したメッセージ内容の現在のデフォルト保存期間は直近1日間です。保存期間を過ぎたデータは削除されます。データが消費される前に削除されないよう、ユーザーは速やかに消費してください。
データ消費の地域は、購読インスタンスの地域と同じである必要があります。
現在、geometry関連のデータ型はサポートされていません。 
購読タスク中に購読対象の変更などの操作を行うと、タスクの再起動が発生します。再起動後、ユーザーがkafkaクライアントでデータを消費する際に重複が発生する可能性があります。
DTSは最小データユニット単位で伝送を行います。増分データは、checkpointの位置が1つマークされるごとに1つのデータユニットとなります。再起動時に、ちょうど1つのデータユニットの伝送が完了している場合は、データの重複は発生しません。再起動時に、1つのデータユニットがまだ伝送中である場合は、再度起動した後にこのデータユニットを再取得してデータの整合性を保つ必要があるため、データの重複が発生します。
ユーザーが重複データを気にする場合は、データを消費する際に重複排除ロジックを設定してください。
サポートされるSQL操作
操作タイプ
サポートされる SQL 操作
DML
INSERT、UPDATE、DELETE
DDL
CREATE DATABASE、DROP DATABASE、CREATE TABLE、ALTER TABLE、DROP TABLE、RENAME TABLE
操作手順
1. DTSコンソールにログインし、左側のナビゲーションでデータ購読を選択し、新しいデータ購読をクリックします。
2. 新しいデータ購読ページで、対応する設定を選択し、今すぐ購入をクリックします。
課金モード：年額・月額課金と従量課金をサポートします。
地域：ソースデータベースがTencent Cloudデータベースの場合、ここの地域はソースデータベースインスタンスの地域と一致させる必要があります。ソースデータベースがTencent Cloudデータベース以外の場合、ここの地域はデータ消費の地域と一致させます。データ消費の地域に特別な要件がない場合は、ソースデータベースに最も近い地域を選択してください。
データベース：データベースタイプを選択してください。
バージョン：Kafka版を選択します。Kafkaクライアントから直接消費できます。
購読インスタンス名：現在のデータ購読インスタンスの名前を編集します。
3. 購入が成功した後、データ購読リストに戻り、操作列の購読の設定をクリックして、購入したばかりの購読を設定します。設定が完了してから使用できます。
4. データベース購読の設定ページで、ソースデータベースの対応する設定を選択し、完了後に接続テストをクリックします。テストが成功した後、保存して次へをクリックします。
設定項目
説明
インスタンスタイプ
購入時に選択したデータベースタイプです。
プライマリデータベースを選択して購読することをお勧めします。購読サービスがソースデータベースに与える負荷は非常に小さいです。
ソースデータベースがTencentDB for MariaDBの場合、災害復旧/読み取り専用インスタンスの選択をサポートします。
アクセスタイプ
お客様のシナリオに応じて選択してください。異なるアクセスタイプの準備作業については、準備作業の概要を参照してください。
公衆網：ソースデータベースにはパブリックIPアドレスでアクセスできます。
CVM自社構築：ソースデータベースはTencent CVM上に配置されています。
Direct Connect：ソースデータベースはDirect Connectを介してTencent Cloud VPCと接続できます。
VPNアクセス：ソースデータベースはVPN Connectionsを介してTencent Cloud VPCと接続できます。
クラウドデータベース：ソースデータベースはTencent Cloudデータベースインスタンスに属します。
CCN：ソースデータベースはCCNを介してTencent Cloud VPCと接続できます。
パブリックネットワーク
ホストアドレス：ソースデータベースのIPアドレスまたはドメイン名。
ポート：ソースデータベースが使用するポート。
CVMでの自己構築
CVMインスタンス：CVMのインスタンスID。
ポート：ソースデータベースが使用するポート。
Direct Connect (DC)
VPC Direct Connectゲートウェイ/：Direct Connectアクセス時はVPC Direct Connectゲートウェイのみサポートされます。ゲートウェイに関連付けられたネットワークタイプを確認してください。
VPC：VPC Direct ConnectゲートウェイおよびVPNゲートウェイに関連付けられたVPCとサブネットを選択します。
ホストアドレス：ソースデータベースのIPアドレスまたはドメイン名。
ポート：ソースデータベースが使用するポート。
VPNアクセス
VPNゲートウェイ：VPNゲートウェイ。VPNゲートウェイを介してアクセスするVPNゲートウェイインスタンスを選択してください。
VPC：VPC Direct ConnectゲートウェイおよびVPNゲートウェイに関連付けられたVPCとサブネットを選択します。
ホストアドレス：ソースデータベースのIPアドレスまたはドメイン名。
ポート：ソースデータベースが使用するポート。
クラウドデータベース
クラウドデータベースインスタンス：ソースデータベースのインスタンスID。
CCN
ホストアドレス：ソースデータベースのホストIPアドレスまたはドメイン名。
ポート：ソースデータベースが使用するポート。
VPC CCN：CCNインスタンス名。
アクセスVPC：アクセスVPCとは、CCN内でサブスクリプションリンクに接続されるVPCを指します。CCNに関連付けられているすべてのVPCの中から、ソースデータベースが属するVPC以外のVPCを選択してください。
例えば、広州地域のデータベースがソースデータベースの場合、アクセスVPCには成都VPCや上海VPCなど、他の地域を選択します。
サブネット：選択済みのVPCネットワークのサブネット名。
アクセスVPC地域：タスク購入時に選択したソースデータベースの地域とアクセスVPCの地域は一致している必要があります。一致していない場合、DTSはタスク購入時に選択したソースデータベースの地域をアクセスVPCの地域に変更します。
アカウント/パスワード
アカウント/パスワード：ソースデータベースのアカウント、パスワード。
kafkaパーティション数
kafkaパーティション数を設定します。パーティション数を増やすと、データの書き込みと消費の速度を向上させることができます。シングルパーティションはメッセージの順序を保証できますが、マルチパーティションはメッセージの順序を保証できません。消費するメッセージの順序に厳密な要件がある場合は、kafkaパーティション数を1に選択してください。
5. 購読タイプと対象選択ページで、購読タイプを選択し、保存して次へをクリックします。
購読タイプには、データ更新、構造更新、全インスタンスが含まれます。
データ更新：選択対象のデータ更新を購読します。これにはデータのINSERT、UPDATE、DELETE操作が含まれます。
構造更新：購読インスタンス内の全オブジェクトの構造の作成、変更、削除を行います。
全インスタンス：この購読インスタンスの全オブジェクトのデータ更新と構造更新が含まれます。
Kafkaパーティションポリシー：テーブル名によるパーティショニング、テーブル名+PKによるパーティショニングを選択します。
6. 事前検証ページでは、事前検証タスクの実行に2分～3分かかると予想されます。事前検証が完了した後、開始をクリックしてデータ購読タスクの設定を完了します。
説明
検証に失敗した場合は、検証不合格時の対処方法を参照して修正し、再度検証を行ってください。
7. 購読タスクは初期化され、3分～4分かかると予想されます。初期化が成功すると、実行中状態になります。
8. 消費グループを追加、データ購読Kafka版はユーザーが複数の消費グループを作成し、マルチポイント消費を行うことをサポートします。データ購読Kafka版の消費はKafkaの消費グループに依存するため、データを消費する前に消費グループを作成する必要があります。 
9. 購読インスタンスが実行中状態になると、データの消費を開始できます。Kafkaの消費にはパスワード認証が必要です。具体的な例についてはデータ消費Demoを参照してください。複数言語のDemoコードを提供しており、消費の主な流れと主要なデータ構造についても説明しています。

ヘルプとサポート

この記事はお役に立ちましたか？

営業担当者にお問い合わせいただくかチケットを提出してサポートを求めることができます。

フィードバック

tencent cloud

Data Transfer Service

MariaDBまたはPerconaデータ購読の作成

前提条件

制約事項

サポートされるSQL操作

操作手順

ヘルプとサポート

操作タイプ	サポートされる SQL 操作
DML	INSERT、UPDATE、DELETE
DDL	CREATE DATABASE、DROP DATABASE、CREATE TABLE、ALTER TABLE、DROP TABLE、RENAME TABLE

設定項目	説明
インスタンスタイプ	購入時に選択したデータベースタイプです。プライマリデータベースを選択して購読することをお勧めします。購読サービスがソースデータベースに与える負荷は非常に小さいです。ソースデータベースがTencentDB for MariaDBの場合、災害復旧/読み取り専用インスタンスの選択をサポートします。
アクセスタイプ	お客様のシナリオに応じて選択してください。異なるアクセスタイプの準備作業については、準備作業の概要を参照してください。公衆網：ソースデータベースにはパブリックIPアドレスでアクセスできます。 CVM自社構築：ソースデータベースはTencent CVM上に配置されています。 Direct Connect：ソースデータベースはDirect Connectを介してTencent Cloud VPCと接続できます。 VPNアクセス：ソースデータベースはVPN Connectionsを介してTencent Cloud VPCと接続できます。クラウドデータベース：ソースデータベースはTencent Cloudデータベースインスタンスに属します。 CCN：ソースデータベースはCCNを介してTencent Cloud VPCと接続できます。
パブリックネットワーク	ホストアドレス：ソースデータベースのIPアドレスまたはドメイン名。ポート：ソースデータベースが使用するポート。
CVMでの自己構築	CVMインスタンス：CVMのインスタンスID。ポート：ソースデータベースが使用するポート。
Direct Connect (DC)	VPC Direct Connectゲートウェイ/：Direct Connectアクセス時はVPC Direct Connectゲートウェイのみサポートされます。ゲートウェイに関連付けられたネットワークタイプを確認してください。 VPC：VPC Direct ConnectゲートウェイおよびVPNゲートウェイに関連付けられたVPCとサブネットを選択します。ホストアドレス：ソースデータベースのIPアドレスまたはドメイン名。ポート：ソースデータベースが使用するポート。
VPNアクセス	VPNゲートウェイ：VPNゲートウェイ。VPNゲートウェイを介してアクセスするVPNゲートウェイインスタンスを選択してください。 VPC：VPC Direct ConnectゲートウェイおよびVPNゲートウェイに関連付けられたVPCとサブネットを選択します。ホストアドレス：ソースデータベースのIPアドレスまたはドメイン名。ポート：ソースデータベースが使用するポート。
クラウドデータベース	クラウドデータベースインスタンス：ソースデータベースのインスタンスID。
CCN	ホストアドレス：ソースデータベースのホストIPアドレスまたはドメイン名。ポート：ソースデータベースが使用するポート。 VPC CCN：CCNインスタンス名。アクセスVPC：アクセスVPCとは、CCN内でサブスクリプションリンクに接続されるVPCを指します。CCNに関連付けられているすべてのVPCの中から、ソースデータベースが属するVPC以外のVPCを選択してください。例えば、広州地域のデータベースがソースデータベースの場合、アクセスVPCには成都VPCや上海VPCなど、他の地域を選択します。サブネット：選択済みのVPCネットワークのサブネット名。アクセスVPC地域：タスク購入時に選択したソースデータベースの地域とアクセスVPCの地域は一致している必要があります。一致していない場合、DTSはタスク購入時に選択したソースデータベースの地域をアクセスVPCの地域に変更します。
アカウント/パスワード	アカウント/パスワード：ソースデータベースのアカウント、パスワード。
kafkaパーティション数	kafkaパーティション数を設定します。パーティション数を増やすと、データの書き込みと消費の速度を向上させることができます。シングルパーティションはメッセージの順序を保証できますが、マルチパーティションはメッセージの順序を保証できません。消費するメッセージの順序に厳密な要件がある場合は、kafkaパーティション数を1に選択してください。