ApsaraDB RDS for MySQLインスタンスのデータをDataHubプロジェクトに同期する - Data Transmission Service

DataHubは、ストリーミングデータを処理するように設計されたリアルタイムデータ配信プラットフォームです。 DataHubでストリーミングデータをパブリッシュおよびサブスクライブし、他のプラットフォームにデータを配布できます。 DataHubを使用すると、ストリーミングデータを分析し、ストリーミングデータに基づいてアプリケーションを構築できます。 data Transmission Service (DTS) を使用して、ApsaraDB RDS for MySQLインスタンスのデータをDataHubプロジェクトに同期できます。これにより、DataHubを使用してストリーミングデータをリアルタイムで分析できます。

前提条件

ソースApsaraDB RDS for MySQLインスタンスが作成されました。
説明
- ApsaraDB RDS For MySQLインスタンスの作成方法の詳細については、「ApsaraDB RDS for MySQLインスタンスの作成」をご参照ください。
- サポートされているデータベースバージョンの詳細については、「データ同期シナリオの概要」をご参照ください。
DataHubがアクティブ化され、同期するデータを受け取るプロジェクトが作成されます。詳細については、「DataHubの使用を開始」および「プロジェクトの管理」をご参照ください。

使用上の注意

説明

DTSは、ソースデータベースの外部キーをターゲットデータベースに同期しません。したがって、ソースデータベースのカスケードおよび削除操作は、ターゲットデータベースと同期されません。

カテゴリ	説明
ソースインスタンスの制限	同期するテーブルには、PRIMARY KEYまたはUNIQUE制約が必要であり、すべてのフィールドが一意である必要があります。そうでなければ、宛先は重複データレコードを含み得る。同期するオブジェクトとしてテーブルを選択し、テーブルや列の名前の変更など、テーブルを変更する必要がある場合は、1つのデータ同期タスクで最大1,000のテーブルを同期できます。タスクを実行して1,000を超えるテーブルを同期すると、リクエストエラーが発生します。この場合、テーブルを分割し、複数のタスクを構成してテーブルをバッチで同期するか、タスクを構成してデータベース全体を同期することをお勧めします。バイナリログの次の要件を満たす必要があります。デフォルトでは、バイナリログ機能が有効になっています。 binlog_row_imageパラメーターはfullに設定する必要があります。それ以外の場合、事前チェック中にエラーメッセージが返され、データ同期タスクを開始できません。詳細は、「インスタンスパラメーターの変更」をご参照ください。重要ソースデータベースが自己管理型MySQLデータベースの場合、バイナリログ機能を有効にし、binlog_formatパラメーターをrowに設定し、binlog_row_imageパラメーターをfullに設定する必要があります。ソースデータベースがデュアルプライマリクラスタにデプロイされた自己管理型MySQLデータベースである場合、log_slave_updatesパラメーターをONに設定する必要があります。これにより、DTSはすべてのバイナリログを取得できます。詳細については、「自己管理型MySQLデータベースのアカウントの作成とバイナリログの設定」をご参照ください。ソースデータベースのバイナリログは、少なくとも7日間保存する必要があります。そうしないと、DTSがバイナリログを取得できないため、データ同期タスクが失敗する可能性があります。例外的な状況では、データの不整合または損失が発生します。上記の要件に基づいて、バイナリログの保持期間を設定してください。そうしないと、DTSのSLAでのサービスの信頼性またはパフォーマンスが保証されない場合があります。 ApsaraDB RDS For MySQLインスタンスのバイナリログファイルを管理する方法の詳細については、「バイナリログファイルの管理」をご参照ください。スキーマ同期および完全データ同期中は、DDL文を実行してデータベースまたはテーブルのスキーマを変更しないでください。それ以外の場合、データ同期タスクは失敗します。
その他の制限	ターゲットDataHubプロジェクトの1つの文字列の長さは2 MBを超えることはできません。同期するテーブルにrecorde_idという名前の列が含まれている場合は、オブジェクト名マッピング機能を使用して、ターゲットデータベースの列の名前を変更することを推奨します。それ以外の場合は、エラーが返されます。詳細については、「マップオブジェクト名」をご参照ください。データ同期中に他のソースからのデータがターゲットデータベースに書き込まれると、ソースデータベースとターゲットデータベース間のデータの不一致が発生します。たとえば、他のソースからのデータがターゲットデータベースに書き込まれているときにDMSを使用してオンラインDDLステートメントを実行すると、ターゲットデータベースでデータが失われる可能性があります。ソースデータベースがEncDB機能が有効になっているApsaraDB RDS for MySQLインスタンスの場合、完全なデータ同期は実行できません。
特別なケース	ソースデータベースが自己管理型MySQLデータベースの場合、次の項目に注意してください。データ同期タスクの実行中にソースデータベースでプライマリ /セカンダリの切り替えを実行すると、タスクは失敗します。 DTSは、同期先データベースの最新の同期データのタイムスタンプとソースデータベースの現在のタイムスタンプに基づいて同期レイテンシを計算します。ソースデータベースでDML操作が長時間実行されない場合、同期レイテンシが不正確になる可能性があります。データ同期タスクのレイテンシが高すぎる場合は、ソースデータベースでDML操作を実行してレイテンシを更新できます。説明同期するオブジェクトとしてデータベース全体を選択した場合は、ハートビートテーブルを作成できます。ハートビートテーブルは1秒ごとに更新されるか、データを受信します。 DTSは、CREATE DATABASE IF NOT EXISTS 'test' ステートメントをソースデータベースで実行し、バイナリログファイルの位置を前に移動します。ソースデータベースがApsara RDS for MySQLインスタンスの場合、次の項目に注意してください。読み取り専用のApsaraDB RDS for MySQL 5.6インスタンスなど、トランザクションログを記録しないApsaraDB RDS for MySQLインスタンスは、ソースデータベースとして使用できません。

