Skip to content
AWS for Query.Farm

aws.dms.describe_replications

Example SQL Queries

SELECT * FROM
aws.dms.describe_replications;

Description

Provides details on replication progress by returning status information for one or more provisioned DMS Serverless replications.

Table Definition

Column NameColumn Data Type
filters Input Column

Filters applied to the replications.

STRUCT(
    "name" VARCHAR,
    "values" VARCHAR[]
)[]
Show child fields
filters[]
Show child fields
filters[].name

The name of the filter as specified for a Describe* or similar operation.

filters[].values[]
marker Input Column

An optional pagination token provided by a previous request. If this parameter is specified, the response includes only records beyond the marker, up to the value specified by MaxRecords. 

VARCHAR
max_records Input Column

The maximum number of records to include in the response. If more records exist than the specified MaxRecords value, a pagination token called a marker is included in the response so that the remaining results can be retrieved. 

BIGINT
_aws_profile Input Column

The AWS profile defines the AWS identity used. It can be defined via credentials or by assuming a IAM role.

STRUCT(
    "type" VARCHAR,
    "name" VARCHAR,
    "account_id" VARCHAR,
    "via_profile_name" VARCHAR,
    "assumed_role_arn" VARCHAR,
    "organization" STRUCT(
        "account_name" VARCHAR,
        "id" VARCHAR,
        "tags" STRUCT(
            "key" VARCHAR,
            "value" VARCHAR
        )[],
        "master_account" STRUCT(
            "id" VARCHAR,
            "email" VARCHAR
        ),
        "parents" STRUCT(
            "type" VARCHAR,
            "id" VARCHAR,
            "name" VARCHAR,
            "tags" STRUCT(
                "key" VARCHAR,
                "value" VARCHAR
            )[]
        )[]
    )
)
Show child fields
_aws_profile.account_id

The AWS account id

_aws_profile.assumed_role_arn

The ARN of the assumed role

_aws_profile.name

The unique name of the profile.

_aws_profile.organization

Information about this profile's membership in the AWS organization.

Show child fields
_aws_profile.organization.account_name

The name of account speciifed by the organization

_aws_profile.organization.id

The organization id

_aws_profile.organization.master_account
Show child fields
_aws_profile.organization.master_account.email

The organization master account email address

_aws_profile.organization.master_account.id

The organization master account id

_aws_profile.organization.parents[]
Show child fields
_aws_profile.organization.parents[].id

The id of the parent

_aws_profile.organization.parents[].name

The name of the parent

_aws_profile.organization.parents[].tags[]
Show child fields
_aws_profile.organization.parents[].tags[].key
_aws_profile.organization.parents[].tags[].value
_aws_profile.organization.parents[].type

The type of parent can be an organization unit or a root

_aws_profile.organization.tags[]
Show child fields
_aws_profile.organization.tags[].key
_aws_profile.organization.tags[].value
_aws_profile.type

The type of profile, either 'credentials' or 'assumed_role'

_aws_profile.via_profile_name

This IAM role for this profile is assumed by first utilizing another profile with this name to obtain credentials.

_aws_region Input Column

The AWS region to use.

VARCHAR
replications

The replication descriptions.

STRUCT(
    "replication_config_identifier" VARCHAR,
    "replication_config_arn" VARCHAR,
    "source_endpoint_arn" VARCHAR,
    "target_endpoint_arn" VARCHAR,
    "replication_type" VARCHAR,
    "status" VARCHAR,
    "provision_data" STRUCT(
        "provision_state" VARCHAR,
        "provisioned_capacity_units" BIGINT,
        "date_provisioned" TIMESTAMP_S,
        "is_new_provisioning_available" BOOLEAN,
        "date_new_provisioning_data_available" TIMESTAMP_S,
        "reason_for_new_provisioning_data" VARCHAR
    ),
    "stop_reason" VARCHAR,
    "failure_messages" VARCHAR[],
    "replication_stats" STRUCT(
        "full_load_progress_percent" BIGINT,
        "elapsed_time_millis" BIGINT,
        "tables_loaded" BIGINT,
        "tables_loading" BIGINT,
        "tables_queued" BIGINT,
        "tables_errored" BIGINT,
        "fresh_start_date" TIMESTAMP_S,
        "start_date" TIMESTAMP_S,
        "stop_date" TIMESTAMP_S,
        "full_load_start_date" TIMESTAMP_S,
        "full_load_finish_date" TIMESTAMP_S
    ),
    "start_replication_type" VARCHAR,
    "cdc_start_time" TIMESTAMP_S,
    "cdc_start_position" VARCHAR,
    "cdc_stop_position" VARCHAR,
    "recovery_checkpoint" VARCHAR,
    "replication_create_time" TIMESTAMP_S,
    "replication_update_time" TIMESTAMP_S,
    "replication_last_stop_time" TIMESTAMP_S,
    "replication_deprovision_time" TIMESTAMP_S
)[]
Show child fields
replications[]
Show child fields
replications[].cdc_start_position

