MySQLまたはTDSQL-C MySQLデータ購読の作成

ダウンロード

フォーカスモード

フォントサイズ

最終更新日: 2026-11-05 17:13:22

AI翻訳・品質チェック済み

本シナリオでは、DTSを使用してMySQLまたはTDSQL-C MySQLのデータ購読タスクを作成する操作手順を紹介します。
前提条件
購読対象のソースデータベースを準備し、データベースのバージョンが要件を満たしていることを確認してください。詳細はデータ購読がサポートするデータベースを参照してください。
ソースデータベースでbinlogを有効にしました。
ソースデータベースに購読アカウントを作成しました。必要なアカウント権限は以下の通りです：REPLICATION CLIENT、REPLICATION SLAVE、PROCESS、およびすべてのオブジェクトに対するSELECT権限。
具体的な権限付与ステートメントは以下の通りです：
create user '移行アカウント' IDENTIFIED BY 'アカウントパスワード';
grant SELECT, REPLICATION CLIENT,REPLICATION SLAVE,PROCESS on *.* to '移行アカウント'@'%';
flush privileges;
制約事項
購読したメッセージはDTS内蔵Kafka（単一Topic）に保存されます。現在のデフォルト保存期間は直近1日で、単一Topicの最大ストレージは500Gです。データの保存期間が1日を超えた場合、またはデータ量が500Gを超えた場合、内蔵Kafkaは最初に書き込まれたデータから削除を開始します。そのため、ユーザーはデータが消費される前に削除されないよう、タイムリーに消費してください。
データ消費の地域は、購読タスクが属する地域と同じである必要があります。
現在、geometry関連のデータ型はサポートされていません。 
購読タスク中に購読対象の変更などの操作を行うと、タスクが再起動されます。再起動後、ユーザーがKafkaクライアントでデータを消費する際に重複が発生する可能性があります。
DTSは最小データ単位で伝送を行います。増分データは、checkpoint位置を1つマークするごとに1つのデータ単位となります。再起動時に、ちょうど1つのデータ単位の伝送が完了している場合は、データの重複は発生しません。再起動時に、1つのデータ単位がまだ伝送中である場合は、再度起動した後にこのデータ単位を再取得してデータの整合性を確保するため、データの重複が発生します。
新規作成されたMySQLまたはTDSQL-C MySQLの購読タスクでは、重複データが気になる場合、ユーザーはデータ消費時に重複排除ロジックを設定する必要があります。
サポートされる購読の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データベース以外の場合、ここでの地域選択はデータ消費の地域と一致させます。データ消費地域に特別な要件がない場合は、ソースデータベースに最も近い地域を選択してください。
バージョン
2.0を選択してください。
仕様
ビジネス要件に応じてスペックを選択してください。
タグ
購読タスクにタグキーとタグ値を設定し、タグによって複数のタスクを効率的に管理できるようにします。
サブスクリプションインスタンス名
作成後に名前を付けることを選択した場合、デフォルトのタスク名はタスクIDと一致します。購読タスクの作成が完了した後、タスク名を再設定できます。
「今すぐ名前を付ける」を選択し、下の入力ボックスにタスク名を入力してください。
契約条件
「『クラウドデータベースサービス利用規約』を読み、同意しました」に必ずチェックを入れてください。
3. 購入が成功したら、データ購読リストに戻り、操作列の購読を設定をクリックして、購入したばかりの購読を設定します。設定が完了してから使用できます。
4. データ購読の設定ページで、データ購読タスクを選択し、完了後に接続テストをクリックします。テストが成功し、ネットワークを設定した後、保存して次へをクリックします。
データ購読タスクの設定
設定項目
説明
インスタンスタイプ
購入時に選択したデータベースタイプは変更できません。
メインデータベースを選択してサブスクリプションを行うことをお勧めします。サブスクリプションサービスがソースデータベースに与える負荷は非常に小さいです。
アクセスタイプ
お客様のシナリオに応じて選択してください。異なるアクセスタイプの準備作業については、準備作業の概要を参照してください。
パブリックネットワーク：ソースデータベースにはパブリック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。
メインデータベースを選択して購読することをお勧めします。購読サービスがソースデータベースに与える負荷は非常に小さいです。
ソースデータベースがTencentDB for MySQLの場合、読み取り専用インスタンスと災害復旧インスタンスを選択できます。ただし、読み取り専用インスタンスを使用する場合は、事前にチケットを提出して申請する必要があります。TencentDB for MySQLシングルノード（旧基本版-提供終了）をソース側として使用する場合、アクセス方式に「TencentDB」は使用できず、「パブリックネットワーク」アクセス方式を使用できます。MySQLシングルノード（クラウドディスク版）をソース側として使用する場合は制限がなく、通常どおり「TencentDB」を使用できます。
ソースデータベースがTencent Cloud TDSQL-C MySQLの場合、読み取り専用インスタンスを選択できます。
CCN
ホストアドレス：ソースデータベースのホストIPアドレスまたはドメイン名。
ポート：ソースデータベースが使用するポート。
VPC CCN：CCNインスタンス名。
アクセスVPC：アクセスVPCとは、CCN内でサブスクリプションリンクにアクセスするVPCを指します。CCNに関連付けられているすべてのVPCの中から、ソースデータベースが属するVPC以外のVPCを選択してください。
例えば、広州地域のデータベースがソースデータベースの場合、アクセスVPCには他の地域（成都VPCや上海VPCなど）を選択します。
サブネット：選択済みのVPCネットワークのサブネット名。
アクセスVPC地域：タスク購入時に選択したソースデータベースの地域とアクセスVPCの地域は一致している必要があります。一致していない場合、DTSはタスク購入時に選択したソースデータベースの地域をアクセスVPCの地域に変更します。
アカウント/パスワード
アカウント/パスワード：ソースデータベースのアカウント、パスワード。
接続方法
SSLセキュア接続とは、DTSとソースデータベースがSSL（Secure socket layer）を介して安全に接続し、伝送リンクを暗号化することを指します。
SSLセキュア接続を選択すると、データベースの接続応答時間が増加する可能性があります。一般的にTencent Cloudのプライベートネットワークリンクは比較的安全なため、SSLセキュア接続を有効にする必要はありません。パブリックネットワーク／専用線などの伝送方式を使用し、かつデータセキュリティ要件が高いシナリオでは、SSLセキュア接続を有効にする必要があります。SSLセキュア接続を選択する前に、まずソースデータベースでSSL暗号化を有効にする必要があります。
ネットワーク設定
設定項目
説明
ネットワーク
購読タスクKafkaにアクセスするVPC環境（VPCとサブネットを含む）を事前に指定してください。その後、このVPCを介してデータ購読サービスを消費できます。
説明：
同一VPCからのアクセス：同じVPC内のすべてのCVMは、追加設定なしでサブスクリプションデータに正常にアクセスできます。
VPC間アクセス：コンシューマー側CVMが別のVPCにある場合、CCNを設定してVPC間アクセスを実現する必要があります。
5. 購読タイプとオブジェクト選択ページで、購読タイプを選択し、保存して次へをクリックします。
設定項目
説明
サブスクリプションタイプ
データ更新：ソースデータベースの全オブジェクトのデータ更新を購読します。これにはデータのINSERT、UPDATE、DELETE操作が含まれます。
構造更新：ソースデータベースの全オブジェクトの構造の作成、変更、削除を購読します。
全インスタンス：ソースデータベースの全オブジェクトのデータ更新と構造更新を購読します。
サブスクリプションデータ形式
ProtoBuf、Avro、JSON の 3 つの形式をサポートしています。ProtoBuf と Avro はバイナリー形式を採用しており、消費効率がより高くなっています。JSON は軽量なテキスト形式を採用しており、よりシンプルで使いやすくなっています。
XAトランザクションをサポートします。
チェックを入れると、DTSデータ購読はソースデータベースで実行されたXAトランザクション操作を認識できます。コンシューマー側で取得したデータは、XAトランザクションのロジックに従って解析されます。ソースデータベースでXAトランザクションのロールバック（rollback）が発生した場合、DTSはrollbackを認識でき、ソースデータベース上のrollbackおよびrollback以前のSQL文はコンシューマー側に送信されません。
現在、MySQL、TDSQL-C MySQL のデータ購読のみが XA トランザクションをサポートしています。
Topicパーティション数
データを内蔵KafkaのTopicに配信するパーティション数を設定します。パーティション数を増やすと、データの書き込みおよび消費速度を向上できます。単一パーティションではメッセージの順序を保証できますが、複数パーティションではメッセージの順序を保証できません。消費するメッセージの順序に厳密な要件がある場合は、パーティション数を1に選択してください。
Topicパーティションポリシー
テーブル名によるパーティショニング：同じテーブル名のデータを同じパーティションに書き込みます。
テーブル名+PKによるパーティショニング：同じPKのデータを同じパーティションに書き込みます。ホットデータのテーブルに適しており、ホットテーブルのデータを異なるパーティションに分散して、並行消費効率を向上させることができます。
カスタムパーティションポリシーを使用します。
まず正規表現を使用して、購読データ内のデータベース名とテーブル名をマッチングします。マッチしたデータは、テーブル名、テーブル名+PK、列に従ってパーティション配信されます。次に、残りのマッチしなかったデータは、Topicパーティションポリシーに従って配信されます。詳細については、パーティションポリシーの設定を参照してください。
6. 事前検証ページでは、事前検証タスクの実行には2～3分かかると予想されます。事前検証が完了した後、開始をクリックしてデータ購読タスクの設定を完了します。
説明：
検証に失敗した場合、検証不合格の対処方法を参照して修正し、再度検証を行ってください。
7. 開始をクリックすると、購読タスクは初期化され、3～4分かかると予想されます。初期化が成功すると、実行中状態になります。
8. 消費グループを追加します。データ購読Kafka版は、ユーザーが複数の消費グループを作成することをサポートしています（1つの購読タスクで最大10個の消費グループを作成できます）。これにより、マルチポイント消費が可能になります。データ購読Kafka版の消費はKafkaの消費グループに依存しているため、データを消費する前に消費グループを作成する必要があります。 
9. 購読インスタンスが実行中状態になると、データの消費を開始できます。Kafkaの消費にはパスワード認証が必要です。具体的な例についてはデータ消費Demoを参照してください。複数言語のDemoコードを提供しており、消費の主な流れと主要なデータ構造についても説明しています。
﻿

