Skip to content

aws.dms.describe_replication_table_statistics

Example SQL Queries

SELECT * FROM
aws.dms.describe_replication_table_statistics
WHERE
"replication_config_arn" = 'VALUE';

Description

Returns table and schema statistics for one or more provisioned replications that use a given DMS Serverless replication configuration.

Table Definition

Column NameColumn Data Type
replication_config_arn Required Input Column

The Amazon Resource Name of the replication config.

VARCHAR
filters Input Column

Filters applied to the replication table statistics.

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
replication_table_statistics

Returns table statistics on the replication, including table name, rows inserted, rows updated, and rows deleted.

STRUCT(
"schema_name" VARCHAR,
"table_name" VARCHAR,
"inserts" BIGINT,
"deletes" BIGINT,
"updates" BIGINT,
"ddls" BIGINT,
"applied_inserts" BIGINT,
"applied_deletes" BIGINT,
"applied_updates" BIGINT,
"applied_ddls" BIGINT,
"full_load_rows" BIGINT,
"full_load_condtnl_chk_failed_rows" BIGINT,
"full_load_error_rows" BIGINT,
"full_load_start_time" TIMESTAMP_S,
"full_load_end_time" TIMESTAMP_S,
"full_load_reloaded" BOOLEAN,
"last_update_time" TIMESTAMP_S,
"table_state" VARCHAR,
"validation_pending_records" BIGINT,
"validation_failed_records" BIGINT,
"validation_suspended_records" BIGINT,
"validation_state" VARCHAR,
"validation_state_details" VARCHAR
)[]
Show child fields
replication_table_statistics[]
Show child fields
replication_table_statistics[].applied_ddls

The number of data definition language (DDL) statements used to build and modify the structure of your tables applied on the target.

replication_table_statistics[].applied_deletes

The number of delete actions applied on a target table.

replication_table_statistics[].applied_inserts

The number of insert actions applied on a target table.

replication_table_statistics[].applied_updates

The number of update actions applied on a target table.

replication_table_statistics[].ddls

The data definition language (DDL) used to build and modify the structure of your tables.

replication_table_statistics[].deletes

The number of delete actions performed on a table.

replication_table_statistics[].full_load_condtnl_chk_failed_rows

The number of rows that failed conditional checks during the full load operation (valid only for migrations where DynamoDB is the target).

replication_table_statistics[].full_load_end_time

The time when the full load operation completed.

replication_table_statistics[].full_load_error_rows

The number of rows that failed to load during the full load operation (valid only for migrations where DynamoDB is the target).

replication_table_statistics[].full_load_reloaded

A value that indicates if the table was reloaded (true) or loaded as part of a new full load operation (false).

replication_table_statistics[].full_load_rows

The number of rows added during the full load operation.

replication_table_statistics[].full_load_start_time

The time when the full load operation started.

replication_table_statistics[].inserts

The number of insert actions performed on a table.

replication_table_statistics[].last_update_time

The last time a table was updated.

replication_table_statistics[].schema_name

The schema name.

replication_table_statistics[].table_name

The name of the table.

replication_table_statistics[].table_state

The state of the tables described.

Valid states: Table does not exist | Before load | Full load | Table completed | Table cancelled | Table error | Table is being reloaded

replication_table_statistics[].updates

The number of update actions performed on a table.

replication_table_statistics[].validation_failed_records

The number of records that failed validation.

replication_table_statistics[].validation_pending_records

The number of records that have yet to be validated.

replication_table_statistics[].validation_state

The validation state of the table.

This parameter can have the following values:

  • Not enabled – Validation isn't enabled for the table in the migration task.

  • Pending records – Some records in the table are waiting for validation.

  • Mismatched records – Some records in the table don't match between the source and target.

  • Suspended records – Some records in the table couldn't be validated.

  • No primary key –The table couldn't be validated because it has no primary key.

  • Table error – The table wasn't validated because it's in an error state and some data wasn't migrated.

  • Validated – All rows in the table are validated. If the table is updated, the status can change from Validated.

  • Error – The table couldn't be validated because of an unexpected error.

  • Pending validation – The table is waiting validation.

  • Preparing table – Preparing the table enabled in the migration task for validation.

  • Pending revalidation – All rows in the table are pending validation after the table was updated.

replication_table_statistics[].validation_state_details

Additional details about the state of validation.

replication_table_statistics[].validation_suspended_records

The number of records that couldn't be validated.