StreamDeliveryResource Class
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().
Example
ts
const stream = new kinesis.Stream(this, 'MemoryEventStream');
const memory = new agentcore.Memory(this, 'MemoryWithStreamDelivery', {
memoryName: 'memory_with_stream',
streamDeliveryResources: [
agentcore.StreamDeliveryResource.kinesis(stream, {
contentConfigurations: [
{
type: agentcore.StreamDeliveryContentType.MEMORY_RECORDS,
// Streams complete memory record bodies, which may include sensitive data
level: agentcore.StreamDeliveryContentLevel.FULL_CONTENT,
},
],
}),
],
});
Properties
contentConfigurationsStreamDeliveryContentConfiguration[]content_configurationstyping.List[StreamDeliveryContentConfiguration]contentConfigurationsList<StreamDeliveryContentConfiguration>ContentConfigurationsStreamDeliveryContentConfiguration[]ContentConfigurations*[]StreamDeliveryContentConfigurationrequired#Content configurations defining what is delivered to the stream.
Methods
kinesis(stream: IStream, options: KinesisStreamDeliveryOptions): StreamDeliveryResource // chainable@staticmethod def kinesis(stream: IStream, options: KinesisStreamDeliveryOptions) -> StreamDeliveryResourcepublic static StreamDeliveryResource kinesis(IStream stream, KinesisStreamDeliveryOptions options)public static StreamDeliveryResource Kinesis(IStream stream, KinesisStreamDeliveryOptions options)func Kinesis(Stream IStream, Options KinesisStreamDeliveryOptions) StreamDeliveryResourcestatic#Deliver memory record lifecycle events to an Amazon Kinesis Data Stream.
The memory execution role is automatically granted write permissions to the stream.
2 parameters
Parameters
streamstreamstreamstreamStream— The Kinesis Data Stream to deliver memory record events to.optionsoptionsoptionsoptionsOptions— What content to deliver to the stream.