Skip to content

Commit

Permalink
Merge pull request #13476 from aburgel/dms-json-diff
Browse files Browse the repository at this point in the history 
Remove readonly properties from DMS ReplicationTaskSettings
  • Loading branch information
@YakDriver
YakDriver authored Apr 2, 2021
2 parents 9a79c95 + 58f2525 commit 285bd81
Show file tree
Hide file tree
Showing 3 changed files with 84 additions and 135 deletions.
3 changes: 3 additions & 0 deletions .changelog/13476.txt
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
```release-note:bug
resource/aws_dms_replication_task: Handle read-only attributes in `replication_task_settings` to avoid unnecessary diffs.
```
34 changes: 33 additions & 1 deletion aws/resource_aws_dms_replication_task.go
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package aws

import (
"encoding/json"
"fmt"
"log"
"strconv"
Expand Down Expand Up @@ -288,11 +289,16 @@ func resourceAwsDmsReplicationTaskSetState(d *schema.ResourceData, task *dms.Rep
d.Set("replication_instance_arn", task.ReplicationInstanceArn)
d.Set("replication_task_arn", task.ReplicationTaskArn)
d.Set("replication_task_id", task.ReplicationTaskIdentifier)
d.Set("replication_task_settings", task.ReplicationTaskSettings)
d.Set("source_endpoint_arn", task.SourceEndpointArn)
d.Set("table_mappings", task.TableMappings)
d.Set("target_endpoint_arn", task.TargetEndpointArn)

settings, err := dmsReplicationTaskRemoveReadOnlySettings(*task.ReplicationTaskSettings)
if err != nil {
return err
}
d.Set("replication_task_settings", settings)

return nil
}

Expand Down Expand Up @@ -328,3 +334,29 @@ func resourceAwsDmsReplicationTaskStateRefreshFunc(
return v, *v.ReplicationTasks[0].Status, nil
}
}

func dmsReplicationTaskRemoveReadOnlySettings(settings string) (*string, error) {
var settingsData map[string]interface{}
if err := json.Unmarshal([]byte(settings), &settingsData); err != nil {
return nil, err
}

controlTablesSettings, ok := settingsData["ControlTablesSettings"].(map[string]interface{})
if ok {
delete(controlTablesSettings, "historyTimeslotInMinutes")
}

logging, ok := settingsData["Logging"].(map[string]interface{})
if ok {
delete(logging, "CloudWatchLogGroup")
delete(logging, "CloudWatchLogStream")
}

cleanedSettings, err := json.Marshal(settingsData)
if err != nil {
return nil, err
}

cleanedSettingsString := string(cleanedSettings)
return &cleanedSettingsString, nil
}
182 changes: 48 additions & 134 deletions aws/resource_aws_dms_replication_task_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -12,8 +12,17 @@ import (
)

