export_table_to_point_in_time async ¶

async def export_table_to_point_in_time(
    self,
    table_arn: "capo_dynamodb.types.table_arn.TableArn",
    s3_bucket: "capo_dynamodb.types.s3_bucket.S3Bucket",
    *,
    config_overrides: Optional[AsyncDynamoDBClientConfig] = None,
    export_time: Optional["capo_dynamodb.types.export_time.ExportTime"] = None,
    client_token: Optional["capo_dynamodb.types.client_token.ClientToken"] = None,
    s3_bucket_owner: Optional[
        "capo_dynamodb.types.s3_bucket_owner.S3BucketOwner"
    ] = None,
    s3_prefix: Optional["capo_dynamodb.types.s3_prefix.S3Prefix"] = None,
    s3_sse_algorithm: Optional[
        "capo_dynamodb.types.s3_sse_algorithm.S3SseAlgorithm"
    ] = None,
    s3_sse_kms_key_id: Optional[
        "capo_dynamodb.types.s3_sse_kms_key_id.S3SseKmsKeyId"
    ] = None,
    export_format: Optional[
        "capo_dynamodb.types.export_format.ExportFormat"
    ] = None,
    export_type: Optional["capo_dynamodb.types.export_type.ExportType"] = None,
    incremental_export_specification: Optional[
        "capo_dynamodb.types.incremental_export_specification.IncrementalExportSpecification"
    ] = None,
    filter_specification: Optional[
        "capo_dynamodb.types.filter_specification.FilterSpecification"
    ] = None,
) -> "capo_dynamodb.types.export_table_to_point_in_time_output.ExportTableToPointInTimeOutput":
    """<p>Exports table data to an S3 bucket. The table must have point in time recovery enabled, and you can export data from any time within the point in time recovery window.</p>

    Args:
        table_arn: <p>The Amazon Resource Name (ARN) associated with the table to export.</p>
        export_time: <p>Time in the past from which to export table data, counted in seconds from the start of the Unix epoch. The table export will be a snapshot of the table's state at this point in time.</p>
        client_token: <p>Providing a <code>ClientToken</code> makes the call to <code>ExportTableToPointInTimeInput</code> idempotent, meaning that multiple identical calls have the same effect as one single call.</p> <p>A client token is valid for 8 hours after the first request that uses it is completed. After 8 hours, any request with the same client token is treated as a new request. Do not resubmit the same request with the same client token for more than 8 hours, or the result might not be idempotent.</p> <p>If you submit a request with the same client token but a change in other parameters within the 8-hour idempotency window, DynamoDB returns an <code>ExportConflictException</code>.</p>
        s3_bucket: <p>The name of the Amazon S3 bucket to export the snapshot to.</p>
        s3_bucket_owner: <p>The ID of the Amazon Web Services account that owns the bucket the export will be stored in.</p> <note> <p>S3BucketOwner is a required parameter when exporting to a S3 bucket in another account.</p> </note>
        s3_prefix: <p>The Amazon S3 bucket prefix to use as the file name and path of the exported snapshot.</p>
        s3_sse_algorithm: <p>Type of encryption used on the bucket where export data will be stored. Valid values for <code>S3SseAlgorithm</code> are:</p> <ul> <li> <p> <code>AES256</code> - server-side encryption with Amazon S3 managed keys</p> </li> <li> <p> <code>KMS</code> - server-side encryption with KMS managed keys</p> </li> </ul>
        s3_sse_kms_key_id: <p>The ID of the KMS managed key used to encrypt the S3 bucket where export data will be stored (if applicable).</p>
        export_format: <p>The format for the exported data. Valid values for <code>ExportFormat</code> are <code>DYNAMODB_JSON</code> or <code>ION</code>.</p>
        export_type: <p>Choice of whether to execute as a full export or incremental export. Valid values are FULL_EXPORT or INCREMENTAL_EXPORT. The default value is FULL_EXPORT. If INCREMENTAL_EXPORT is provided, the IncrementalExportSpecification must also be used.</p>
        incremental_export_specification: <p>Optional object containing the parameters specific to an incremental export.</p>
        filter_specification: <p>The criteria used to filter which items are included in the point-in-time export. When you specify this parameter, only items that match the key conditions and filter expressions are exported.</p>

    Raises:
        capo_dynamodb.errors.export_conflict_exception.ExportConflictException: <p>There was a conflict when writing to the specified S3 bucket.</p>
        capo_dynamodb.errors.internal_server_error.InternalServerError: <p>An error occurred on the server side.</p>
        capo_dynamodb.errors.invalid_export_time_exception.InvalidExportTimeException: <p>The specified <code>ExportTime</code> is outside of the point in time recovery window.</p>
        capo_dynamodb.errors.limit_exceeded_exception.LimitExceededException: <p>There is no limit to the number of daily on-demand backups that can be taken. </p> <p>For most purposes, up to 500 simultaneous table operations are allowed per account. These operations include <code>CreateTable</code>, <code>UpdateTable</code>, <code>DeleteTable</code>,<code>UpdateTimeToLive</code>, <code>RestoreTableFromBackup</code>, and <code>RestoreTableToPointInTime</code>. </p> <p>When you are creating a table with one or more secondary indexes, you can have up to 250 such requests running at a time. However, if the table or index specifications are complex, then DynamoDB might temporarily reduce the number of concurrent operations.</p> <p>When importing into DynamoDB, up to 50 simultaneous import table operations are allowed per account.</p> <p>There is a soft account quota of 2,500 tables.</p> <p>GetRecords was called with a value of more than 1000 for the limit request parameter.</p> <p>More than 2 processes are reading from the same streams shard at the same time. Exceeding this limit may result in request throttling.</p>
        capo_dynamodb.errors.point_in_time_recovery_unavailable_exception.PointInTimeRecoveryUnavailableException: <p>Point in time recovery has not yet been enabled for this source table.</p>
        capo_dynamodb.errors.table_not_found_exception.TableNotFoundException: <p>A source table with the name <code>TableName</code> does not currently exist within the subscriber's account or the subscriber is operating in the wrong Amazon Web Services Region.</p>
        capo_dynamodb.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_dynamodb.types.export_table_to_point_in_time_input.ExportTableToPointInTimeInput]",
    ) -> AsyncOperationResponse[
        "capo_dynamodb.types.export_table_to_point_in_time_output.ExportTableToPointInTimeOutput"
    ]:
        import capo_dynamodb._operations.dynamo_db_20120810.export_table_to_point_in_time

        (
            output,
            http_response,
        ) = await capo_dynamodb._operations.dynamo_db_20120810.export_table_to_point_in_time.async_export_table_to_point_in_time(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("ExportTableToPointInTime")
    )
    input_: capo_dynamodb.types.export_table_to_point_in_time_input.ExportTableToPointInTimeInput = {
        "table_arn": table_arn,
        "s3_bucket": s3_bucket,
    }
    if export_time is not None:
        input_["export_time"] = export_time
    if client_token is None:
        client_token = str(uuid.uuid4())
    input_["client_token"] = client_token
    if s3_bucket_owner is not None:
        input_["s3_bucket_owner"] = s3_bucket_owner
    if s3_prefix is not None:
        input_["s3_prefix"] = s3_prefix
    if s3_sse_algorithm is not None:
        input_["s3_sse_algorithm"] = s3_sse_algorithm
    if s3_sse_kms_key_id is not None:
        input_["s3_sse_kms_key_id"] = s3_sse_kms_key_id
    if export_format is not None:
        input_["export_format"] = export_format
    if export_type is not None:
        input_["export_type"] = export_type
    if incremental_export_specification is not None:
        input_["incremental_export_specification"] = (
            incremental_export_specification
        )
    if filter_specification is not None:
        input_["filter_specification"] = filter_specification

    response = await aexecute_pipeline(
        AsyncOperationRequest(input=input_, options=options_),
        handler=_handler,
        interceptors=list(interceptors_),
    )
    await response.response.aclose()
    return response.output