サポートしている同期トポロジ

一方向の 1 対 1 の同期
一方向の 1 対多の同期
一方向の多対 1 の同期

DTSでサポートされている同期トポロジの詳細については、「同期トポロジ」をご参照ください。

同期可能なSQL操作

操作タイプ	SQL文
DML	挿入、更新、および削除
DDL	コラムを追加

手順

[データ同期タスク] ページに移動します。
1. データ管理 (DMS) コンソールにログインします。
2. 上部のナビゲーションバーで、DTSをクリックします。
3. 左側のナビゲーションウィンドウで、DTS (DTS) > データ同期を選択します。
説明
- 操作は、DMSコンソールのモードとレイアウトによって異なります。詳細については、「シンプルモード」および「DMSコンソールのレイアウトとスタイルのカスタマイズ」をご参照ください。
- に行くこともできます新しいDTSコンソールのデータ同期タスクページ。
の右側にデータ同期タスク、データ同期インスタンスが存在するリージョンを選択します。
説明
新しいDTSコンソールを使用する場合は、上部のナビゲーションバーでデータ同期インスタンスが存在するリージョンを選択する必要があります。

[タスクの作成] をクリックします。 [タスクの作成] ページで、ソースデータベースとターゲットデータベースを設定します。次の表にパラメーターを示します。

警告

ソースデータベースとターゲットデータベースを設定した後、ページに表示される制限を読むことを推奨します。そうしないと、タスクが失敗したり、データの不一致が発生します。