ヘルプとサポート

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

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

フィードバック

tencent cloud

Data Transfer Service

MySQLまたはTDSQL-C MySQLデータ購読の作成

前提条件

制約事項

サポートされる購読のSQL操作

操作手順

ヘルプとサポート

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

パラメータ	説明
課金モデル	サポートされているのは、年額・月額プランと従量課金です。
データベース	具体的なデータベースタイプに応じて選択してください。
リージョン	ソースデータベースがTencent Cloudデータベースの場合、ここでの地域はソースデータベースインスタンスの地域と一致させる必要があります。ソースデータベースがTencent Cloudデータベース以外の場合、ここでの地域選択はデータ消費の地域と一致させます。データ消費地域に特別な要件がない場合は、ソースデータベースに最も近い地域を選択してください。
バージョン	2.0を選択してください。
仕様	ビジネス要件に応じてスペックを選択してください。
タグ	購読タスクにタグキーとタグ値を設定し、タグによって複数のタスクを効率的に管理できるようにします。
サブスクリプションインスタンス名	作成後に名前を付けることを選択した場合、デフォルトのタスク名はタスクIDと一致します。購読タスクの作成が完了した後、タスク名を再設定できます。「今すぐ名前を付ける」を選択し、下の入力ボックスにタスク名を入力してください。
契約条件	「『クラウドデータベースサービス利用規約』を読み、同意しました」に必ずチェックを入れてください。

