Replication Task
Provides a DMS (Data Migration Service) replication task resource. DMS replication tasks can be created, updated, deleted, and imported.
NOTE: Changing most arguments will stop the task if it is running. You can set
start_replication_taskto resume the task afterwards.
Example Usage
import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";
// Create a new replication task
const test = new aws.dms.ReplicationTask("test", {
cdcStartTime: "1993-05-21T05:50:00Z",
migrationType: "full-load",
replicationInstanceArn: test_dms_replication_instance_tf.replicationInstanceArn,
replicationTaskId: "test-dms-replication-task-tf",
replicationTaskSettings: "...",
sourceEndpointArn: test_dms_source_endpoint_tf.endpointArn,
tableMappings: "{\"rules\":[{\"rule-type\":\"selection\",\"rule-id\":\"1\",\"rule-name\":\"1\",\"object-locator\":{\"schema-name\":\"%\",\"table-name\":\"%\"},\"rule-action\":\"include\"}]}",
tags: {
Name: "test",
},
targetEndpointArn: test_dms_target_endpoint_tf.endpointArn,
});import pulumi
import pulumi_aws as aws
# Create a new replication task
test = aws.dms.ReplicationTask("test",
cdc_start_time="1993-05-21T05:50:00Z",
migration_type="full-load",
replication_instance_arn=test_dms_replication_instance_tf["replicationInstanceArn"],
replication_task_id="test-dms-replication-task-tf",
replication_task_settings="...",
source_endpoint_arn=test_dms_source_endpoint_tf["endpointArn"],
table_mappings="{\"rules\":[{\"rule-type\":\"selection\",\"rule-id\":\"1\",\"rule-name\":\"1\",\"object-locator\":{\"schema-name\":\"%\",\"table-name\":\"%\"},\"rule-action\":\"include\"}]}",
tags={
"Name": "test",
},
target_endpoint_arn=test_dms_target_endpoint_tf["endpointArn"])using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;
return await Deployment.RunAsync(() =>
{
// Create a new replication task
var test = new Aws.Dms.ReplicationTask("test", new()
{
CdcStartTime = "1993-05-21T05:50:00Z",
MigrationType = "full-load",
ReplicationInstanceArn = test_dms_replication_instance_tf.ReplicationInstanceArn,
ReplicationTaskId = "test-dms-replication-task-tf",
ReplicationTaskSettings = "...",
SourceEndpointArn = test_dms_source_endpoint_tf.EndpointArn,
TableMappings = "{\"rules\":[{\"rule-type\":\"selection\",\"rule-id\":\"1\",\"rule-name\":\"1\",\"object-locator\":{\"schema-name\":\"%\",\"table-name\":\"%\"},\"rule-action\":\"include\"}]}",
Tags =
{
{ "Name", "test" },
},
TargetEndpointArn = test_dms_target_endpoint_tf.EndpointArn,
});
});package main
import (
"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/dms"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
// Create a new replication task
_, err := dms.NewReplicationTask(ctx, "test", &dms.ReplicationTaskArgs{
CdcStartTime: pulumi.String("1993-05-21T05:50:00Z"),
MigrationType: pulumi.String("full-load"),
ReplicationInstanceArn: pulumi.Any(test_dms_replication_instance_tf.ReplicationInstanceArn),
ReplicationTaskId: pulumi.String("test-dms-replication-task-tf"),
ReplicationTaskSettings: pulumi.String("..."),
SourceEndpointArn: pulumi.Any(test_dms_source_endpoint_tf.EndpointArn),
TableMappings: pulumi.String("{\"rules\":[{\"rule-type\":\"selection\",\"rule-id\":\"1\",\"rule-name\":\"1\",\"object-locator\":{\"schema-name\":\"%\",\"table-name\":\"%\"},\"rule-action\":\"include\"}]}"),
Tags: pulumi.StringMap{
"Name": pulumi.String("test"),
},
TargetEndpointArn: pulumi.Any(test_dms_target_endpoint_tf.EndpointArn),
})
if err != nil {
return err
}
return nil
})
}package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.dms.ReplicationTask;
import com.pulumi.aws.dms.ReplicationTaskArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
// Create a new replication task
var test = new ReplicationTask("test", ReplicationTaskArgs.builder()
.cdcStartTime("1993-05-21T05:50:00Z")
.migrationType("full-load")
.replicationInstanceArn(test_dms_replication_instance_tf.replicationInstanceArn())
.replicationTaskId("test-dms-replication-task-tf")
.replicationTaskSettings("...")
.sourceEndpointArn(test_dms_source_endpoint_tf.endpointArn())
.tableMappings("{\"rules\":[{\"rule-type\":\"selection\",\"rule-id\":\"1\",\"rule-name\":\"1\",\"object-locator\":{\"schema-name\":\"%\",\"table-name\":\"%\"},\"rule-action\":\"include\"}]}")
.tags(Map.of("Name", "test"))
.targetEndpointArn(test_dms_target_endpoint_tf.endpointArn())
.build());
}
}resources:
# Create a new replication task
test:
type: aws:dms:ReplicationTask
properties:
cdcStartTime: 1993-05-21T05:50:00Z
migrationType: full-load
replicationInstanceArn: ${["test-dms-replication-instance-tf"].replicationInstanceArn}
replicationTaskId: test-dms-replication-task-tf
replicationTaskSettings: '...'
sourceEndpointArn: ${["test-dms-source-endpoint-tf"].endpointArn}
tableMappings: '{"rules":[{"rule-type":"selection","rule-id":"1","rule-name":"1","object-locator":{"schema-name":"%","table-name":"%"},"rule-action":"include"}]}'
tags:
Name: test
targetEndpointArn: ${["test-dms-target-endpoint-tf"].endpointArn}Import
Using pulumi import, import replication tasks using the replication_task_id. For example:
$ pulumi import aws:dms/replicationTask:ReplicationTask test test-dms-replication-task-tfProperties
Indicates when you want a change data capture (CDC) operation to start. The value can be a RFC3339 formatted date, a checkpoint, or a LSN/SCN format depending on the source engine. For more information see Determining a CDC native start point.
An escaped JSON string that contains the task settings. For a complete list of task settings, see Task Settings for AWS Database Migration Service Tasks.
An escaped JSON string that contains the table mappings. For information on table mapping see Using Table Mapping with an AWS Database Migration Service Task to Select and Filter Data