Skip to main content

streams

Creates, updates, deletes, gets or lists a streams resource.

Overview

Namestreams
TypeResource
Idaws.keyspacesstreams.streams

Fields

The following fields are returned by SELECT queries:

NameDatatypeDescription
parent_shard_idsarrayThe identifiers of parent shards that this shard evolved from, if this shard was created through resharding.
sequence_number_rangeobjectThe range of sequence numbers contained within this shard.
shard_idstringA unique identifier for this shard within the stream.

Methods

The following methods are available for this resource:

NameAccessible byRequired ParamsOptional ParamsDescription
get_streamselectregionReturns 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.
list_streamsselectregionReturns 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.

Parameters

Parameters can be passed in the WHERE clause of a query. Check the Methods section to see which parameters are required or optional for each operation.

NameDatatypeDescription
regionstringAWS region (default: us-east-1)

SELECT examples

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.

SELECT
parent_shard_ids,
sequence_number_range,
shard_id
FROM aws.keyspacesstreams.streams
WHERE region = '{{ region }}' -- required
;