Amazon Technologies, Inc.

Jakub Mateusz Narloch

Mohamed Marzouk Adedoyin Mounirou

Nikita Pinski

Kunal Chopra

Nicholas Smit

Ahmed Usman Khalid

Timothy William Bray

Jamie Christopher Dool

Rishi Baldawa

Ali Baghani

Jesse Marcus Dougherty

Siva Swaroop Palli

Neha Gupta

Tristan Calderbank

Juan Jose Tam-Huang

Tim Bray

Techniques for a service provider network to communicatively couple services and/or applications in a serverless computing environment. A pipe component can configure a pipe to integrate two services by transmitting data between services and/or applications using the pipe. The pipe may also be configured to transform how a service processes an event, control timing of event transmissions using the pipe, define an event structure for an event, and/or batch events. Pipes enable an application or service to exchange data with a variety of services provided by the service provider network while controlling what type of data is generated, stored, or transmitted.

Defining event data in an event-driven architecture

Transforming data between cloud entities in an event architecture

Batching event data in an event-driven architecture

Controlling timing of event data transmissions in an event architecture

Integration of cloud entities in an event architecture

Systems and methods are described herein for a service that backs-up and stores events received at an event bus, in order to replay those backed-up events at a later time. In one example, a request to replay an event processed by an event bus may be received, for example, by a service. The event bus may process events by directing individual events to a target to perform an operation on the data. Individual event may include data and metadata indicating attributes of the data. A data object, corresponding to the event may be obtained from an event archive, which stores multiple events organized into a number of data objects according to attributes of the events. An event may be extracted from the data object and sent to the event bus to be reprocessed by the event bus and directed to the target to perform the operation on the data.

Event archiving and replay

Based on analysis of messages transmitted to a communication channel, a schema for a category of messages is generated. The schema indicates one or more data types and an ordering of instances of the data types. The schema is stored in a registry. A code artifact generated in accordance with the schema is provided to automate event processing tasks associated with the message category.

Message schema management service for heterogeneous event-driven computing environments

Growing community of inventors

Vancouver, Canada

Jakub Mateusz Narloch