KeyspacesStreams **************** Client ====== class KeyspacesStreams.Client A low-level client representing Amazon Keyspaces Streams Amazon Keyspaces (for Apache Cassandra) change data capture (CDC) records change events for Amazon Keyspaces tables. The change events captured in a stream are time-ordered and de-duplicated write operations. Using stream data you can build event driven applications that incorporate near-real time change events from Amazon Keyspaces tables. Amazon Keyspaces CDC is serverless and scales the infrastructure for change events automatically based on the volume of changes on your table. This API reference describes the Amazon Keyspaces CDC stream API in detail. For more information about Amazon Keyspaces CDC, see Working with change data capture (CDC) streams in Amazon Keyspaces in the *Amazon Keyspaces Developer Guide*. To learn how Amazon Keyspaces CDC API actions are recorded with CloudTrail, see Amazon Keyspaces information in CloudTrail in the *Amazon Keyspaces Developer Guide*. To see the metrics Amazon Keyspaces CDC sends to Amazon CloudWatch, see Amazon Keyspaces change data capture (CDC) CloudWatch metrics in the *Amazon Keyspaces Developer Guide*. import boto3 client = boto3.client('keyspacesstreams') These are the available methods: * can_paginate * close * get_paginator * get_records * get_shard_iterator * get_stream * get_waiter * list_streams Paginators ========== Paginators are available on a client instance via the "get_paginator" method. For more detailed instructions and examples on the usage of paginators, see the paginators user guide. The available paginators are: * GetStream * ListStreams KeyspacesStreams / Paginator / ListStreams ListStreams *********** class KeyspacesStreams.Paginator.ListStreams paginator = client.get_paginator('list_streams') paginate(**kwargs) Creates an iterator that will paginate through responses from "KeyspacesStreams.Client.list_streams()". See also: AWS API Documentation **Request Syntax** response_iterator = paginator.paginate( keyspaceName='string', tableName='string', PaginationConfig={ 'MaxItems': 123, 'PageSize': 123, 'StartingToken': 'string' } ) Parameters: * **keyspaceName** (*string*) -- The name of the keyspace for which to list streams. If specified, only streams associated with tables in this keyspace are returned. If omitted, streams from all keyspaces are included in the results. * **tableName** (*string*) -- The name of the table for which to list streams. Must be used together with "keyspaceName". If specified, only streams associated with this specific table are returned. * **PaginationConfig** (*dict*) -- A dictionary that provides parameters to control pagination. * **MaxItems** *(integer) --* The total number of items to return. If the total number of items available is more than the value specified in max-items then a "NextToken" will be provided in the output that you can use to resume pagination. * **PageSize** *(integer) --* The size of each page. * **StartingToken** *(string) --* A token to specify where to start paginating. This is the "NextToken" from a previous response. Return type: dict Returns: **Response Syntax** { 'streams': [ { 'streamArn': 'string', 'keyspaceName': 'string', 'tableName': 'string', 'streamLabel': 'string' }, ], 'NextToken': 'string' } **Response Structure** * *(dict) --* * **streams** *(list) --* An array of stream objects, each containing summary information about a stream including its ARN, status, and associated table information. This list includes all streams that match the request criteria. * *(dict) --* Represents a change data capture stream for an Amazon Keyspaces table, which enables tracking and processing of data changes. * **streamArn** *(string) --* The Amazon Resource Name (ARN) that uniquely identifies this stream. * **keyspaceName** *(string) --* The name of the keyspace containing the table associated with this stream. * **tableName** *(string) --* The name of the table associated with this stream. * **streamLabel** *(string) --* A unique identifier for this stream that can be used in stream operations. * **NextToken** *(string) --* A token to resume pagination. KeyspacesStreams / Paginator / GetStream GetStream ********* class KeyspacesStreams.Paginator.GetStream paginator = client.get_paginator('get_stream') paginate(**kwargs) Creates an iterator that will paginate through responses from "KeyspacesStreams.Client.get_stream()". See also: AWS API Documentation **Request Syntax** response_iterator = paginator.paginate( streamArn='string', shardFilter={ 'type': 'CHILD_SHARDS', 'shardId': 'string' }, PaginationConfig={ 'MaxItems': 123, 'PageSize': 123, 'StartingToken': 'string' } ) Parameters: * **streamArn** (*string*) -- **[REQUIRED]** The Amazon Resource Name (ARN) of the stream for which detailed information is requested. This uniquely identifies the specific stream you want to get information about. * **shardFilter** (*dict*) -- Optional filter criteria to apply when retrieving shards. You can filter shards based on their state or other attributes to narrow down the results returned by the "GetStream" operation. * **type** *(string) --* The type of shard filter to use, which determines how the shardId parameter is interpreted. * **shardId** *(string) --* The identifier of a specific shard used to filter results based on the specified filter type. * **PaginationConfig** (*dict*) -- A dictionary that provides parameters to control pagination. * **MaxItems** *(integer) --* The total number of items to return. If the total number of items available is more than the value specified in max-items then a "NextToken" will be provided in the output that you can use to resume pagination. * **PageSize** *(integer) --* The size of each page. * **StartingToken** *(string) --* A token to specify where to start paginating. This is the "NextToken" from a previous response. Return type: dict Returns: **Response Syntax** { 'streamArn': 'string', 'streamLabel': 'string', 'streamStatus': 'ENABLING'|'ENABLED'|'DISABLING'|'DISABLED', 'streamViewType': 'NEW_IMAGE'|'OLD_IMAGE'|'NEW_AND_OLD_IMAGES'|'KEYS_ONLY', 'creationRequestDateTime': datetime(2015, 1, 1), 'keyspaceName': 'string', 'tableName': 'string', 'shards': [ { 'shardId': 'string', 'sequenceNumberRange': { 'startingSequenceNumber': 'string', 'endingSequenceNumber': 'string' }, 'parentShardIds': [ 'string', ] }, ], 'NextToken': 'string' } **Response Structure** * *(dict) --* * **streamArn** *(string) --* The Amazon Resource Name (ARN) that uniquely identifies the stream within Amazon Keyspaces. This ARN can be used in other API operations to reference this specific stream. * **streamLabel** *(string) --* A timestamp that serves as a unique identifier for this stream, used for debugging and monitoring purposes. The stream label represents the point in time when the stream was created. * **streamStatus** *(string) --* The current status of the stream. Values can be "ENABLING", "ENABLED", "DISABLING", or "DISABLED". Operations on the stream depend on its current status. * **streamViewType** *(string) --* The format of the data records in this stream. Currently, this can be one of the following options: * "NEW_AND_OLD_IMAGES" - both versions of the row, before and after the change. This is the default. * "NEW_IMAGE" - the version of the row after the change. * "OLD_IMAGE" - the version of the row before the change. * "KEYS_ONLY" - the partition and clustering keys of the row that was changed. * **creationRequestDateTime** *(datetime) --* The date and time when the request to create this stream was issued. The value is represented in ISO 8601 format. * **keyspaceName** *(string) --* The name of the keyspace containing the table associated with this stream. The keyspace name is part of the table's hierarchical identifier in Amazon Keyspaces. * **tableName** *(string) --* The name of the table associated with this stream. The stream captures changes to rows in this Amazon Keyspaces table. * **shards** *(list) --* An array of shard objects associated with this stream. Each shard contains a subset of the stream's data records and has its own unique identifier. The collection of shards represents the complete stream data. * *(dict) --* Represents a uniquely identified group of change records within a change data capture stream for Amazon Keyspaces. * **shardId** *(string) --* A unique identifier for this shard within the stream. * **sequenceNumberRange** *(dict) --* The range of sequence numbers contained within this shard. * **startingSequenceNumber** *(string) --* The starting sequence number of the range. * **endingSequenceNumber** *(string) --* The ending sequence number of the range, which may be null for open-ended ranges. * **parentShardIds** *(list) --* The identifiers of parent shards that this shard evolved from, if this shard was created through resharding. * *(string) --* * **NextToken** *(string) --* A token to resume pagination. KeyspacesStreams / Client / get_paginator get_paginator ************* KeyspacesStreams.Client.get_paginator(operation_name) Create a paginator for an operation. Parameters: **operation_name** (*string*) -- The operation name. This is the same name as the method name on the client. For example, if the method name is "create_foo", and you'd normally invoke the operation as "client.create_foo(**kwargs)", if the "create_foo" operation can be paginated, you can use the call "client.get_paginator("create_foo")". Raises: **OperationNotPageableError** -- Raised if the operation is not pageable. You can use the "client.can_paginate" method to check if an operation is pageable. Return type: "botocore.paginate.Paginator" Returns: A paginator object. KeyspacesStreams / Client / can_paginate can_paginate ************ KeyspacesStreams.Client.can_paginate(operation_name) Check if an operation can be paginated. Parameters: **operation_name** (*string*) -- The operation name. This is the same name as the method name on the client. For example, if the method name is "create_foo", and you'd normally invoke the operation as "client.create_foo(**kwargs)", if the "create_foo" operation can be paginated, you can use the call "client.get_paginator("create_foo")". Returns: "True" if the operation can be paginated, "False" otherwise. KeyspacesStreams / Client / get_waiter get_waiter ********** KeyspacesStreams.Client.get_waiter(waiter_name) Returns an object that can wait for some condition. Parameters: **waiter_name** (*str*) -- The name of the waiter to get. See the waiters section of the service docs for a list of available waiters. Returns: The specified waiter object. Return type: "botocore.waiter.Waiter" KeyspacesStreams / Client / list_streams list_streams ************ KeyspacesStreams.Client.list_streams(**kwargs) Returns a list of all data capture streams associated with your Amazon Keyspaces account or for a specific keyspace or table. The response includes information such as stream ARNs, table associations, creation timestamps, and current status. This operation helps you discover and manage all active data streams in your Amazon Keyspaces environment. See also: AWS API Documentation **Request Syntax** response = client.list_streams( keyspaceName='string', tableName='string', maxResults=123, nextToken='string' ) Parameters: * **keyspaceName** (*string*) -- The name of the keyspace for which to list streams. If specified, only streams associated with tables in this keyspace are returned. If omitted, streams from all keyspaces are included in the results. * **tableName** (*string*) -- The name of the table for which to list streams. Must be used together with "keyspaceName". If specified, only streams associated with this specific table are returned. * **maxResults** (*integer*) -- The maximum number of streams to return in a single "ListStreams" request. Default value is 100. The minimum value is 1 and the maximum value is 100. * **nextToken** (*string*) -- An optional pagination token provided by a previous "ListStreams" operation. If this parameter is specified, the response includes only records beyond the token, up to the value specified by "maxResults". Return type: dict Returns: **Response Syntax** { 'streams': [ { 'streamArn': 'string', 'keyspaceName': 'string', 'tableName': 'string', 'streamLabel': 'string' }, ], 'nextToken': 'string' } **Response Structure** * *(dict) --* * **streams** *(list) --* An array of stream objects, each containing summary information about a stream including its ARN, status, and associated table information. This list includes all streams that match the request criteria. * *(dict) --* Represents a change data capture stream for an Amazon Keyspaces table, which enables tracking and processing of data changes. * **streamArn** *(string) --* The Amazon Resource Name (ARN) that uniquely identifies this stream. * **keyspaceName** *(string) --* The name of the keyspace containing the table associated with this stream. * **tableName** *(string) --* The name of the table associated with this stream. * **streamLabel** *(string) --* A unique identifier for this stream that can be used in stream operations. * **nextToken** *(string) --* A pagination token that can be used in a subsequent "ListStreams" request. This token is returned if the response contains more streams than can be returned in a single response based on the "MaxResults" parameter. **Exceptions** * "KeyspacesStreams.Client.exceptions.ThrottlingException" * "KeyspacesStreams.Client.exceptions.AccessDeniedException" * "KeyspacesStreams.Client.exceptions.InternalServerException" * "KeyspacesStreams.Client.exceptions.ValidationException" * "KeyspacesStreams.Client.exceptions.ResourceNotFoundException" KeyspacesStreams / Client / get_stream get_stream ********** KeyspacesStreams.Client.get_stream(**kwargs) Returns detailed information about a specific data capture stream for an Amazon Keyspaces table. The information includes the stream's Amazon Resource Name (ARN), creation time, current status, retention period, shard composition, and associated table details. This operation helps you monitor and manage the configuration of your Amazon Keyspaces data streams. See also: AWS API Documentation **Request Syntax** response = client.get_stream( streamArn='string', maxResults=123, shardFilter={ 'type': 'CHILD_SHARDS', 'shardId': 'string' }, nextToken='string' ) Parameters: * **streamArn** (*string*) -- **[REQUIRED]** The Amazon Resource Name (ARN) of the stream for which detailed information is requested. This uniquely identifies the specific stream you want to get information about. * **maxResults** (*integer*) -- The maximum number of shard objects to return in a single "GetStream" request. Default value is 100. The minimum value is 1 and the maximum value is 100. * **shardFilter** (*dict*) -- Optional filter criteria to apply when retrieving shards. You can filter shards based on their state or other attributes to narrow down the results returned by the "GetStream" operation. * **type** *(string) --* The type of shard filter to use, which determines how the shardId parameter is interpreted. * **shardId** *(string) --* The identifier of a specific shard used to filter results based on the specified filter type. * **nextToken** (*string*) -- An optional pagination token provided by a previous "GetStream" operation. If this parameter is specified, the response includes only records beyond the token, up to the value specified by "maxResults". Return type: dict Returns: **Response Syntax** { 'streamArn': 'string', 'streamLabel': 'string', 'streamStatus': 'ENABLING'|'ENABLED'|'DISABLING'|'DISABLED', 'streamViewType': 'NEW_IMAGE'|'OLD_IMAGE'|'NEW_AND_OLD_IMAGES'|'KEYS_ONLY', 'creationRequestDateTime': datetime(2015, 1, 1), 'keyspaceName': 'string', 'tableName': 'string', 'shards': [ { 'shardId': 'string', 'sequenceNumberRange': { 'startingSequenceNumber': 'string', 'endingSequenceNumber': 'string' }, 'parentShardIds': [ 'string', ] }, ], 'nextToken': 'string' } **Response Structure** * *(dict) --* * **streamArn** *(string) --* The Amazon Resource Name (ARN) that uniquely identifies the stream within Amazon Keyspaces. This ARN can be used in other API operations to reference this specific stream. * **streamLabel** *(string) --* A timestamp that serves as a unique identifier for this stream, used for debugging and monitoring purposes. The stream label represents the point in time when the stream was created. * **streamStatus** *(string) --* The current status of the stream. Values can be "ENABLING", "ENABLED", "DISABLING", or "DISABLED". Operations on the stream depend on its current status. * **streamViewType** *(string) --* The format of the data records in this stream. Currently, this can be one of the following options: * "NEW_AND_OLD_IMAGES" - both versions of the row, before and after the change. This is the default. * "NEW_IMAGE" - the version of the row after the change. * "OLD_IMAGE" - the version of the row before the change. * "KEYS_ONLY" - the partition and clustering keys of the row that was changed. * **creationRequestDateTime** *(datetime) --* The date and time when the request to create this stream was issued. The value is represented in ISO 8601 format. * **keyspaceName** *(string) --* The name of the keyspace containing the table associated with this stream. The keyspace name is part of the table's hierarchical identifier in Amazon Keyspaces. * **tableName** *(string) --* The name of the table associated with this stream. The stream captures changes to rows in this Amazon Keyspaces table. * **shards** *(list) --* An array of shard objects associated with this stream. Each shard contains a subset of the stream's data records and has its own unique identifier. The collection of shards represents the complete stream data. * *(dict) --* Represents a uniquely identified group of change records within a change data capture stream for Amazon Keyspaces. * **shardId** *(string) --* A unique identifier for this shard within the stream. * **sequenceNumberRange** *(dict) --* The range of sequence numbers contained within this shard. * **startingSequenceNumber** *(string) --* The starting sequence number of the range. * **endingSequenceNumber** *(string) --* The ending sequence number of the range, which may be null for open-ended ranges. * **parentShardIds** *(list) --* The identifiers of parent shards that this shard evolved from, if this shard was created through resharding. * *(string) --* * **nextToken** *(string) --* A pagination token that can be used in a subsequent "GetStream" request. This token is returned if the response contains more shards than can be returned in a single response. **Exceptions** * "KeyspacesStreams.Client.exceptions.ThrottlingException" * "KeyspacesStreams.Client.exceptions.AccessDeniedException" * "KeyspacesStreams.Client.exceptions.InternalServerException" * "KeyspacesStreams.Client.exceptions.ValidationException" * "KeyspacesStreams.Client.exceptions.ResourceNotFoundException" KeyspacesStreams / Client / close close ***** KeyspacesStreams.Client.close() Closes underlying endpoint connections. KeyspacesStreams / Client / get_shard_iterator get_shard_iterator ****************** KeyspacesStreams.Client.get_shard_iterator(**kwargs) Returns a shard iterator that serves as a bookmark for reading data from a specific position in an Amazon Keyspaces data stream's shard. The shard iterator specifies the shard position from which to start reading data records sequentially. You can specify whether to begin reading at the latest record, the oldest record, or at a particular sequence number within the shard. See also: AWS API Documentation **Request Syntax** response = client.get_shard_iterator( streamArn='string', shardId='string', shardIteratorType='TRIM_HORIZON'|'LATEST'|'AT_SEQUENCE_NUMBER'|'AFTER_SEQUENCE_NUMBER', sequenceNumber='string' ) Parameters: * **streamArn** (*string*) -- **[REQUIRED]** The Amazon Resource Name (ARN) of the stream for which to get the shard iterator. The ARN uniquely identifies the stream within Amazon Keyspaces. * **shardId** (*string*) -- **[REQUIRED]** The identifier of the shard within the stream. The shard ID uniquely identifies a subset of the stream's data records that you want to access. * **shardIteratorType** (*string*) -- **[REQUIRED]** Determines how the shard iterator is positioned. Must be one of the following: * "TRIM_HORIZON" - Start reading at the last untrimmed record in the shard, which is the oldest data record in the shard. * "AT_SEQUENCE_NUMBER" - Start reading exactly from the specified sequence number. * "AFTER_SEQUENCE_NUMBER" - Start reading right after the specified sequence number. * "LATEST" - Start reading just after the most recent record in the shard, so that you always read the most recent data. * **sequenceNumber** (*string*) -- The sequence number of the data record in the shard from which to start reading. Required if "ShardIteratorType" is "AT_SEQUENCE_NUMBER" or "AFTER_SEQUENCE_NUMBER". This parameter is ignored for other iterator types. Return type: dict Returns: **Response Syntax** { 'shardIterator': 'string' } **Response Structure** * *(dict) --* * **shardIterator** *(string) --* The unique identifier for the shard iterator. This value is used in the "GetRecords" operation to retrieve data records from the specified shard. Each shard iterator expires 15 minutes after it is returned to the requester. **Exceptions** * "KeyspacesStreams.Client.exceptions.ThrottlingException" * "KeyspacesStreams.Client.exceptions.AccessDeniedException" * "KeyspacesStreams.Client.exceptions.InternalServerException" * "KeyspacesStreams.Client.exceptions.ValidationException" * "KeyspacesStreams.Client.exceptions.ResourceNotFoundException" KeyspacesStreams / Client / get_records get_records *********** KeyspacesStreams.Client.get_records(**kwargs) Retrieves data records from a specified shard in an Amazon Keyspaces data stream. This operation returns a collection of data records from the shard, including the primary key columns and information about modifications made to the captured table data. Each record represents a single data modification in the Amazon Keyspaces table and includes metadata about when the change occurred. See also: AWS API Documentation **Request Syntax** response = client.get_records( shardIterator='string', maxResults=123 ) Parameters: * **shardIterator** (*string*) -- **[REQUIRED]** The unique identifier of the shard iterator. A shard iterator specifies the position in the shard from which you want to start reading data records sequentially. You obtain this value by calling the "GetShardIterator" operation. Each shard iterator is valid for 15 minutes after creation. * **maxResults** (*integer*) -- The maximum number of records to return in a single "GetRecords" request. Default value is 1000. You can specify a limit between 1 and 1000, but the actual number returned might be less than the specified maximum if the size of the data for the returned records exceeds the internal size limit. Return type: dict Returns: **Response Syntax** { 'changeRecords': [ { 'eventVersion': 'string', 'createdAt': datetime(2015, 1, 1), 'origin': 'USER'|'REPLICATION'|'TTL', 'partitionKeys': { 'string': { 'asciiT': 'string', 'bigintT': 'string', 'blobT': b'bytes', 'boolT': True|False, 'counterT': 'string', 'dateT': 'string', 'decimalT': 'string', 'doubleT': 'string', 'floatT': 'string', 'inetT': 'string', 'intT': 'string', 'listT': [ { 'value': {'... recursive ...'}, 'metadata': { 'expirationTime': 'string', 'writeTime': 'string' } }, ], 'mapT': [ { 'key': {'... recursive ...'}, 'value': {'... recursive ...'}, 'metadata': { 'expirationTime': 'string', 'writeTime': 'string' } }, ], 'setT': [ { 'value': {'... recursive ...'}, 'metadata': { 'expirationTime': 'string', 'writeTime': 'string' } }, ], 'smallintT': 'string', 'textT': 'string', 'timeT': 'string', 'timestampT': 'string', 'timeuuidT': 'string', 'tinyintT': 'string', 'tupleT': [ { 'value': {'... recursive ...'}, 'metadata': { 'expirationTime': 'string', 'writeTime': 'string' } }, ], 'uuidT': 'string', 'varcharT': 'string', 'varintT': 'string', 'udtT': { 'string': { 'value': {'... recursive ...'}, 'metadata': { 'expirationTime': 'string', 'writeTime': 'string' } } } } }, 'clusteringKeys': { 'string': { 'asciiT': 'string', 'bigintT': 'string', 'blobT': b'bytes', 'boolT': True|False, 'counterT': 'string', 'dateT': 'string', 'decimalT': 'string', 'doubleT': 'string', 'floatT': 'string', 'inetT': 'string', 'intT': 'string', 'listT': [ { 'value': {'... recursive ...'}, 'metadata': { 'expirationTime': 'string', 'writeTime': 'string' } }, ], 'mapT': [ { 'key': {'... recursive ...'}, 'value': {'... recursive ...'}, 'metadata': { 'expirationTime': 'string', 'writeTime': 'string' } }, ], 'setT': [ { 'value': {'... recursive ...'}, 'metadata': { 'expirationTime': 'string', 'writeTime': 'string' } }, ], 'smallintT': 'string', 'textT': 'string', 'timeT': 'string', 'timestampT': 'string', 'timeuuidT': 'string', 'tinyintT': 'string', 'tupleT': [ { 'value': {'... recursive ...'}, 'metadata': { 'expirationTime': 'string', 'writeTime': 'string' } }, ], 'uuidT': 'string', 'varcharT': 'string', 'varintT': 'string', 'udtT': { 'string': { 'value': {'... recursive ...'}, 'metadata': { 'expirationTime': 'string', 'writeTime': 'string' } } } } }, 'newImage': { 'valueCells': { 'string': { 'value': { 'asciiT': 'string', 'bigintT': 'string', 'blobT': b'bytes', 'boolT': True|False, 'counterT': 'string', 'dateT': 'string', 'decimalT': 'string', 'doubleT': 'string', 'floatT': 'string', 'inetT': 'string', 'intT': 'string', 'listT': [ {'... recursive ...'}, ], 'mapT': [ { 'key': {'... recursive ...'}, 'value': {'... recursive ...'}, 'metadata': { 'expirationTime': 'string', 'writeTime': 'string' } }, ], 'setT': [ {'... recursive ...'}, ], 'smallintT': 'string', 'textT': 'string', 'timeT': 'string', 'timestampT': 'string', 'timeuuidT': 'string', 'tinyintT': 'string', 'tupleT': [ {'... recursive ...'}, ], 'uuidT': 'string', 'varcharT': 'string', 'varintT': 'string', 'udtT': { 'string': {'... recursive ...'} } }, 'metadata': { 'expirationTime': 'string', 'writeTime': 'string' } } }, 'staticCells': { 'string': { 'value': { 'asciiT': 'string', 'bigintT': 'string', 'blobT': b'bytes', 'boolT': True|False, 'counterT': 'string', 'dateT': 'string', 'decimalT': 'string', 'doubleT': 'string', 'floatT': 'string', 'inetT': 'string', 'intT': 'string', 'listT': [ {'... recursive ...'}, ], 'mapT': [ { 'key': {'... recursive ...'}, 'value': {'... recursive ...'}, 'metadata': { 'expirationTime': 'string', 'writeTime': 'string' } }, ], 'setT': [ {'... recursive ...'}, ], 'smallintT': 'string', 'textT': 'string', 'timeT': 'string', 'timestampT': 'string', 'timeuuidT': 'string', 'tinyintT': 'string', 'tupleT': [ {'... recursive ...'}, ], 'uuidT': 'string', 'varcharT': 'string', 'varintT': 'string', 'udtT': { 'string': {'... recursive ...'} } }, 'metadata': { 'expirationTime': 'string', 'writeTime': 'string' } } }, 'rowMetadata': { 'expirationTime': 'string', 'writeTime': 'string' } }, 'oldImage': { 'valueCells': { 'string': { 'value': { 'asciiT': 'string', 'bigintT': 'string', 'blobT': b'bytes', 'boolT': True|False, 'counterT': 'string', 'dateT': 'string', 'decimalT': 'string', 'doubleT': 'string', 'floatT': 'string', 'inetT': 'string', 'intT': 'string', 'listT': [ {'... recursive ...'}, ], 'mapT': [ { 'key': {'... recursive ...'}, 'value': {'... recursive ...'}, 'metadata': { 'expirationTime': 'string', 'writeTime': 'string' } }, ], 'setT': [ {'... recursive ...'}, ], 'smallintT': 'string', 'textT': 'string', 'timeT': 'string', 'timestampT': 'string', 'timeuuidT': 'string', 'tinyintT': 'string', 'tupleT': [ {'... recursive ...'}, ], 'uuidT': 'string', 'varcharT': 'string', 'varintT': 'string', 'udtT': { 'string': {'... recursive ...'} } }, 'metadata': { 'expirationTime': 'string', 'writeTime': 'string' } } }, 'staticCells': { 'string': { 'value': { 'asciiT': 'string', 'bigintT': 'string', 'blobT': b'bytes', 'boolT': True|False, 'counterT': 'string', 'dateT': 'string', 'decimalT': 'string', 'doubleT': 'string', 'floatT': 'string', 'inetT': 'string', 'intT': 'string', 'listT': [ {'... recursive ...'}, ], 'mapT': [ { 'key': {'... recursive ...'}, 'value': {'... recursive ...'}, 'metadata': { 'expirationTime': 'string', 'writeTime': 'string' } }, ], 'setT': [ {'... recursive ...'}, ], 'smallintT': 'string', 'textT': 'string', 'timeT': 'string', 'timestampT': 'string', 'timeuuidT': 'string', 'tinyintT': 'string', 'tupleT': [ {'... recursive ...'}, ], 'uuidT': 'string', 'varcharT': 'string', 'varintT': 'string', 'udtT': { 'string': {'... recursive ...'} } }, 'metadata': { 'expirationTime': 'string', 'writeTime': 'string' } } }, 'rowMetadata': { 'expirationTime': 'string', 'writeTime': 'string' } }, 'sequenceNumber': 'string' }, ], 'nextShardIterator': 'string' } **Response Structure** * *(dict) --* * **changeRecords** *(list) --* An array of change data records retrieved from the specified shard. Each record represents a single data modification (insert, update, or delete) to a row in the Amazon Keyspaces table. Records include the primary key columns and information about what data was modified. * *(dict) --* Represents a change data capture record for a row in an Amazon Keyspaces table, containing both the new and old states of the row. * **eventVersion** *(string) --* The version of the record format, used to track the evolution of the record structure over time. * **createdAt** *(datetime) --* The timestamp indicating when this change data capture record was created. * **origin** *(string) --* The origin or source of this change data capture record. * **partitionKeys** *(dict) --* The partition key columns and their values for the affected row. * *(string) --* * *(dict) --* Represents the value of a cell in an Amazon Keyspaces table, supporting various data types with type-specific fields. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **asciiT** *(string) --* A value of ASCII text type, containing US-ASCII characters. * **bigintT** *(string) --* A 64-bit signed integer value. * **blobT** *(bytes) --* A binary large object (BLOB) value stored as a Base64-encoded string. * **boolT** *(boolean) --* A Boolean value, either "true" or "false". * **counterT** *(string) --* A distributed counter value that can be incremented and decremented. * **dateT** *(string) --* A date value without a time component, represented as days since epoch (January 1, 1970). * **decimalT** *(string) --* A variable-precision decimal number value. * **doubleT** *(string) --* A 64-bit double-precision floating point value. * **floatT** *(string) --* A 32-bit single-precision floating point value. * **inetT** *(string) --* An IP address value, either IPv4 or IPv6 format. * **intT** *(string) --* A 32-bit signed integer value. * **listT** *(list) --* An ordered collection of elements that can contain duplicate values. * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **value** *(dict) --* The value stored in this cell, which can be of various data types supported by Amazon Keyspaces. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **metadata** *(dict) --* Metadata associated with this cell, such as time-to-live (TTL) expiration time and write timestamp. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **mapT** *(list) --* A collection of key-value pairs where each key is unique. * *(dict) --* Represents a key-value pair within a map data type in Amazon Keyspaces, including the associated metadata. * **key** *(dict) --* The key of this map entry in the Amazon Keyspaces cell. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **value** *(dict) --* The value associated with the key in this map entry. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **metadata** *(dict) --* Metadata for this specific key-value pair within the map, such as timestamps and TTL information. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **setT** *(list) --* An unordered collection of unique elements. * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **value** *(dict) --* The value stored in this cell, which can be of various data types supported by Amazon Keyspaces. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **metadata** *(dict) --* Metadata associated with this cell, such as time-to-live (TTL) expiration time and write timestamp. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **smallintT** *(string) --* A 16-bit signed integer value. * **textT** *(string) --* A UTF-8 encoded string value. * **timeT** *(string) --* A time value without a date component, with nanosecond precision. * **timestampT** *(string) --* A timestamp value representing date and time with millisecond precision. * **timeuuidT** *(string) --* A universally unique identifier (UUID) that includes a timestamp component, ensuring both uniqueness and time ordering. * **tinyintT** *(string) --* An 8-bit signed integer value. * **tupleT** *(list) --* A fixed-length ordered list of elements, where each element can be of a different data type. * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **value** *(dict) --* The value stored in this cell, which can be of various data types supported by Amazon Keyspaces. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **metadata** *(dict) --* Metadata associated with this cell, such as time-to-live (TTL) expiration time and write timestamp. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **uuidT** *(string) --* A universally unique identifier (UUID) value. * **varcharT** *(string) --* A UTF-8 encoded string value, functionally equivalent to text type. * **varintT** *(string) --* A variable precision integer value with arbitrary length. * **udtT** *(dict) --* A user-defined type (UDT) value consisting of named fields, each with its own data type. * *(string) --* * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **value** *(dict) --* The value stored in this cell, which can be of various data types supported by Amazon Keyspaces. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **metadata** *(dict) --* Metadata associated with this cell, such as time-to-live (TTL) expiration time and write timestamp. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **clusteringKeys** *(dict) --* The clustering key columns and their values for the affected row, which determine the order of rows within a partition. * *(string) --* * *(dict) --* Represents the value of a cell in an Amazon Keyspaces table, supporting various data types with type-specific fields. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **asciiT** *(string) --* A value of ASCII text type, containing US-ASCII characters. * **bigintT** *(string) --* A 64-bit signed integer value. * **blobT** *(bytes) --* A binary large object (BLOB) value stored as a Base64-encoded string. * **boolT** *(boolean) --* A Boolean value, either "true" or "false". * **counterT** *(string) --* A distributed counter value that can be incremented and decremented. * **dateT** *(string) --* A date value without a time component, represented as days since epoch (January 1, 1970). * **decimalT** *(string) --* A variable-precision decimal number value. * **doubleT** *(string) --* A 64-bit double-precision floating point value. * **floatT** *(string) --* A 32-bit single-precision floating point value. * **inetT** *(string) --* An IP address value, either IPv4 or IPv6 format. * **intT** *(string) --* A 32-bit signed integer value. * **listT** *(list) --* An ordered collection of elements that can contain duplicate values. * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **value** *(dict) --* The value stored in this cell, which can be of various data types supported by Amazon Keyspaces. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **metadata** *(dict) --* Metadata associated with this cell, such as time-to-live (TTL) expiration time and write timestamp. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **mapT** *(list) --* A collection of key-value pairs where each key is unique. * *(dict) --* Represents a key-value pair within a map data type in Amazon Keyspaces, including the associated metadata. * **key** *(dict) --* The key of this map entry in the Amazon Keyspaces cell. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **value** *(dict) --* The value associated with the key in this map entry. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **metadata** *(dict) --* Metadata for this specific key-value pair within the map, such as timestamps and TTL information. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **setT** *(list) --* An unordered collection of unique elements. * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **value** *(dict) --* The value stored in this cell, which can be of various data types supported by Amazon Keyspaces. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **metadata** *(dict) --* Metadata associated with this cell, such as time-to-live (TTL) expiration time and write timestamp. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **smallintT** *(string) --* A 16-bit signed integer value. * **textT** *(string) --* A UTF-8 encoded string value. * **timeT** *(string) --* A time value without a date component, with nanosecond precision. * **timestampT** *(string) --* A timestamp value representing date and time with millisecond precision. * **timeuuidT** *(string) --* A universally unique identifier (UUID) that includes a timestamp component, ensuring both uniqueness and time ordering. * **tinyintT** *(string) --* An 8-bit signed integer value. * **tupleT** *(list) --* A fixed-length ordered list of elements, where each element can be of a different data type. * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **value** *(dict) --* The value stored in this cell, which can be of various data types supported by Amazon Keyspaces. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **metadata** *(dict) --* Metadata associated with this cell, such as time-to-live (TTL) expiration time and write timestamp. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **uuidT** *(string) --* A universally unique identifier (UUID) value. * **varcharT** *(string) --* A UTF-8 encoded string value, functionally equivalent to text type. * **varintT** *(string) --* A variable precision integer value with arbitrary length. * **udtT** *(dict) --* A user-defined type (UDT) value consisting of named fields, each with its own data type. * *(string) --* * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **value** *(dict) --* The value stored in this cell, which can be of various data types supported by Amazon Keyspaces. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **metadata** *(dict) --* Metadata associated with this cell, such as time-to-live (TTL) expiration time and write timestamp. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **newImage** *(dict) --* The state of the row after the change operation that generated this record. * **valueCells** *(dict) --* A map of regular (non-static) column cells in the row, where keys are column names and values are the corresponding cells. * *(string) --* * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **value** *(dict) --* The value stored in this cell, which can be of various data types supported by Amazon Keyspaces. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **asciiT** *(string) --* A value of ASCII text type, containing US- ASCII characters. * **bigintT** *(string) --* A 64-bit signed integer value. * **blobT** *(bytes) --* A binary large object (BLOB) value stored as a Base64-encoded string. * **boolT** *(boolean) --* A Boolean value, either "true" or "false". * **counterT** *(string) --* A distributed counter value that can be incremented and decremented. * **dateT** *(string) --* A date value without a time component, represented as days since epoch (January 1, 1970). * **decimalT** *(string) --* A variable-precision decimal number value. * **doubleT** *(string) --* A 64-bit double-precision floating point value. * **floatT** *(string) --* A 32-bit single-precision floating point value. * **inetT** *(string) --* An IP address value, either IPv4 or IPv6 format. * **intT** *(string) --* A 32-bit signed integer value. * **listT** *(list) --* An ordered collection of elements that can contain duplicate values. * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **mapT** *(list) --* A collection of key-value pairs where each key is unique. * *(dict) --* Represents a key-value pair within a map data type in Amazon Keyspaces, including the associated metadata. * **key** *(dict) --* The key of this map entry in the Amazon Keyspaces cell. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **value** *(dict) --* The value associated with the key in this map entry. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **metadata** *(dict) --* Metadata for this specific key-value pair within the map, such as timestamps and TTL information. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **setT** *(list) --* An unordered collection of unique elements. * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **smallintT** *(string) --* A 16-bit signed integer value. * **textT** *(string) --* A UTF-8 encoded string value. * **timeT** *(string) --* A time value without a date component, with nanosecond precision. * **timestampT** *(string) --* A timestamp value representing date and time with millisecond precision. * **timeuuidT** *(string) --* A universally unique identifier (UUID) that includes a timestamp component, ensuring both uniqueness and time ordering. * **tinyintT** *(string) --* An 8-bit signed integer value. * **tupleT** *(list) --* A fixed-length ordered list of elements, where each element can be of a different data type. * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **uuidT** *(string) --* A universally unique identifier (UUID) value. * **varcharT** *(string) --* A UTF-8 encoded string value, functionally equivalent to text type. * **varintT** *(string) --* A variable precision integer value with arbitrary length. * **udtT** *(dict) --* A user-defined type (UDT) value consisting of named fields, each with its own data type. * *(string) --* * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **metadata** *(dict) --* Metadata associated with this cell, such as time-to-live (TTL) expiration time and write timestamp. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **staticCells** *(dict) --* A map of static column cells shared by all rows with the same partition key, where keys are column names and values are the corresponding cells. * *(string) --* * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **value** *(dict) --* The value stored in this cell, which can be of various data types supported by Amazon Keyspaces. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **asciiT** *(string) --* A value of ASCII text type, containing US- ASCII characters. * **bigintT** *(string) --* A 64-bit signed integer value. * **blobT** *(bytes) --* A binary large object (BLOB) value stored as a Base64-encoded string. * **boolT** *(boolean) --* A Boolean value, either "true" or "false". * **counterT** *(string) --* A distributed counter value that can be incremented and decremented. * **dateT** *(string) --* A date value without a time component, represented as days since epoch (January 1, 1970). * **decimalT** *(string) --* A variable-precision decimal number value. * **doubleT** *(string) --* A 64-bit double-precision floating point value. * **floatT** *(string) --* A 32-bit single-precision floating point value. * **inetT** *(string) --* An IP address value, either IPv4 or IPv6 format. * **intT** *(string) --* A 32-bit signed integer value. * **listT** *(list) --* An ordered collection of elements that can contain duplicate values. * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **mapT** *(list) --* A collection of key-value pairs where each key is unique. * *(dict) --* Represents a key-value pair within a map data type in Amazon Keyspaces, including the associated metadata. * **key** *(dict) --* The key of this map entry in the Amazon Keyspaces cell. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **value** *(dict) --* The value associated with the key in this map entry. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **metadata** *(dict) --* Metadata for this specific key-value pair within the map, such as timestamps and TTL information. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **setT** *(list) --* An unordered collection of unique elements. * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **smallintT** *(string) --* A 16-bit signed integer value. * **textT** *(string) --* A UTF-8 encoded string value. * **timeT** *(string) --* A time value without a date component, with nanosecond precision. * **timestampT** *(string) --* A timestamp value representing date and time with millisecond precision. * **timeuuidT** *(string) --* A universally unique identifier (UUID) that includes a timestamp component, ensuring both uniqueness and time ordering. * **tinyintT** *(string) --* An 8-bit signed integer value. * **tupleT** *(list) --* A fixed-length ordered list of elements, where each element can be of a different data type. * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **uuidT** *(string) --* A universally unique identifier (UUID) value. * **varcharT** *(string) --* A UTF-8 encoded string value, functionally equivalent to text type. * **varintT** *(string) --* A variable precision integer value with arbitrary length. * **udtT** *(dict) --* A user-defined type (UDT) value consisting of named fields, each with its own data type. * *(string) --* * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **metadata** *(dict) --* Metadata associated with this cell, such as time-to-live (TTL) expiration time and write timestamp. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **rowMetadata** *(dict) --* Metadata that applies to the entire row, such as timestamps and TTL information. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **oldImage** *(dict) --* The state of the row before the change operation that generated this record. * **valueCells** *(dict) --* A map of regular (non-static) column cells in the row, where keys are column names and values are the corresponding cells. * *(string) --* * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **value** *(dict) --* The value stored in this cell, which can be of various data types supported by Amazon Keyspaces. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **asciiT** *(string) --* A value of ASCII text type, containing US- ASCII characters. * **bigintT** *(string) --* A 64-bit signed integer value. * **blobT** *(bytes) --* A binary large object (BLOB) value stored as a Base64-encoded string. * **boolT** *(boolean) --* A Boolean value, either "true" or "false". * **counterT** *(string) --* A distributed counter value that can be incremented and decremented. * **dateT** *(string) --* A date value without a time component, represented as days since epoch (January 1, 1970). * **decimalT** *(string) --* A variable-precision decimal number value. * **doubleT** *(string) --* A 64-bit double-precision floating point value. * **floatT** *(string) --* A 32-bit single-precision floating point value. * **inetT** *(string) --* An IP address value, either IPv4 or IPv6 format. * **intT** *(string) --* A 32-bit signed integer value. * **listT** *(list) --* An ordered collection of elements that can contain duplicate values. * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **mapT** *(list) --* A collection of key-value pairs where each key is unique. * *(dict) --* Represents a key-value pair within a map data type in Amazon Keyspaces, including the associated metadata. * **key** *(dict) --* The key of this map entry in the Amazon Keyspaces cell. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **value** *(dict) --* The value associated with the key in this map entry. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **metadata** *(dict) --* Metadata for this specific key-value pair within the map, such as timestamps and TTL information. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **setT** *(list) --* An unordered collection of unique elements. * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **smallintT** *(string) --* A 16-bit signed integer value. * **textT** *(string) --* A UTF-8 encoded string value. * **timeT** *(string) --* A time value without a date component, with nanosecond precision. * **timestampT** *(string) --* A timestamp value representing date and time with millisecond precision. * **timeuuidT** *(string) --* A universally unique identifier (UUID) that includes a timestamp component, ensuring both uniqueness and time ordering. * **tinyintT** *(string) --* An 8-bit signed integer value. * **tupleT** *(list) --* A fixed-length ordered list of elements, where each element can be of a different data type. * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **uuidT** *(string) --* A universally unique identifier (UUID) value. * **varcharT** *(string) --* A UTF-8 encoded string value, functionally equivalent to text type. * **varintT** *(string) --* A variable precision integer value with arbitrary length. * **udtT** *(dict) --* A user-defined type (UDT) value consisting of named fields, each with its own data type. * *(string) --* * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **metadata** *(dict) --* Metadata associated with this cell, such as time-to-live (TTL) expiration time and write timestamp. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **staticCells** *(dict) --* A map of static column cells shared by all rows with the same partition key, where keys are column names and values are the corresponding cells. * *(string) --* * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **value** *(dict) --* The value stored in this cell, which can be of various data types supported by Amazon Keyspaces. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **asciiT** *(string) --* A value of ASCII text type, containing US- ASCII characters. * **bigintT** *(string) --* A 64-bit signed integer value. * **blobT** *(bytes) --* A binary large object (BLOB) value stored as a Base64-encoded string. * **boolT** *(boolean) --* A Boolean value, either "true" or "false". * **counterT** *(string) --* A distributed counter value that can be incremented and decremented. * **dateT** *(string) --* A date value without a time component, represented as days since epoch (January 1, 1970). * **decimalT** *(string) --* A variable-precision decimal number value. * **doubleT** *(string) --* A 64-bit double-precision floating point value. * **floatT** *(string) --* A 32-bit single-precision floating point value. * **inetT** *(string) --* An IP address value, either IPv4 or IPv6 format. * **intT** *(string) --* A 32-bit signed integer value. * **listT** *(list) --* An ordered collection of elements that can contain duplicate values. * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **mapT** *(list) --* A collection of key-value pairs where each key is unique. * *(dict) --* Represents a key-value pair within a map data type in Amazon Keyspaces, including the associated metadata. * **key** *(dict) --* The key of this map entry in the Amazon Keyspaces cell. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **value** *(dict) --* The value associated with the key in this map entry. Note: This is a Tagged Union structure. Only one of the following top level keys will be set: "asciiT", "bigintT", "blobT", "boolT", "counterT", "dateT", "decimalT", "doubleT", "floatT", "inetT", "intT", "listT", "mapT", "setT", "smallintT", "textT", "timeT", "timestampT", "timeuuidT", "tinyintT", "tupleT", "uuidT", "varcharT", "varintT", "udtT". If a client receives an unknown member it will set "SDK_UNKNOWN_MEMBER" as the top level key, which maps to the name or tag of the unknown member. The structure of "SDK_UNKNOWN_MEMBER" is as follows: 'SDK_UNKNOWN_MEMBER': {'name': 'UnknownMemberName'} * **metadata** *(dict) --* Metadata for this specific key-value pair within the map, such as timestamps and TTL information. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **setT** *(list) --* An unordered collection of unique elements. * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **smallintT** *(string) --* A 16-bit signed integer value. * **textT** *(string) --* A UTF-8 encoded string value. * **timeT** *(string) --* A time value without a date component, with nanosecond precision. * **timestampT** *(string) --* A timestamp value representing date and time with millisecond precision. * **timeuuidT** *(string) --* A universally unique identifier (UUID) that includes a timestamp component, ensuring both uniqueness and time ordering. * **tinyintT** *(string) --* An 8-bit signed integer value. * **tupleT** *(list) --* A fixed-length ordered list of elements, where each element can be of a different data type. * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **uuidT** *(string) --* A universally unique identifier (UUID) value. * **varcharT** *(string) --* A UTF-8 encoded string value, functionally equivalent to text type. * **varintT** *(string) --* A variable precision integer value with arbitrary length. * **udtT** *(dict) --* A user-defined type (UDT) value consisting of named fields, each with its own data type. * *(string) --* * *(dict) --* Represents a cell in an Amazon Keyspaces table, containing both the value and metadata about the cell. * **metadata** *(dict) --* Metadata associated with this cell, such as time-to-live (TTL) expiration time and write timestamp. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **rowMetadata** *(dict) --* Metadata that applies to the entire row, such as timestamps and TTL information. * **expirationTime** *(string) --* The time at which the associated data will expire, based on the time-to-live (TTL) setting. * **writeTime** *(string) --* The timestamp at which the associated data was written to the database. * **sequenceNumber** *(string) --* A unique identifier assigned to this record within the shard, used for ordering and tracking purposes. * **nextShardIterator** *(string) --* The next position in the shard from which to start sequentially reading data records. If null, the shard has been closed and the requested iterator doesn't return any more data. **Exceptions** * "KeyspacesStreams.Client.exceptions.ThrottlingException" * "KeyspacesStreams.Client.exceptions.AccessDeniedException" * "KeyspacesStreams.Client.exceptions.InternalServerException" * "KeyspacesStreams.Client.exceptions.ValidationException" * "KeyspacesStreams.Client.exceptions.ResourceNotFoundException"