セクション	パラメーター	説明
非該当	タスク名	DTSタスクの名前。タスク名は自動生成されます。タスクを簡単に識別できるように、わかりやすい名前を指定することをお勧めします。一意のタスク名を指定する必要はありません。
ソースデータベース	既存のDMSデータベースインスタンスの選択	使用するデータベースインスタンス。ビジネス要件に基づいて、既存のインスタンスを使用するかどうかを選択できます。既存のインスタンスを選択すると、DTSはデータベースのパラメーターを自動的に入力します。既存のインスタンスを選択しない場合は、次のデータベース情報を設定する必要があります。
	データベースタイプ	移行元ディスクのタイプを設定します。 [MySQL] を選択します。
	アクセス方法	ソースデータベースのアクセス方法。 [Alibaba Cloudインスタンス] を選択します。
	インスタンスリージョン	ソースApsaraDB RDS for MySQLインスタンスが存在するリージョンです。
	Alibaba Cloudアカウント全体でのデータの複製	Alibaba Cloudアカウント間でデータを同期するかどうかを指定します。この例では、[いいえ] が選択されています。
	RDSインスタンスID	ソースApsaraDB RDS for MySQLインスタンスのID。
	データベースアカウント	ソースApsaraDB RDS for MySQLインスタンスのデータベースアカウント。アカウントには、同期するオブジェクトに対する読み取り権限が必要です。
	データベースパスワード	データベースインスタンスへのアクセスに使用されるパスワード。
	暗号化	データベースへの接続を暗号化するかどうかを指定します。ビジネス要件に基づいて、[非暗号化] または [SSL暗号化] を選択できます。このパラメーターをSSL暗号化に設定する場合、DTSタスクを設定する前に、ApsaraDB RDS for MySQLインスタンスのSSL暗号化を有効にする必要があります。詳細については、「クラウド証明書を使用したSSL暗号化の有効化」をご参照ください。
宛先データベース	既存のDMSデータベースインスタンスの選択	使用するデータベースインスタンス。ビジネス要件に基づいて、既存のインスタンスを使用するかどうかを選択できます。既存のインスタンスを選択すると、DTSはデータベースのパラメーターを自動的に入力します。既存のインスタンスを選択しない場合は、次のデータベース情報を設定する必要があります。
	データベースタイプ	ターゲットデータベースのタイプ。 [DataHub] を選択します。
	アクセス方法	ターゲットデータベースのアクセス方法。 [Alibaba Cloudインスタンス] を選択します。
	インスタンスリージョン	ターゲットDataHubプロジェクトが存在するリージョン。
	プロジェクト	移行先のDataHubプロジェクトの名前。

ページの下部で、接続性をテストして続行.
ソースまたはターゲットデータベースがAlibaba Cloudデータベースインスタンス (ApsaraDB RDS for MySQLインスタンスやApsaraDB for MongoDBインスタンスなど) の場合、DTSは自動的にDTSサーバーのCIDRブロックをインスタンスのホワイトリストに追加します。ソースデータベースまたはターゲットデータベースがElastic Compute Service (ECS) インスタンスでホストされている自己管理データベースの場合、DTSサーバーのCIDRブロックがECSインスタンスのセキュリティグループルールに自動的に追加されます。ECSインスタンスがデータベースにアクセスできることを確認する必要があります。データベースが複数のECSインスタンスにデプロイされている場合、DTSサーバーのCIDRブロックを各ECSインスタンスのセキュリティグループルールに手動で追加する必要があります。ソースデータベースまたはターゲットデータベースが、データセンターにデプロイされているか、サードパーティのクラウドサービスプロバイダーによって提供される自己管理データベースである場合、DTSサーバーのCIDRブロックをデータベースのホワイトリストに手動で追加して、DTSがデータベースにアクセスできるようにする必要があります。詳細については、「DTSサーバーのCIDRブロックの追加」トピックの「DTSサーバーのCIDRブロック」セクションをご参照ください。
警告
DTSサーバーのCIDRブロックがデータベースまたはインスタンスのホワイトリスト、またはECSセキュリティグループルールに自動的または手動で追加されると、セキュリティリスクが発生する可能性があります。したがって、DTSを使用してデータを同期する前に、潜在的なリスクを理解して認識し、次の対策を含む予防策を講じる必要があります。VPNゲートウェイ、またはSmart Access Gateway。

