CDCソースからの変更データのキャプチャ

• •状態テーブル名: <MappingTaskID>_<Instance(s)>
• •ステージングテーブル名: <MappingTaskID>_<TargetInstanceName>

制限

CDCマッピングのソースまたはルックアップオブジェクト

CDCマッピングではSnowflakeターゲットを使用して、CDCソースからデータを書き込むことができます。CDCマッピングでSnowflakeソースまたはルックアップを使用することはできません。

ステージング最適化プロパティ

Secure AgentのDTMではステージングデータに設定した最適化プロパティは適用されません。CDCおよびステージングプロパティを有効にしてマッピングを実行すると、マッピングは正常に実行されます。ただし、ステージングの最適化は無効になりますが、セッションログに記録されたメッセージを表示することができます。

リカバリ初期化エラー

CDCマッピングを実行してCDCソースから実行時に作成されたSnowflakeターゲットにデータを書き込むと、次のエラーが発生する場合があります。

Error occured while initializing CCI State Handler com.informatica.cci.runtime.internal.utils.impl.CExceptionImpl: Internal error: Recovery Init failed

このエラーを回避するには、Snowflakeでテーブルを作成する権限を付与する必要があります。

DTMエラー

［JDBC URLの追加パラメータ］フィールドのProcessConnDBパラメータとProcessConnSchemaパラメータで構成されたSnowflakeターゲット接続を使用するCDCマッピングを実行する場合、マッピングが次のDTMエラーで失敗する可能性があります:

内部エラー。DTMプロセスが予期せず終了しました。Informaticaグローバルカスタマサポートにお問い合わせください。

このエラーを回避するには、Snowflake Data Cloud接続の［JDBC URLの追加パラメータ］フィールドからProcessConnDBパラメータとProcessConnSchemaパラメータを削除します。ただし、ProcessConnDBパラメータとProcessConnSchemaパラメータを使用して一時ステージテーブルとリカバリ状態テーブルを作成する場合は、必要なデータベースとスキーマに必要な権限があることを確認してください。

CDCソースから読み取るためのマッピングタスクの設定

• •データベース
• •スキーマ
• •ウェアハウス
• •ロール
• •Pre SQL
• •Post SQL
• •ターゲットテーブルの切り詰め
• •テーブル名
• •更新オーバーライド

手順1.ソースを設定します

1ソーストランスフォーメーションの全般プロパティで、名前と説明を指定します。
2［ソース］タブで、設定済みの任意のCDC接続を選択し、必要なソースプロパティを指定します。
ソースオブジェクトにプライマリキーを含めることをお勧めします。

手順2.ターゲットを設定します

1［ターゲット］タブで、次の手順を実行してターゲットプロパティを設定します。
1. a［接続］フィールドで、Snowflake Data Cloud接続を選択します。
2. b［ターゲットの種類］フィールドで、ターゲットオブジェクトのタイプを選択します。
3. c［オブジェクト］フィールドで、必要なターゲットオブジェクトを選択します。
4. d［操作］フィールドで、［挿入］または［データドリブン］を選択します。
注: ターゲットの更新、更新/挿入、および削除操作は適用されません。ターゲットテーブルにSnowflakeで定義されたプライマリキーがないことを確認します。
5. e［データドリブン条件］を選択した場合は、DD_INSERT条件を指定します。
注: ターゲットテーブルにSnowflakeで定義されたプライマリキーがないことを確認します。
6. fCDCモードに適用可能な詳細ターゲットプロパティを設定します。
2［フィールドマッピング］タブで、受信フィールドをターゲットフィールドにマップします。手動でマップすることも、フィールド名に基づいて自動的にマップすることもできます。
Snowflakeターゲットテーブルで必要に応じてカラムを定義する場合は、CDCソースのカラムをマッピングのSnowflakeターゲットの必要なカラムにマッピングします。

手順3.マッピングタスクを設定します

1［アクション］メニューで、［新しいマッピングタスク］をクリックします。
［新しいマッピングタスク］ページが表示されます。
2［定義］タブで、タスク名を入力し、設定済みのマッピングを選択します。
3［CDCランタイム］タブで、選択したCDCソースに必要なプロパティを指定します。
［CDCランタイム］プロパティの詳細については、選択したCDCソースのソースプロパティを参照してください。
4［ランタイムオプション］タブの［詳細セッションプロパティ］セクションで、次のプロパティを追加します。
1. a［ファイル終端（EOF）でコミット］フィールドで、このプロパティの値として［いいえ］を選択します。
2. b［コミットタイプ］フィールドで、このプロパティの値として［ソース］を選択します。
3. c［リカバリストラテジ］フィールドで、このプロパティの値として［最終チェックポイントから再開］を選択します。
5［保存］ > ［実行］をクリックして、マッピングタスクを保存して実行します。
スケジュールを作成して、手動で操作しなくてもマッピングタスクが定期的に実行されるようにすることもできます。マッピングタスクの実行間隔ができるだけ短くなるようにスケジュールを定義できます。Monitorで、タスクの実行後にログのステータスを監視できます。

リカバリメカニズムの無効化

1. 1Snowflake Data Cloudターゲットトランスフォーメーションの［追加の書き込みランタイムパラメータ］フィールドでdisableSnowflakeRecoveryCDC=trueプロパティを設定します。
2. 2マッピングタスクの［ランタイムオプション］タブの［詳細セッションプロパティ］で、設定済みのリカバリストラテジを削除します。