Skip to content
GitHubXDiscord

EventStream

The EventStream resource allows you to manage AWS CustomerProfiles EventStreams for capturing real-time events related to customer profiles.

Create a basic EventStream with required properties and a common tag.

import AWS from "alchemy/aws/control";
const basicEventStream = await AWS.CustomerProfiles.EventStream("basicEventStream", {
DomainName: "customerDomain",
EventStreamName: "customerUpdates",
Uri: "https://example.com/event-stream",
Tags: [
{ Key: "Environment", Value: "Production" }
]
});

Configure an EventStream with additional optional properties like adopting an existing resource.

const advancedEventStream = await AWS.CustomerProfiles.EventStream("advancedEventStream", {
DomainName: "customerDomain",
EventStreamName: "customerActivity",
Uri: "https://example.com/activity-stream",
Tags: [
{ Key: "Environment", Value: "Staging" },
{ Key: "Department", Value: "Marketing" }
],
adopt: true // Adopt an existing EventStream if it already exists
});

Create an EventStream with multiple tags for better categorization and management.

const taggedEventStream = await AWS.CustomerProfiles.EventStream("taggedEventStream", {
DomainName: "customerDomain",
EventStreamName: "customerFeedback",
Uri: "https://example.com/feedback-stream",
Tags: [
{ Key: "Project", Value: "CustomerInsights" },
{ Key: "Owner", Value: "Alice" },
{ Key: "Priority", Value: "High" }
]
});

Manage EventStreams for different environments, ensuring each stream is uniquely identified.

const devEventStream = await AWS.CustomerProfiles.EventStream("devEventStream", {
DomainName: "customerDomain",
EventStreamName: "devCustomerUpdates",
Uri: "https://dev.example.com/event-stream",
Tags: [
{ Key: "Environment", Value: "Development" }
]
});
const prodEventStream = await AWS.CustomerProfiles.EventStream("prodEventStream", {
DomainName: "customerDomain",
EventStreamName: "prodCustomerUpdates",
Uri: "https://prod.example.com/event-stream",
Tags: [
{ Key: "Environment", Value: "Production" }
]
});