同期するオブジェクトと詳細設定を設定します。

パラメーター	説明
同期タイプ	同期タイプ。デフォルトでは、増分データ同期が選択されています。 [スキーマ同期] および [完全データ同期] も選択する必要があります。事前チェックが完了すると、DTSは選択したオブジェクトの履歴データをソースデータベースからターゲットクラスターに同期します。履歴データは、その後の増分同期の基礎となる。
追加列の命名規則	DTSがデータをDataHubプロジェクトに同期すると、DTSは宛先テーブルに追加の列を追加します。追加の列の名前がターゲットテーブルの既存の列の名前と同じである場合、データ同期は失敗します。ビジネス要件に基づいて、[新しいルール] または [以前のルール] を選択します。警告このパラメーターの値を選択する前に、ターゲットテーブルの追加の列と既存の列に名前の競合があるかどうかを確認します。競合が存在する場合、データ移行タスクが失敗し、データが失われる可能性があります。詳細については、「追加の列の命名規則の変更」トピックの「追加の列の命名規則」セクションをご参照ください。
競合するテーブルの処理モード	エラーの事前チェックと報告: ターゲットデータベースに、ソースデータベースのテーブルと同じ名前のテーブルが含まれているかどうかを確認します。ソースデータベースとターゲットデータベースに同じテーブル名のテーブルが含まれていない場合は、事前チェックに合格します。それ以外の場合、事前チェック中にエラーが返され、データ同期タスクを開始できません。説明ソースデータベースとターゲットデータベースに同じ名前のテーブルが含まれていて、ターゲットデータベース内のテーブルを削除または名前変更できない場合は、オブジェクト名マッピング機能を使用して、ターゲットデータベースに同期されるテーブルの名前を変更できます。詳細については、「マップオブジェクト名」をご参照ください。エラーを無視して続行: ソースデータベースとターゲットデータベースの同じテーブル名の事前チェックをスキップします。警告エラーを無視して続行を選択すると、データの不整合が発生し、ビジネスが潜在的なリスクにさらされる可能性があります。ソースデータベースとターゲットデータベースが同じスキーマを持ち、ターゲットデータベースのデータレコードがソースデータベースのデータレコードと同じ主キー値または一意キー値を持つ場合: 完全データ同期中、DTSはデータレコードをターゲットデータベースに同期しません。ターゲットデータベースの既存のデータレコードが保持されます。増分データ同期中、DTSはデータレコードをターゲットデータベースに同期します。ターゲットデータベースの既存のデータレコードが上書きされます。ソースデータベースとターゲットデータベースのスキーマが異なる場合、データの初期化に失敗する可能性があります。この場合、一部の列のみが同期されるか、データ同期タスクが失敗します。作業は慎重に行ってください。
宛先インスタンスでのオブジェクト名の大文字化	ターゲットインスタンスのデータベース名、テーブル名、および列名の大文字化。デフォルトでは、DTSデフォルトポリシーが選択されています。他のオプションを選択して、オブジェクト名の大文字化をソースまたはターゲットデータベースの大文字化と一致させることができます。詳細については、「ターゲットインスタンスのオブジェクト名の大文字化の指定」をご参照ください。
ソースオブジェクト	ソースオブジェクトセクションから1つ以上のオブジェクトを選択し、アイコンをクリックして選択中のオブジェクトセクションにオブジェクトを追加します。説明同期するオブジェクトとしてテーブルを選択できます。
選択中のオブジェクト	同期先のインスタンスに同期するオブジェクトの名前を変更するには、選択中のオブジェクトセクションでオブジェクトを右クリックします。詳細については、「オブジェクト名のマップ」トピックの「単一オブジェクトの名前のマップ」セクションをご参照ください。一度に複数のオブジェクトの名前を変更するには、選択中のオブジェクトセクションの右上隅にある一括編集をクリックします。詳細については、「オブジェクト名のマップ」トピックの「一度に複数のオブジェクト名をマップする」セクションをご参照ください。説明データをフィルタリングするWHERE条件を指定するには、選択中のオブジェクトセクションでテーブルを右クリックします。表示されるダイアログボックスで、条件を指定します。詳細については、「フィルター条件の設定」をご参照ください。選択中のオブジェクトセクションでテーブルを右クリックします。表示されるダイアログボックスで、すべてのテーブルを同期をオフにします。次に、テーブルのパーティション分割に使用するシャードキーを設定できます。

