StreamDeliveryResource

class aws_cdk.aws_bedrockagentcore.StreamDeliveryResource(*args: Any, **kwargs)

Bases: object

A delivery target for real-time streaming of memory record lifecycle events.

Instances are created through the static factory methods, one per delivery target type, for example StreamDeliveryResource.kinesis().

See:: https://docs.aws.amazon.com/bedrock-agentcore/latest/devguide/memory-record-streaming.html
ExampleMetadata:: fixture=default infused

Example:

stream = kinesis.Stream(self, "MemoryEventStream")

memory = agentcore.Memory(self, "MemoryWithStreamDelivery",
    memory_name="memory_with_stream",
    stream_delivery_resources=[
        agentcore.StreamDeliveryResource.kinesis(stream,
            content_configurations=[agentcore.StreamDeliveryContentConfiguration(
                type=agentcore.StreamDeliveryContentType.MEMORY_RECORDS,
                # Streams complete memory record bodies, which may include sensitive data
                level=agentcore.StreamDeliveryContentLevel.FULL_CONTENT
            )
            ]
        )
    ]
)

Attributes

content_configurations: Content configurations defining what is delivered to the stream.

stream: The Kinesis Data Stream that memory record events are delivered to.

Static Methods

classmethod kinesis(stream, *, content_configurations)

Deliver memory record lifecycle events to an Amazon Kinesis Data Stream.

The memory execution role is automatically granted write permissions to the stream.

Parameters:

stream (IStream) – The Kinesis Data Stream to deliver memory record events to.
content_configurations (Sequence[Union[StreamDeliveryContentConfiguration, Dict[str, Any]]]) – Content configurations defining what to deliver to the stream. Currently exactly one configuration is supported.

Return type:

StreamDeliveryResource