設定項目	説明
インスタンスタイプ	購入時に選択したデータベースタイプは変更できません。メインデータベースを選択してサブスクリプションを行うことをお勧めします。サブスクリプションサービスがソースデータベースに与える負荷は非常に小さいです。
アクセスタイプ	お客様のシナリオに応じて選択してください。異なるアクセスタイプの準備作業については、準備作業の概要を参照してください。パブリックネットワーク：ソースデータベースにはパブリック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。メインデータベースを選択して購読することをお勧めします。購読サービスがソースデータベースに与える負荷は非常に小さいです。ソースデータベースがTencentDB for MySQLの場合、読み取り専用インスタンスと災害復旧インスタンスを選択できます。ただし、読み取り専用インスタンスを使用する場合は、事前にチケットを提出して申請する必要があります。TencentDB for MySQLシングルノード（旧基本版-提供終了）をソース側として使用する場合、アクセス方式に「TencentDB」は使用できず、「パブリックネットワーク」アクセス方式を使用できます。MySQLシングルノード（クラウドディスク版）をソース側として使用する場合は制限がなく、通常どおり「TencentDB」を使用できます。ソースデータベースがTencent Cloud TDSQL-C MySQLの場合、読み取り専用インスタンスを選択できます。
CCN	ホストアドレス：ソースデータベースのホストIPアドレスまたはドメイン名。ポート：ソースデータベースが使用するポート。 VPC CCN：CCNインスタンス名。アクセスVPC：アクセスVPCとは、CCN内でサブスクリプションリンクにアクセスするVPCを指します。CCNに関連付けられているすべてのVPCの中から、ソースデータベースが属するVPC以外のVPCを選択してください。例えば、広州地域のデータベースがソースデータベースの場合、アクセスVPCには他の地域（成都VPCや上海VPCなど）を選択します。サブネット：選択済みのVPCネットワークのサブネット名。アクセスVPC地域：タスク購入時に選択したソースデータベースの地域とアクセスVPCの地域は一致している必要があります。一致していない場合、DTSはタスク購入時に選択したソースデータベースの地域をアクセスVPCの地域に変更します。
アカウント/パスワード	アカウント/パスワード：ソースデータベースのアカウント、パスワード。
接続方法	SSLセキュア接続とは、DTSとソースデータベースがSSL（Secure socket layer）を介して安全に接続し、伝送リンクを暗号化することを指します。 SSLセキュア接続を選択すると、データベースの接続応答時間が増加する可能性があります。一般的にTencent Cloudのプライベートネットワークリンクは比較的安全なため、SSLセキュア接続を有効にする必要はありません。パブリックネットワーク／専用線などの伝送方式を使用し、かつデータセキュリティ要件が高いシナリオでは、SSLセキュア接続を有効にする必要があります。SSLセキュア接続を選択する前に、まずソースデータベースでSSL暗号化を有効にする必要があります。

