GRANT RELOAD,LOCK TABLES,REPLICATION CLIENT,REPLICATION SLAVE,SHOW VIEW,PROCESS,SELECT ON *.* TO 'アカウント'@'%' IDENTIFIED BY 'パスワード';GRANT ALL PRIVILEGES ON `__tencentdb__`.* TO 'アカウント'@'%';FLUSH PRIVILEGES;
パラメータ | 説明 |
課金モデル | 年額・月額と従量課金をサポートします。 |
ソースインスタンスタイプ | TDSQL MySQLを選択します。購入後は変更できません。 |
ソースインスタンスの地域 | ソースインスタンスの所在地域を選択します。購入後は変更できません。 |
ターゲットインスタンスタイプ | Kafkaを選択します。購入後は変更できません。 |
ターゲットインスタンスの地域 | 目的インスタンスの所在地域を選択します。購入後は変更できません。 |
仕様 |
設定項目 | パラメータ | 説明 |
タスク設定 | タスク名 | DTSはタスク名を自動生成します。ユーザーは実際の状況に応じて設定できます。 |
| 実行モード | 即時実行と定時実行の2つのモードをサポートします。 |
ソースインスタンスの設定 | ソースインスタンスタイプ | 購入時に選択したソースインスタンスタイプは変更できません。 |
| ソースインスタンスの地域 | 購入時に選択したソースインスタンスの所在地域は変更できません。 |
| アクセスタイプ | お客様のシナリオに応じて選択してください。現在、ソース側はTencent Cloudデータベースのみサポートされています。 |
| アカウント/パスワード | アカウント/パスワード:ソースデータベースのアカウント、パスワード。 |
ターゲットインスタンスの設定 | ターゲットインスタンスタイプ | 購入時に選択したターゲットインスタンスタイプは変更できません。 |
| ターゲットインスタンスの地域 | 購入時に選択したターゲットインスタンスの地域は変更できません。 |
| アクセスタイプ | お客様のシナリオに応じて選択してください。このシナリオでは「Ckafkaインスタンス」を選択します。 |
| インスタンスID | ターゲットインスタンスIDを選択します。 |
パラメータ | 説明 |
初期化タイプ | 構造初期化:同期タスクの実行時に、まずソースインスタンスのテーブル構造をターゲットインスタンスに初期化します。 全量データ初期化:同期タスクの実行時に、まずソースインスタンスのデータをターゲットインスタンスに初期化します。全量データ初期化のみを選択した場合、ユーザーは事前にターゲットデータベースにテーブル構造を作成しておく必要があります。 フル同期の場合は、両方にチェックを入れます。増分同期の場合は、両方ともチェックを入れず、下の同期操作タイプでDDLとDMLにチェックを入れます。 |
Kafka に配信するデータ形式 | Avroはバイナリ形式で、消費効率がより高くなっています。JSONは軽量のテキスト形式で、よりシンプルで使いやすくなっています。 |
開始位置の指定 | 初期化タイプをいずれもチェックしない場合、つまり増分同期を選択した場合、データ同期の開始位置を設定できます。 1. 全量同期と増分同期を分けて実行する場合、ここで注意してください。全量同期を実行する際、DTSがすでに同期した全量データのポジション1と、増分同期で設定された開始ポジション2の間に、DDL変更データが存在してはなりません。存在する場合、タスクはエラーを報告します。 2. データベースに設定されたタイムゾーンが現在のコンソールのタイムゾーン(つまりブラウザのタイムゾーン)と一致しているかどうかを確認してください。または、データベースに設定されたタイムゾーンに対応する時間に換算してください。そうしないと、指定されたポイントの同期結果が期待どおりにならない可能性があります。 3. ソース側のTDSQL MySQLの各クラスターノードの時刻が一致していることを確認してください。そうしないと、指定されたポイントの同期結果が期待どおりにならない可能性があります。 4. 指定されたポイントの同期を開始してから、増分タスクが開始される前まで(つまり、タスクステップが「指定されたポイントの検索」から「増分の同期」に変わる前まで)、ソースデータベースでDDLを操作することはできません。そうしないと、タスクがエラーを報告します。 |
パラメータ | 説明 |
Topic同期ポリシー | カスタムTopic名:配信するTopic名を設定します。設定後、ターゲット側のKafkaがそのTopicを自動的に作成します。実現効果として、同期データをそのTopic配下の異なるパーティションにランダムに配信します。ターゲット側のKafkaでTopicの作成に失敗した場合、タスクはエラーを報告します。 単一Topicへの集中配信:ターゲット側に既存のTopicを選択し、複数のパーティションポリシーに従って配信します。単一パーティション、テーブル名によるパーティショニング、テーブル名+PKによるパーティショニングをサポートし、異なるパーティションに配信します。 |
カスタムTopic名ルール | ユーザーが複数のルールを追加すると、カスタムTopicマッチルールは上から順番にマッチングします。設定されたデータベース名とテーブル名のルールがすべて一致した場合のみ、そのルールに対応するTopicに発送されます。データベース・テーブルのマッチルールに一致しない場合、最後のルールのTopicに発送されます。複数のデータベース・テーブルのマッチルールに一致した場合、すべてのマッチルールのTopicに発送されます。 説明: マッチルールはデータベース・テーブル名の大文字と小文字を区別します。 ソースデータベースでlower_case_table_names=0に設定した場合、データベース・テーブルのマッチルール内のデータベース・テーブル名は、ソースデータベース内の名前と大文字・小文字を厳密に一致させる必要があります。 ソースデータベースでlower_case_table_names=1に設定した場合、データベース・テーブル名は小文字に統一して変換され、データベース・テーブルのマッチルール内のデータベース・テーブル名は小文字で統一して入力されます。 |
単一Topicへの集中配信ルール | 指定されたTopicを選択すると、システムは以下の指定ポリシーに従ってパーティショニングを行います。 すべてPartition0に配信します:ソースデータベースの同期データをすべて最初のパーティションに配信します。 テーブル名によるパーティショニング:ソースデータベースの同期データをテーブル名に従ってパーティショニングします。設定後、同じテーブル名のデータは同じパーティションに書き込まれます。 テーブル名+PKによるパーティショニング:ソースデータベースの同期データをテーブル名+PKに従ってパーティショニングします。ホットデータに適しており、設定後、ホットデータのテーブルは、テーブル名+PKの方式でデータを異なるパーティションに分散し、並行消費効率を向上させます。 |
DDLを格納するTopic | 任意です。ユーザーがソースデータベースのDDL操作を指定したTopicに個別に発送する必要がある場合、ここで選択して設定できます。
設定後、デフォルトで選択済みTopicのPartition0に発送されます。設定されていない場合は、上で選択したTopicルールに従って発送されます。 |
設定項目 | パラメータ | 説明 |
データ同期オプション | 同期操作タイプ | サポートされる操作:Insert、Update、Delete、DDL。 |
同期オブジェクトオプション | ソースインスタンスのテーブルオブジェクト | 同期をサポートする基本的なデータベース、テーブルオブジェクトのみです。 |
フィードバック