func TestAccAWSDmsReplicationTask_basic(t *testing.T) {
resourceName := "aws_dms_replication_task.dms_replication_task"
randId := acctest.RandString(8)
rName := acctest.RandomWithPrefix("tf-acc-test")
resourceName := "aws_dms_replication_task.test"

tags := `
Update = "to-update"
Remove = "to-remove"
`
updatedTags := `
Update = "updated"
Add = "added"
`

resource.ParallelTest(t, resource.TestCase{
PreCheck: func() { testAccPreCheck(t) },
Expand All @@ -22,19 +31,24 @@ func TestAccAWSDmsReplicationTask_basic(t *testing.T) {
CheckDestroy: dmsReplicationTaskDestroy,
Steps: []resource.TestStep{
{
Config: dmsReplicationTaskConfig(randId),
Config: dmsReplicationTaskConfig(rName, tags),
Check: resource.ComposeTestCheckFunc(
checkDmsReplicationTaskExists(resourceName),
resource.TestCheckResourceAttrSet(resourceName, "replication_task_arn"),
),
},
{
Config: dmsReplicationTaskConfig(rName, tags),
PlanOnly: true,
ExpectNonEmptyPlan: false,
},
{
ResourceName: resourceName,
ImportState: true,
ImportStateVerify: true,
},
{
Config: dmsReplicationTaskConfigUpdate(randId),
Config: dmsReplicationTaskConfig(rName, updatedTags),
Check: resource.ComposeTestCheckFunc(
checkDmsReplicationTaskExists(resourceName),
),
Expand Down Expand Up @@ -103,47 +117,43 @@ func dmsReplicationTaskDestroy(s *terraform.State) error {
return nil
}

func dmsReplicationTaskConfig(randId string) string {
func dmsReplicationTaskConfig(rName, tags string) string {
return composeConfig(testAccAvailableAZsNoOptInConfig(), fmt.Sprintf(`
data "aws_partition" "current" {}
data "aws_region" "current" {}
resource "aws_vpc" "dms_vpc" {
resource "aws_vpc" "test" {
cidr_block = "10.1.0.0/16"
tags = {
Name = "terraform-testacc-dms-replication-task-%[1]s"
Name = %[1]q
}
}
resource "aws_subnet" "dms_subnet_1" {
resource "aws_subnet" "test1" {
cidr_block = "10.1.1.0/24"
availability_zone = data.aws_availability_zones.available.names[0]
vpc_id = aws_vpc.dms_vpc.id
vpc_id = aws_vpc.test.id
tags = {
Name = "tf-acc-dms-replication-task-1-%[1]s"
Name = %[1]q
}
depends_on = [aws_vpc.dms_vpc]
}
resource "aws_subnet" "dms_subnet_2" {
resource "aws_subnet" "test2" {
cidr_block = "10.1.2.0/24"
availability_zone = data.aws_availability_zones.available.names[1]
vpc_id = aws_vpc.dms_vpc.id
vpc_id = aws_vpc.test.id
tags = {
Name = "tf-acc-dms-replication-task-2-%[1]s"
Name = "%[1]s-2"
}
depends_on = [aws_vpc.dms_vpc]
}
resource "aws_dms_endpoint" "dms_endpoint_source" {
database_name = "tf-test-dms-db"
endpoint_id = "tf-test-dms-endpoint-source-%[1]s"
resource "aws_dms_endpoint" "source" {
database_name = %[1]q
endpoint_id = "%[1]s-source"
endpoint_type = "source"
engine_name = "aurora"
server_name = "tf-test-cluster.cluster-xxxxxxx.${data.aws_region.current.name}.rds.${data.aws_partition.current.dns_suffix}"
Expand All @@ -152,9 +162,9 @@ resource "aws_dms_endpoint" "dms_endpoint_source" {
password = "tftest"
}
resource "aws_dms_endpoint" "dms_endpoint_target" {
database_name = "tf-test-dms-db"
endpoint_id = "tf-test-dms-endpoint-target-%[1]s"
resource "aws_dms_endpoint" "target" {
database_name = %[1]q
endpoint_id = "%[1]s-target"
endpoint_type = "target"
engine_name = "aurora"
server_name = "tf-test-cluster.cluster-xxxxxxx.${data.aws_region.current.name}.rds.${data.aws_partition.current.dns_suffix}"
Expand All @@ -163,132 +173,36 @@ resource "aws_dms_endpoint" "dms_endpoint_target" {
password = "tftest"
}
resource "aws_dms_replication_subnet_group" "dms_replication_subnet_group" {
replication_subnet_group_id = "tf-test-dms-replication-subnet-group-%[1]s"
resource "aws_dms_replication_subnet_group" "test" {
replication_subnet_group_id = %[1]q
replication_subnet_group_description = "terraform test for replication subnet group"
subnet_ids = [aws_subnet.dms_subnet_1.id, aws_subnet.dms_subnet_2.id]
subnet_ids = [aws_subnet.test1.id, aws_subnet.test2.id]
}
resource "aws_dms_replication_instance" "dms_replication_instance" {
resource "aws_dms_replication_instance" "test" {
allocated_storage = 5
auto_minor_version_upgrade = true
replication_instance_class = "dms.c4.large"
replication_instance_id = "tf-test-dms-replication-instance-%[1]s"
replication_instance_id = %[1]q
preferred_maintenance_window = "sun:00:30-sun:02:30"
publicly_accessible = false
replication_subnet_group_id = aws_dms_replication_subnet_group.dms_replication_subnet_group.replication_subnet_group_id
replication_subnet_group_id = aws_dms_replication_subnet_group.test.replication_subnet_group_id
}
resource "aws_dms_replication_task" "dms_replication_task" {
resource "aws_dms_replication_task" "test" {
migration_type = "full-load"
replication_instance_arn = aws_dms_replication_instance.dms_replication_instance.replication_instance_arn
replication_task_id = "tf-test-dms-replication-task-%[1]s"
replication_task_settings = "{\"TargetMetadata\":{\"TargetSchema\":\"\",\"SupportLobs\":true,\"FullLobMode\":false,\"LobChunkSize\":0,\"LimitedSizeLobMode\":true,\"LobMaxSize\":32,\"LoadMaxFileSize\":0,\"ParallelLoadThreads\":0,\"BatchApplyEnabled\":false},\"FullLoadSettings\":{\"FullLoadEnabled\":true,\"ApplyChangesEnabled\":false,\"TargetTablePrepMode\":\"DROP_AND_CREATE\",\"CreatePkAfterFullLoad\":false,\"StopTaskCachedChangesApplied\":false,\"StopTaskCachedChangesNotApplied\":false,\"ResumeEnabled\":false,\"ResumeMinTableSize\":100000,\"ResumeOnlyClusteredPKTables\":true,\"MaxFullLoadSubTasks\":8,\"TransactionConsistencyTimeout\":600,\"CommitRate\":10000},\"Logging\":{\"EnableLogging\":false,\"LogComponents\":[{\"Id\":\"SOURCE_UNLOAD\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"TARGET_LOAD\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"SOURCE_CAPTURE\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"TARGET_APPLY\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"TASK_MANAGER\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"}],\"CloudWatchLogGroup\":null,\"CloudWatchLogStream\":null},\"ControlTablesSettings\":{\"historyTimeslotInMinutes\":5,\"ControlSchema\":\"\",\"HistoryTimeslotInMinutes\":5,\"HistoryTableEnabled\":false,\"SuspendedTablesTableEnabled\":false,\"StatusTableEnabled\":false},\"StreamBufferSettings\":{\"StreamBufferCount\":3,\"StreamBufferSizeInMB\":8,\"CtrlStreamBufferSizeInMB\":5},\"ChangeProcessingDdlHandlingPolicy\":{\"HandleSourceTableDropped\":true,\"HandleSourceTableTruncated\":true,\"HandleSourceTableAltered\":true},\"ErrorBehavior\":{\"DataErrorPolicy\":\"LOG_ERROR\",\"DataTruncationErrorPolicy\":\"LOG_ERROR\",\"DataErrorEscalationPolicy\":\"SUSPEND_TABLE\",\"DataErrorEscalationCount\":0,\"TableErrorPolicy\":\"SUSPEND_TABLE\",\"TableErrorEscalationPolicy\":\"STOP_TASK\",\"TableErrorEscalationCount\":0,\"RecoverableErrorCount\":-1,\"RecoverableErrorInterval\":5,\"RecoverableErrorThrottling\":true,\"RecoverableErrorThrottlingMax\":1800,\"ApplyErrorDeletePolicy\":\"IGNORE_RECORD\",\"ApplyErrorInsertPolicy\":\"LOG_ERROR\",\"ApplyErrorUpdatePolicy\":\"LOG_ERROR\",\"ApplyErrorEscalationPolicy\":\"LOG_ERROR\",\"ApplyErrorEscalationCount\":0,\"FullLoadIgnoreConflicts\":true},\"ChangeProcessingTuning\":{\"BatchApplyPreserveTransaction\":true,\"BatchApplyTimeoutMin\":1,\"BatchApplyTimeoutMax\":30,\"BatchApplyMemoryLimit\":500,\"BatchSplitSize\":0,\"MinTransactionSize\":1000,\"CommitTimeout\":1,\"MemoryLimitTotal\":1024,\"MemoryKeepTime\":60,\"StatementCacheSize\":50}}"
source_endpoint_arn = aws_dms_endpoint.dms_endpoint_source.endpoint_arn
replication_instance_arn = aws_dms_replication_instance.test.replication_instance_arn
replication_task_id = %[1]q
replication_task_settings = "{\"BeforeImageSettings\":null,\"FailTaskWhenCleanTaskResourceFailed\":false,\"ChangeProcessingDdlHandlingPolicy\":{\"HandleSourceTableAltered\":true,\"HandleSourceTableDropped\":true,\"HandleSourceTableTruncated\":true},\"ChangeProcessingTuning\":{\"BatchApplyMemoryLimit\":500,\"BatchApplyPreserveTransaction\":true,\"BatchApplyTimeoutMax\":30,\"BatchApplyTimeoutMin\":1,\"BatchSplitSize\":0,\"CommitTimeout\":1,\"MemoryKeepTime\":60,\"MemoryLimitTotal\":1024,\"MinTransactionSize\":1000,\"StatementCacheSize\":50},\"CharacterSetSettings\":null,\"ControlTablesSettings\":{\"ControlSchema\":\"\",\"FullLoadExceptionTableEnabled\":false,\"HistoryTableEnabled\":false,\"HistoryTimeslotInMinutes\":5,\"StatusTableEnabled\":false,\"SuspendedTablesTableEnabled\":false},\"ErrorBehavior\":{\"ApplyErrorDeletePolicy\":\"IGNORE_RECORD\",\"ApplyErrorEscalationCount\":0,\"ApplyErrorEscalationPolicy\":\"LOG_ERROR\",\"ApplyErrorFailOnTruncationDdl\":false,\"ApplyErrorInsertPolicy\":\"LOG_ERROR\",\"ApplyErrorUpdatePolicy\":\"LOG_ERROR\",\"DataErrorEscalationCount\":0,\"DataErrorEscalationPolicy\":\"SUSPEND_TABLE\",\"DataErrorPolicy\":\"LOG_ERROR\",\"DataTruncationErrorPolicy\":\"LOG_ERROR\",\"FailOnNoTablesCaptured\":false,\"FailOnTransactionConsistencyBreached\":false,\"FullLoadIgnoreConflicts\":true,\"RecoverableErrorCount\":-1,\"RecoverableErrorInterval\":5,\"RecoverableErrorStopRetryAfterThrottlingMax\":false,\"RecoverableErrorThrottling\":true,\"RecoverableErrorThrottlingMax\":1800,\"TableErrorEscalationCount\":0,\"TableErrorEscalationPolicy\":\"STOP_TASK\",\"TableErrorPolicy\":\"SUSPEND_TABLE\"},\"FullLoadSettings\":{\"CommitRate\":10000,\"CreatePkAfterFullLoad\":false,\"MaxFullLoadSubTasks\":8,\"StopTaskCachedChangesApplied\":false,\"StopTaskCachedChangesNotApplied\":false,\"TargetTablePrepMode\":\"DROP_AND_CREATE\",\"TransactionConsistencyTimeout\":600},\"Logging\":{\"EnableLogging\":false,\"LogComponents\":[{\"Id\":\"TRANSFORMATION\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"SOURCE_UNLOAD\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"IO\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"TARGET_LOAD\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"PERFORMANCE\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"SOURCE_CAPTURE\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"SORTER\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"REST_SERVER\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"VALIDATOR_EXT\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"TARGET_APPLY\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"TASK_MANAGER\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"TABLES_MANAGER\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"METADATA_MANAGER\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"FILE_FACTORY\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"COMMON\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"ADDONS\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"DATA_STRUCTURE\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"COMMUNICATION\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"FILE_TRANSFER\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"}]},\"LoopbackPreventionSettings\":null,\"PostProcessingRules\":null,\"StreamBufferSettings\":{\"CtrlStreamBufferSizeInMB\":5,\"StreamBufferCount\":3,\"StreamBufferSizeInMB\":8},\"TargetMetadata\":{\"BatchApplyEnabled\":false,\"FullLobMode\":false,\"InlineLobMaxSize\":0,\"LimitedSizeLobMode\":true,\"LoadMaxFileSize\":0,\"LobChunkSize\":0,\"LobMaxSize\":32,\"ParallelApplyBufferSize\":0,\"ParallelApplyQueuesPerThread\":0,\"ParallelApplyThreads\":0,\"ParallelLoadBufferSize\":0,\"ParallelLoadQueuesPerThread\":0,\"ParallelLoadThreads\":0,\"SupportLobs\":true,\"TargetSchema\":\"\",\"TaskRecoveryTableEnabled\":false}}"
source_endpoint_arn = aws_dms_endpoint.source.endpoint_arn
table_mappings = "{\"rules\":[{\"rule-type\":\"selection\",\"rule-id\":\"1\",\"rule-name\":\"1\",\"object-locator\":{\"schema-name\":\"%%\",\"table-name\":\"%%\"},\"rule-action\":\"include\"}]}"
tags = {
Name = "tf-test-dms-replication-task-%[1]s"
Update = "to-update"
Remove = "to-remove"
}
target_endpoint_arn = aws_dms_endpoint.dms_endpoint_target.endpoint_arn
}
`, randId))
}

func dmsReplicationTaskConfigUpdate(randId string) string {
return composeConfig(testAccAvailableAZsNoOptInConfig(), fmt.Sprintf(`
data "aws_partition" "current" {}
data "aws_region" "current" {}
resource "aws_vpc" "dms_vpc" {
cidr_block = "10.1.0.0/16"
tags = {
Name = "terraform-testacc-dms-replication-task-%[1]s"
}
}
resource "aws_subnet" "dms_subnet_1" {
cidr_block = "10.1.1.0/24"
availability_zone = data.aws_availability_zones.available.names[0]
vpc_id = aws_vpc.dms_vpc.id
tags = {
Name = "tf-acc-dms-replication-task-1-%[1]s"
}
depends_on = [aws_vpc.dms_vpc]
}
resource "aws_subnet" "dms_subnet_2" {
cidr_block = "10.1.2.0/24"
availability_zone = data.aws_availability_zones.available.names[1]
vpc_id = aws_vpc.dms_vpc.id
tags = {
Name = "tf-acc-dms-replication-task-2-%[1]s"
}
depends_on = [aws_vpc.dms_vpc]
}
resource "aws_dms_endpoint" "dms_endpoint_source" {
database_name = "tf-test-dms-db"
endpoint_id = "tf-test-dms-endpoint-source-%[1]s"
endpoint_type = "source"
engine_name = "aurora"
server_name = "tf-test-cluster.cluster-xxxxxxx.${data.aws_region.current.name}.rds.${data.aws_partition.current.dns_suffix}"
port = 3306
username = "tftest"
password = "tftest"
}
resource "aws_dms_endpoint" "dms_endpoint_target" {
database_name = "tf-test-dms-db"
endpoint_id = "tf-test-dms-endpoint-target-%[1]s"
endpoint_type = "target"
engine_name = "aurora"
server_name = "tf-test-cluster.cluster-xxxxxxx.${data.aws_region.current.name}.rds.${data.aws_partition.current.dns_suffix}"
port = 3306
username = "tftest"
password = "tftest"
}
resource "aws_dms_replication_subnet_group" "dms_replication_subnet_group" {
replication_subnet_group_id = "tf-test-dms-replication-subnet-group-%[1]s"
replication_subnet_group_description = "terraform test for replication subnet group"
subnet_ids = [aws_subnet.dms_subnet_1.id, aws_subnet.dms_subnet_2.id]
}
resource "aws_dms_replication_instance" "dms_replication_instance" {
allocated_storage = 5
auto_minor_version_upgrade = true
replication_instance_class = "dms.c4.large"
replication_instance_id = "tf-test-dms-replication-instance-%[1]s"
preferred_maintenance_window = "sun:00:30-sun:02:30"
publicly_accessible = false
replication_subnet_group_id = aws_dms_replication_subnet_group.dms_replication_subnet_group.replication_subnet_group_id
}
resource "aws_dms_replication_task" "dms_replication_task" {
migration_type = "full-load"
replication_instance_arn = aws_dms_replication_instance.dms_replication_instance.replication_instance_arn
replication_task_id = "tf-test-dms-replication-task-%[1]s"
replication_task_settings = "{\"TargetMetadata\":{\"TargetSchema\":\"\",\"SupportLobs\":true,\"FullLobMode\":false,\"LobChunkSize\":0,\"LimitedSizeLobMode\":true,\"LobMaxSize\":32,\"LoadMaxFileSize\":0,\"ParallelLoadThreads\":0,\"BatchApplyEnabled\":false},\"FullLoadSettings\":{\"FullLoadEnabled\":true,\"ApplyChangesEnabled\":false,\"TargetTablePrepMode\":\"DROP_AND_CREATE\",\"CreatePkAfterFullLoad\":false,\"StopTaskCachedChangesApplied\":false,\"StopTaskCachedChangesNotApplied\":false,\"ResumeEnabled\":false,\"ResumeMinTableSize\":100000,\"ResumeOnlyClusteredPKTables\":true,\"MaxFullLoadSubTasks\":7,\"TransactionConsistencyTimeout\":600,\"CommitRate\":10000},\"Logging\":{\"EnableLogging\":false,\"LogComponents\":[{\"Id\":\"SOURCE_UNLOAD\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"TARGET_LOAD\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"SOURCE_CAPTURE\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"TARGET_APPLY\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"},{\"Id\":\"TASK_MANAGER\",\"Severity\":\"LOGGER_SEVERITY_DEFAULT\"}],\"CloudWatchLogGroup\":null,\"CloudWatchLogStream\":null},\"ControlTablesSettings\":{\"historyTimeslotInMinutes\":5,\"ControlSchema\":\"\",\"HistoryTimeslotInMinutes\":5,\"HistoryTableEnabled\":false,\"SuspendedTablesTableEnabled\":false,\"StatusTableEnabled\":false},\"StreamBufferSettings\":{\"StreamBufferCount\":3,\"StreamBufferSizeInMB\":8,\"CtrlStreamBufferSizeInMB\":5},\"ChangeProcessingDdlHandlingPolicy\":{\"HandleSourceTableDropped\":true,\"HandleSourceTableTruncated\":true,\"HandleSourceTableAltered\":true},\"ErrorBehavior\":{\"DataErrorPolicy\":\"LOG_ERROR\",\"DataTruncationErrorPolicy\":\"LOG_ERROR\",\"DataErrorEscalationPolicy\":\"SUSPEND_TABLE\",\"DataErrorEscalationCount\":0,\"TableErrorPolicy\":\"SUSPEND_TABLE\",\"TableErrorEscalationPolicy\":\"STOP_TASK\",\"TableErrorEscalationCount\":0,\"RecoverableErrorCount\":-1,\"RecoverableErrorInterval\":5,\"RecoverableErrorThrottling\":true,\"RecoverableErrorThrottlingMax\":1800,\"ApplyErrorDeletePolicy\":\"IGNORE_RECORD\",\"ApplyErrorInsertPolicy\":\"LOG_ERROR\",\"ApplyErrorUpdatePolicy\":\"LOG_ERROR\",\"ApplyErrorEscalationPolicy\":\"LOG_ERROR\",\"ApplyErrorEscalationCount\":0,\"FullLoadIgnoreConflicts\":true},\"ChangeProcessingTuning\":{\"BatchApplyPreserveTransaction\":true,\"BatchApplyTimeoutMin\":1,\"BatchApplyTimeoutMax\":30,\"BatchApplyMemoryLimit\":500,\"BatchSplitSize\":0,\"MinTransactionSize\":1000,\"CommitTimeout\":1,\"MemoryLimitTotal\":1024,\"MemoryKeepTime\":60,\"StatementCacheSize\":50}}"
source_endpoint_arn = aws_dms_endpoint.dms_endpoint_source.endpoint_arn
table_mappings = "{\"rules\":[{\"rule-type\":\"selection\",\"rule-id\":\"1\",\"rule-name\":\"1\",\"object-locator\":{\"schema-name\":\"%%\",\"table-name\":\"%%\"},\"rule-action\":\"include\"}]}"
tags = {
Name = "tf-test-dms-replication-task-%[1]s"
Update = "updated"
Add = "added"
Name = %[1]q
%[2]s
}
target_endpoint_arn = aws_dms_endpoint.dms_endpoint_target.endpoint_arn
target_endpoint_arn = aws_dms_endpoint.target.endpoint_arn
}
`, randId))
`, rName, tags))
}

0 comments on commit 285bd81

Please sign in to comment.