refresh_schemas ¶

def refresh_schemas(
    self,
    endpoint_arn: "capo_database_migration_service.types.string.String",
    replication_instance_arn: "capo_database_migration_service.types.string.String",
    *,
    config_overrides: Optional[DatabaseMigrationServiceClientConfig] = None,
) -> "capo_database_migration_service.types.refresh_schemas_response.RefreshSchemasResponse":
    """<p>Populates the schema for the specified endpoint. This is an asynchronous operation and can take several minutes. You can check the status of this operation by calling the DescribeRefreshSchemasStatus operation.</p>

    Args:
        endpoint_arn: <p>The Amazon Resource Name (ARN) string that uniquely identifies the endpoint.</p>
        replication_instance_arn: <p>The Amazon Resource Name (ARN) of the replication instance.</p>

    Raises:
        capo_database_migration_service.errors.invalid_resource_state_fault.InvalidResourceStateFault: <p>The resource is in a state that prevents it from being used for database migration.</p>
        capo_database_migration_service.errors.kms_key_not_accessible_fault.KMSKeyNotAccessibleFault: <p>DMS cannot access the KMS key.</p>
        capo_database_migration_service.errors.resource_not_found_fault.ResourceNotFoundFault: <p>The resource could not be found.</p>
        capo_database_migration_service.errors.resource_quota_exceeded_fault.ResourceQuotaExceededFault: <p>The quota for this resource quota has been exceeded.</p>
        capo_database_migration_service.errors.UnknownServiceError: The service returned an error code this client does not model.

    Examples:
        Refresh schema
        Populates the schema for the specified endpoint. This is an asynchronous operation and can take several minutes. You can check the status of this operation by calling the describe-refresh-schemas-status operation.

        >>> client.refresh_schemas(endpoint_arn='', replication_instance_arn='')
    """

    def _handler(
        req: "OperationRequest[capo_database_migration_service.types.refresh_schemas_message.RefreshSchemasMessage]",
    ) -> OperationResponse[
        "capo_database_migration_service.types.refresh_schemas_response.RefreshSchemasResponse"
    ]:
        import capo_database_migration_service._operations.amazon_dm_sv20160101.refresh_schemas

        output, http_response = (
            capo_database_migration_service._operations.amazon_dm_sv20160101.refresh_schemas.refresh_schemas(
                req.options, req.input
            )
        )
        return OperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("RefreshSchemas")
    )
    input_: capo_database_migration_service.types.refresh_schemas_message.RefreshSchemasMessage = {
        "endpoint_arn": endpoint_arn,
        "replication_instance_arn": replication_instance_arn,
    }

    response = execute_pipeline(
        OperationRequest(input=input_, options=options_),
        handler=_handler,
        interceptors=list(interceptors_),
    )
    response.response.close()
    return response.output