pulumi-aws-kotlin/com.pulumi.aws.dms.kotlin/ReplicationTask

ReplicationTask

class ReplicationTask : KotlinCustomResource

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_task to resume the task afterwards.

Example Usage

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) {
        var test = new ReplicationTask("test", ReplicationTaskArgs.builder()
            .cdcStartTime(1484346880)
            .migrationType("full-load")
            .replicationInstanceArn(aws_dms_replication_instance.test-dms-replication-instance-tf().replication_instance_arn())
            .replicationTaskId("test-dms-replication-task-tf")
            .replicationTaskSettings("...")
            .sourceEndpointArn(aws_dms_endpoint.test-dms-source-endpoint-tf().endpoint_arn())
            .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(aws_dms_endpoint.test-dms-target-endpoint-tf().endpoint_arn())
            .build());
    }
}

Import

Replication tasks can be imported using the replication_task_id, e.g.,

$ pulumi import aws:dms/replicationTask:ReplicationTask test test-dms-replication-task-tf

Properties

cdcStartPosition

val cdcStartPosition: Output<String>

Indicates when you want a change data capture (CDC) operation to start. The value can be in date, checkpoint, or LSN/SCN format depending on the source engine. For more information, see Determining a CDC native start point.

cdcStartTime

val cdcStartTime: Output<String>?

The Unix timestamp integer for the start of the Change Data Capture (CDC) operation.

val id: Output<String>

migrationType

val migrationType: Output<String>

The migration type. Can be one of full-load | cdc | full-load-and-cdc.

pulumiChildResources

val pulumiChildResources: Set<KotlinResource>

pulumiResourceName

val pulumiResourceName: String

pulumiResourceType

val pulumiResourceType: String

replicationInstanceArn

val replicationInstanceArn: Output<String>

The Amazon Resource Name (ARN) of the replication instance.

replicationTaskArn

val replicationTaskArn: Output<String>

The Amazon Resource Name (ARN) for the replication task.

replicationTaskId

val replicationTaskId: Output<String>

The replication task identifier.

replicationTaskSettings

val replicationTaskSettings: Output<String>?

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.

sourceEndpointArn

val sourceEndpointArn: Output<String>

The Amazon Resource Name (ARN) string that uniquely identifies the source endpoint.

startReplicationTask

val startReplicationTask: Output<Boolean>?

Whether to run or stop the replication task.

status

val status: Output<String>

Replication Task status.

tableMappings

val tableMappings: Output<String>

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