[次へ：詳細設定] をクリックして詳細設定を構成します。

パラメーター	説明
タスクのスケジュールに使用する専用クラスターの選択	デフォルトでは、DTSはタスクを共有クラスターにスケジュールします。このパラメーターを設定する必要はありません。データ同期タスクの安定性を向上させたい場合は、専用クラスターを購入してください。詳細については、「DTS専用クラスターの概要」をご参照ください。
アラートの設定	データ同期タスクのアラートを設定するかどうかを指定します。タスクが失敗するか、同期レイテンシが指定されたしきい値を超えると、アラート送信先は通知を受け取ります。有効な値： No: アラートを有効にしません。 Yes: アラートを設定します。この場合、アラートしきい値とアラート通知設定詳細については、「モニタリングとアラートの設定」トピックの「DTSタスクを作成するときのモニタリングとアラートの設定」をご参照ください。
失敗した接続の再試行時間	失敗した接続のリトライ時間範囲。データ同期タスクの開始後にソースデータベースまたはターゲットデータベースの接続に失敗した場合、DTSはその時間範囲内ですぐに接続を再試行します。有効な値: 10 ~ 1440 単位は分です。デフォルト値: 720 このパラメーターを30より大きい値に設定することを推奨します。 DTSが指定された時間範囲内にソースデータベースとターゲットデータベースに再接続すると、DTSはデータ同期タスクを再開します。それ以外の場合、データ同期タスクは失敗します。説明ソースまたはターゲットデータベースが同じである複数のデータ同期タスクに対して異なるリトライ時間範囲を指定した場合、最も短いリトライ時間範囲が優先されます。 DTSが接続を再試行すると、DTSインスタンスに対して課金されます。業務要件に基づいて再試行時間範囲を指定することを推奨します。ソースインスタンスとターゲットインスタンスがリリースされた後、できるだけ早くDTSインスタンスをリリースすることもできます。
移行元データベースと移行先データベースで他の問題が発生した場合の、再試行までの待機時間です。	その他の問題の再試行時間範囲。たとえば、データ同期タスクの開始後にDDLまたはDML操作の実行に失敗した場合、DTSはその時間範囲内ですぐに操作を再試行します。有効な値: 1 ~ 1440 単位は分です。デフォルト値は 10 です。このパラメーターを10より大きい値に設定することを推奨します。指定された時間範囲内で失敗した操作が正常に実行されると、DTSはデータ同期タスクを再開します。それ以外の場合、データ同期タスクは失敗します。重要移行元データベースと移行先データベースで他の問題が発生した場合の、再試行までの待機時間です。パラメーターの値は、失敗した接続の再試行時間パラメーターの値よりも小さくする必要があります。
完全移行率を制限するかどうか	完全データ同期中、DTSはソースデータベースとターゲットデータベースの読み取りおよび書き込みリソースを使用します。これにより、データベースサーバーの負荷が増加する可能性があります。 1 秒あたりのソースデータベースのクエリ率 QPS 、1 秒あたりの完全移行の行数 RPS、および1 秒あたりの完全移行データ量 (MB) BPS パラメーターを設定して、ターゲットデータベースサーバーの負荷を軽減できます。説明このパラメーターは、同期タイプパラメーターで完全データ同期が選択されている場合にのみ表示されます。
増分同期率を制限するかどうか	増分データ同期のスロットリングを有効にするかどうかを指定します。ビジネス要件に基づいて、増分データ同期のスロットリングを有効にできます。スロットリングを設定するには、1 秒あたりの増分同期の行数 RPSおよび1 秒あたりの増分同期データ量 (MB) BPS パラメーターを設定する必要があります。これにより、移行先データベースサーバーの負荷が軽減されます。
環境タグ	DTSインスタンスを識別するために使用される環境タグ。ビジネス要件に基づいて環境タグを選択できます。この例では、このパラメーターを設定する必要はありません。
ETL の設定	抽出、変換、および読み込み (ETL) 機能を有効にするかどうかを指定します。詳細については、「ETLとは何ですか?」をご参照ください。有効な値： Yes: ETL機能を設定します。コードエディターでデータ処理ステートメントを入力できます。詳細については、「データ移行またはデータ同期タスクでのETLの設定」をご参照ください。 No: ETL機能を設定しません。
順方向および逆方向タスクのハートビートテーブル sql を削除	DTSインスタンスの実行中に、ハートビートテーブルのSQL操作をソースデータベースに書き込むかどうかを指定します。有効な値： Yes: ハートビートテーブルにSQL操作を書き込みません。この場合、DTSインスタンスのレイテンシが表示され得る。 No: ハートビートテーブルにSQL操作を書き込みます。この場合、ソースデータベースの物理バックアップやクローニングなどの機能が影響を受ける可能性があります。

