AWS DMSでError 1032が発生する原因と確認方法

-- 対象: Aurora MySQL / RDS for MySQL（DMSターゲット）
-- 権限: ターゲットDBへの接続権限
-- 変更作業: なし（参照のみ）
-- Production 実行: 可能
SELECT TABLE_SCHEMA, TABLE_NAME, TABLE_ROWS
FROM information_schema.TABLES
WHERE TABLE_NAME IN (
    'awsdms_apply_exceptions',
    'awsdms_validation_failures_v1',
    'awsdms_status',
    'awsdms_suspended_tables',
    'awsdms_history'
)
ORDER BY TABLE_SCHEMA, TABLE_NAME;

-- 対象: DMSターゲット上の制御スキーマ（既定名は ControlSchema 設定に依存）
-- 権限: 制御スキーマへの SELECT
-- 変更作業: なし（参照のみ）
-- Production 実行: 可能
SELECT
    TASK_NAME,
    TABLE_OWNER,
    TABLE_NAME,
    ERROR_TIME,
    LEFT(STATEMENT, 500) AS statement_head,
    LEFT(ERROR, 500)     AS error_head
FROM awsdms_control.awsdms_apply_exceptions
ORDER BY ERROR_TIME DESC
LIMIT 50;

-- 対象: DMSターゲット上の制御スキーマ（EnableValidation 有効時のみ生成）
-- 権限: 制御スキーマへの SELECT
-- 変更作業: なし（参照のみ）
-- Production 実行: 可能
SELECT
    TASK_NAME,
    TABLE_OWNER,
    TABLE_NAME,
    FAILURE_TIME,
    KEY_TYPE,
    `KEY`            AS row_key,
    FAILURE_TYPE,
    LEFT(DETAILS, 500) AS details_head
FROM awsdms_control.awsdms_validation_failures_v1
ORDER BY FAILURE_TIME DESC
LIMIT 50;

-- 対象: ソース・ターゲット双方で同じSQLを実行して結果を比較する
-- 権限: 対象スキーマのメタデータ参照権限
-- 変更作業: なし（参照のみ）
-- Production 実行: 可能
SELECT
    t.TABLE_SCHEMA,
    t.TABLE_NAME,
    (SELECT GROUP_CONCAT(k.COLUMN_NAME ORDER BY k.ORDINAL_POSITION)
       FROM information_schema.KEY_COLUMN_USAGE k
      WHERE k.TABLE_SCHEMA    = t.TABLE_SCHEMA
        AND k.TABLE_NAME      = t.TABLE_NAME
        AND k.CONSTRAINT_NAME = 'PRIMARY')            AS pk_columns,
    (SELECT COUNT(DISTINCT s.INDEX_NAME)
       FROM information_schema.STATISTICS s
      WHERE s.TABLE_SCHEMA = t.TABLE_SCHEMA
        AND s.TABLE_NAME   = t.TABLE_NAME
        AND s.NON_UNIQUE   = 0)                        AS unique_index_count
FROM information_schema.TABLES t
WHERE t.TABLE_SCHEMA = 'SampleDB'
  AND t.TABLE_TYPE   = 'BASE TABLE'
ORDER BY t.TABLE_NAME;

-- 対象: DMSターゲットのAurora MySQL
-- 権限: 対象テーブルへの SELECT
-- 変更作業: なし（参照のみ）
-- Production 実行: 可能
-- awsdms_apply_exceptions の STATEMENT に出ていたキー値をそのまま当てる
SELECT COUNT(*) AS target_row_count
FROM SampleDB.sample_table
WHERE id = 1001;

-- 併せてソース側でも同じ条件で確認し、片方にしか無いのかを判定する
SELECT COUNT(*) AS source_row_count
FROM SampleDB.sample_table
WHERE id = 1001;

# 対象: AWS DMS レプリケーションタスク
# 権限: IAM dms:DescribeReplicationTasks
# 変更作業: なし（参照のみ）
# Production 実行: 可能

# 1) タスク一覧と状態
aws dms describe-replication-tasks \
  --query 'ReplicationTasks[].{Id:ReplicationTaskIdentifier,Type:MigrationType,Status:Status}' \
  --output table

# 2) 対象タスクの設定JSONをそのまま取り出す（設定名の実体はここで確認する）
aws dms describe-replication-tasks \
  --filters Name=replication-task-id,Values=example-dms-task \
  --query 'ReplicationTasks[0].ReplicationTaskSettings' \
  --output text

// 対象: AWS DMS レプリケーションタスク設定（抜粋）
// 権限: IAM dms:ModifyReplicationTask（変更にはタスク停止が必要）
// 変更作業: あり（適用エラー時の挙動が変わる）
// Production 実行: 影響を理解したうえでのみ。IGNORE_RECORD は変更を黙って捨てる
{
  "TargetMetadata": {
    "TargetTablePrepMode": "DO_NOTHING"
  },
  "ErrorBehavior": {
    "ApplyErrorInsertPolicy": "LOG_ERROR",
    "ApplyErrorUpdatePolicy": "LOG_ERROR",
    "ApplyErrorDeletePolicy": "IGNORE_RECORD",
    "ApplyErrorEscalationPolicy": "LOG_ERROR",
    "ApplyErrorEscalationCount": 0,
    "TableErrorPolicy": "SUSPEND_TABLE"
  },
  "ValidationSettings": {
    "EnableValidation": true,
    "ValidationMode": "ROW_LEVEL",
    "ThreadCount": 5
  }
}