Indicates the start time for a change data capture (CDC) operation. Use either CdcStartTime or CdcStartPosition to specify when you want a CDC operation to start. Specifying both values results in an error.

replications[].cdc_start_time

Indicates the start time for a change data capture (CDC) operation. Use either CdcStartTime or CdcStartPosition to specify when you want a CDC operation to start. Specifying both values results in an error.

replications[].cdc_stop_position

Indicates when you want a change data capture (CDC) operation to stop. The value can be either server time or commit time.

replications[].failure_messages[]
replications[].provision_data

Information about provisioning resources for an DMS serverless replication.

Show child fields
replications[].provision_data.date_new_provisioning_data_available

The timestamp when provisioning became available.

replications[].provision_data.date_provisioned

The timestamp when DMS provisioned replication resources.

replications[].provision_data.is_new_provisioning_available

Whether the new provisioning is available to the replication.

replications[].provision_data.provision_state

The current provisioning state

replications[].provision_data.provisioned_capacity_units

The number of capacity units the replication is using.

replications[].provision_data.reason_for_new_provisioning_data

A message describing the reason that DMS provisioned new resources for the serverless replication.

replications[].recovery_checkpoint

Indicates the last checkpoint that occurred during a change data capture (CDC) operation. You can provide this value to the CdcStartPosition parameter to start a CDC operation that begins at that checkpoint.

replications[].replication_config_arn

The Amazon Resource Name for the ReplicationConfig associated with the replication.

replications[].replication_config_identifier

The identifier for the ReplicationConfig associated with the replication.

replications[].replication_create_time

The time the serverless replication was created.

replications[].replication_deprovision_time

The timestamp when DMS will deprovision the replication.

replications[].replication_last_stop_time

The timestamp when replication was last stopped.

replications[].replication_stats

This object provides a collection of statistics about a serverless replication.

Show child fields
replications[].replication_stats.elapsed_time_millis

The elapsed time of the replication, in milliseconds.

replications[].replication_stats.fresh_start_date

The date the replication was started either with a fresh start or a target reload.

replications[].replication_stats.full_load_finish_date

The date the replication full load was finished.

replications[].replication_stats.full_load_progress_percent

The percent complete for the full load serverless replication.

replications[].replication_stats.full_load_start_date

The date the replication full load was started.

replications[].replication_stats.start_date

The date the replication is scheduled to start.

replications[].replication_stats.stop_date

The date the replication was stopped.

replications[].replication_stats.tables_errored

The number of errors that have occured for this replication.

replications[].replication_stats.tables_loaded

The number of tables loaded for this replication.

replications[].replication_stats.tables_loading

The number of tables currently loading for this replication.

replications[].replication_stats.tables_queued

The number of tables queued for this replication.

replications[].replication_type

The type of the serverless replication.

replications[].replication_update_time

The time the serverless replication was updated.

replications[].source_endpoint_arn

The Amazon Resource Name for an existing Endpoint the serverless replication uses for its data source.

replications[].start_replication_type

The replication type.

replications[].status

The current status of the serverless replication.

replications[].stop_reason

The reason the replication task was stopped. This response parameter can return one of the following values:

  • "Stop Reason NORMAL"

  • "Stop Reason RECOVERABLE_ERROR"

  • "Stop Reason FATAL_ERROR"

  • "Stop Reason FULL_LOAD_ONLY_FINISHED"

  • "Stop Reason STOPPED_AFTER_FULL_LOAD" – Full load completed, with cached changes not applied

  • "Stop Reason STOPPED_AFTER_CACHED_EVENTS" – Full load completed, with cached changes applied

  • "Stop Reason EXPRESS_LICENSE_LIMITS_REACHED"

  • "Stop Reason STOPPED_AFTER_DDL_APPLY" – User-defined stop task after DDL applied

  • "Stop Reason STOPPED_DUE_TO_LOW_MEMORY"

  • "Stop Reason STOPPED_DUE_TO_LOW_DISK"

  • "Stop Reason STOPPED_AT_SERVER_TIME" – User-defined server time for stopping task

  • "Stop Reason STOPPED_AT_COMMIT_TIME" – User-defined commit time for stopping task

  • "Stop Reason RECONFIGURATION_RESTART"

  • "Stop Reason RECYCLE_TASK"

replications[].target_endpoint_arn

The Amazon Resource Name for an existing Endpoint the serverless replication uses for its data target.