タスク設定を保存し、事前チェックを実行します。
- 関連するAPI操作を呼び出してDTSタスクを設定するときに指定するパラメーターを表示するには、ポインターを 次：タスク設定の保存と事前チェック に移動し、OpenAPI パラメーターのプレビュー をクリックします。
- パラメーターを表示または表示する必要がない場合は、ページ下部の 次：タスク設定の保存と事前チェック をクリックします。
説明
- データ同期タスクを開始する前に、DTSは事前チェックを実行します。データ同期タスクは、タスクが事前チェックに合格した後にのみ開始できます。
- データ同期タスクが事前チェックに失敗した場合は、失敗した各項目の横にある [詳細の表示] をクリックします。チェック結果に基づいて原因を分析した後、問題のトラブルシューティングを行います。次に、プレチェックを再実行します。
- 事前チェック中にアイテムに対してアラートがトリガーされた場合:
  アラートアイテムを無視できない場合は、失敗したアイテムの横にある [詳細の表示] をクリックして、問題のトラブルシューティングを行います。次に、もう一度プレチェックを実行します。
  アラート項目を無視できる場合は、[アラート詳細の確認] をクリックします。 [詳細の表示] ダイアログボックスで、[無視] をクリックします。表示されたメッセージボックスで、[OK] をクリックします。次に、[再度事前チェック] をクリックして、事前チェックを再度実行します。アラート項目を無視すると、データの不整合が発生し、ビジネスが潜在的なリスクにさらされる可能性があります。
成功率が100% になるまで待ちます。次に、[次へ: インスタンスの購入] をクリックします。

購入ページで、データ同期インスタンスの課金方法とインスタンスクラスのパラメーターを設定します。下表にパラメーターを示します。

セクション	パラメーター	説明
新しいインスタンスクラス	Billing Method	サブスクリプション: データ同期インスタンスの作成時にサブスクリプションの料金を支払います。サブスクリプションの課金方法は、長期使用の場合、従量課金の課金方法よりも費用対効果が高くなります。従量課金: 従量課金インスタンスは1時間ごとに課金されます。従量課金方法は、短期使用に適しています。従量課金データ同期インスタンスが不要になった場合は、インスタンスをリリースしてコストを削減できます。
	リソースグループの設定	データ同期インスタンスが属するリソースグループ。デフォルト値: Default resource group 詳細については、「リソース管理とは」をご参照ください。
	インスタンスクラス	DTSは、同期速度が異なるインスタンスクラスを提供します。ビジネス要件に基づいてインスタンスクラスを選択できます。詳細については、「データ同期インスタンスのインスタンスクラス」をご参照ください。
	サブスクリプション期間	サブスクリプションの課金方法を選択した場合は、サブスクリプション期間と作成するデータ同期インスタンスの数を指定します。サブスクリプション期間は、1〜9か月、1年、2年、3年、または5年とすることができる。説明このパラメーターは、サブスクリプションの課金方法を選択した場合にのみ使用できます。

