create_table ¶

def create_table(
    self,
    database_name: "capo_timestream_write.types.resource_create_api_name.ResourceCreateAPIName",
    table_name: "capo_timestream_write.types.resource_create_api_name.ResourceCreateAPIName",
    *,
    config_overrides: Optional[TimestreamWriteClientConfig] = None,
    retention_properties: Optional[
        "capo_timestream_write.types.retention_properties.RetentionProperties"
    ] = None,
    tags: Optional["capo_timestream_write.types.tag_list.TagList"] = None,
    magnetic_store_write_properties: Optional[
        "capo_timestream_write.types.magnetic_store_write_properties.MagneticStoreWriteProperties"
    ] = None,
    schema: Optional["capo_timestream_write.types.schema.Schema"] = None,
) -> "capo_timestream_write.types.create_table_response.CreateTableResponse":
    """<p>Adds a new table to an existing database in your account. In an Amazon Web Services account, table names must be at least unique within each Region if they are in the same database. You might have identical table names in the same Region if the tables are in separate databases. While creating the table, you must specify the table name, database name, and the retention properties. <a href="https://docs.aws.amazon.com/timestream/latest/developerguide/ts-limits.html">Service quotas apply</a>. See <a href="https://docs.aws.amazon.com/timestream/latest/developerguide/code-samples.create-table.html">code sample</a> for details. </p>

    Args:
        database_name: <p>The name of the Timestream database.</p>
        table_name: <p>The name of the Timestream table.</p>
        retention_properties: <p>The duration for which your time-series data must be stored in the memory store and the magnetic store.</p>
        tags: <p> A list of key-value pairs to label the table. </p>
        magnetic_store_write_properties: <p>Contains properties to set on the table when enabling magnetic store writes.</p>
        schema: <p> The schema of the table. </p>

    Raises:
        capo_timestream_write.errors.access_denied_exception.AccessDeniedException: <p>You are not authorized to perform this action.</p>
        capo_timestream_write.errors.conflict_exception.ConflictException: <p>Timestream was unable to process this request because it contains resource that already exists.</p>
        capo_timestream_write.errors.internal_server_exception.InternalServerException: <p> Timestream was unable to fully process this request because of an internal server error.</p>
        capo_timestream_write.errors.invalid_endpoint_exception.InvalidEndpointException: <p>The requested endpoint was not valid.</p>
        capo_timestream_write.errors.resource_not_found_exception.ResourceNotFoundException: <p>The operation tried to access a nonexistent resource. The resource might not be specified correctly, or its status might not be ACTIVE.</p>
        capo_timestream_write.errors.service_quota_exceeded_exception.ServiceQuotaExceededException: <p> The instance quota of resource exceeded for this account.</p>
        capo_timestream_write.errors.throttling_exception.ThrottlingException: <p> Too many requests were made by a user and they exceeded the service quotas. The request was throttled.</p>
        capo_timestream_write.errors.validation_exception.ValidationException: <p> An invalid or malformed request.</p>
        capo_timestream_write.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    def _handler(
        req: "OperationRequest[capo_timestream_write.types.create_table_request.CreateTableRequest]",
    ) -> OperationResponse[
        "capo_timestream_write.types.create_table_response.CreateTableResponse"
    ]:
        import capo_timestream_write._operations.timestream_20181101.create_table

        output, http_response = (
            capo_timestream_write._operations.timestream_20181101.create_table.create_table(
                req.options, req.input
            )
        )
        return OperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("CreateTable")
    )
    input_: capo_timestream_write.types.create_table_request.CreateTableRequest = {
        "database_name": database_name,
        "table_name": table_name,
    }
    if retention_properties is not None:
        input_["retention_properties"] = retention_properties
    if tags is not None:
        input_["tags"] = tags
    if magnetic_store_write_properties is not None:
        input_["magnetic_store_write_properties"] = magnetic_store_write_properties
    if schema is not None:
        input_["schema"] = schema

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