設定項目	説明
サブスクリプションタイプ	データ更新：ソースデータベースの全オブジェクトのデータ更新を購読します。これにはデータのINSERT、UPDATE、DELETE操作が含まれます。構造更新：ソースデータベースの全オブジェクトの構造の作成、変更、削除を購読します。全インスタンス：ソースデータベースの全オブジェクトのデータ更新と構造更新を購読します。
サブスクリプションデータ形式	ProtoBuf、Avro、JSON の 3 つの形式をサポートしています。ProtoBuf と Avro はバイナリー形式を採用しており、消費効率がより高くなっています。JSON は軽量なテキスト形式を採用しており、よりシンプルで使いやすくなっています。
XAトランザクションをサポートします。	チェックを入れると、DTSデータ購読はソースデータベースで実行されたXAトランザクション操作を認識できます。コンシューマー側で取得したデータは、XAトランザクションのロジックに従って解析されます。ソースデータベースでXAトランザクションのロールバック（rollback）が発生した場合、DTSはrollbackを認識でき、ソースデータベース上のrollbackおよびrollback以前のSQL文はコンシューマー側に送信されません。現在、MySQL、TDSQL-C MySQL のデータ購読のみが XA トランザクションをサポートしています。
Topicパーティション数	データを内蔵KafkaのTopicに配信するパーティション数を設定します。パーティション数を増やすと、データの書き込みおよび消費速度を向上できます。単一パーティションではメッセージの順序を保証できますが、複数パーティションではメッセージの順序を保証できません。消費するメッセージの順序に厳密な要件がある場合は、パーティション数を1に選択してください。
Topicパーティションポリシー	テーブル名によるパーティショニング：同じテーブル名のデータを同じパーティションに書き込みます。テーブル名+PKによるパーティショニング：同じPKのデータを同じパーティションに書き込みます。ホットデータのテーブルに適しており、ホットテーブルのデータを異なるパーティションに分散して、並行消費効率を向上させることができます。
カスタムパーティションポリシーを使用します。	まず正規表現を使用して、購読データ内のデータベース名とテーブル名をマッチングします。マッチしたデータは、テーブル名、テーブル名+PK、列に従ってパーティション配信されます。次に、残りのマッチしなかったデータは、Topicパーティションポリシーに従って配信されます。詳細については、パーティションポリシーの設定を参照してください。