データ伝送サービス (従量課金) サービス規約 を読んで選択します。
[購入して開始] をクリックします。表示されるダイアログボックスで、OK をクリックします。
タスクリストでタスクの進行状況を確認できます。

DataHubトピックのスキーマ

DTSが増分データをDataHubトピックに同期すると、DTSはトピック内のメタデータを格納する列を追加します。次の図は、DataHubトピックのスキーマを示しています。

説明

この例では、id、name、およびaddressはデータフィールドです。 DTSは、以前のバージョンの追加列の命名規則が使用されているため、データフィールドにdts_ プレフィックスを追加します。

Topic定义

次の表に、DataHubトピックの追加の列を示します。

前の追加の列名	新しい追加列名	タイプ	説明
`dts_record_id`	`new_dts_sync_dts_record_id`	String	増分ログエントリの一意のID。説明デフォルトでは、IDは新しいログエントリごとに自動インクリメントされます。ディザスタリカバリシナリオでは、ロールバックが発生し、IDが自動インクリメントされない場合があります。したがって、いくつかのIDが重複することがある。 UPDATE操作が実行されると、DTSは2つの増分ログエントリを生成して、更新前と更新後の値を記録します。 2つの増分ログエントリの`dts_record_id`フィールドの値は同じです。
`dts_operation_フラグ`	`new_dts_sync_dts_operation_フラグ`	String	操作タイプ。有効な値： I: INSERT操作。 D: DELETE操作。 U: UPDATE操作。 F: 完全なデータ同期。
`dts_instance_id`	`new_dts_sync_dts_instance_id`	String	データベースのサーバーID。
`dts_db_name`	`new_dts_sync_dts_db_名`	String	データベース名。
`dts_table_name`	`new_dts_sync_dts_table_name`	String	<td class="en-UStry align-left colsep-1 rowsep-1">テーブル名。</td>
`dts_utc_タイムスタンプ`	`new_dts_sync_dts_utc_タイムスタンプ`	String	UTCでの操作のタイムスタンプ。また、バイナリログファイルのタイムスタンプでもあります。
`dts_before_フラグ`	`new_dts_sync_dts_before_フラグ`	String	列の値が更新前の値かどうかを示します。有効値: YとN。
`dts_after_flag`	`new_dts_sync_dts_after_フラグ`	String	列の値が更新後の値であるかどうかを示します。有効値: YとN。

dts_before_flagおよびdts_after_flagフィールドに関する追加情報

増分ログエントリのdts_before_flagおよびdts_after_flagフィールドの値は、操作の種類によって異なります。

INSERT
INSERT操作の場合、列の値は新しく挿入されたレコードの値 (更新後の値) です。 dts_before_flagフィールドの値はNであり、dts_after_flagフィールドの値はYである。
UPDATE
DTSは、UPDATE操作用に2つの増分ログエントリを生成します。 2つの増分ログエントリは、dts_record_id、dts_operation_flag、およびdts_utc_timestampフィールドの値が同じです。
第1のログエントリは、更新前の値を記録する。したがって、dts_before_flagフィールドの値はYであり、dts_after_flagフィールドの値はNである。第2のログエントリは、更新後の値を記録する。したがって、dts_before_flagフィールドの値はNであり、dts_after_flagフィールドの値はYである。
DELETE
DELETE操作の場合、列の値は削除されたレコードの値 (更新前の値) です。 dts_before_flagフィールドの値はYであり、dts_after_flagフィールドの値はNである。