Serverless WebSocket API: API Gateway, Kinesis, Lambda
Nowadays, it is a common approach to use a RESTful API following the synchronous request/response model. But what about asynchronous communication? Or communication that is synchronous but could be modeled asynchronous as well? A WebSocket API based on API Gateway, Kinesis, and Lambda is the perfect tool for that job.
AWS announced WebSocket support for the API Gateway in December 2018. Recently CloudFormation added support for the new resources as well. Therefore, it is about time to discover how to build an event-driven API based on the following building blocks:
- An API Gateway providing the WebSocket API
- A Kinesis Stream to buffer and distribute events
- Several Lambda Functions implementing event-driven microservices
The following figure illustrated the architecture.
What are the unique features of this architecture?
- Low latency: The API Gateway forwards incoming events to the Kinesis Stream. No Lambda Function needed, which decreases costs and latency.
- High Decoupling: Each microservice subscribes to the Kinesis Stream to process events from the client. A microservice is able to send events to a client by posting a message to the WebSocket via the API Gateway.
- Fault Tolerant: The Kinesis Stream acts as a buffer for incoming events. In case of a failure within one of the micro-services events are not lost.
- Asynchronous But Real-Time: Events are processed asynchronously but with minimal latency. The bidirectional model offered by the WebSocket allows sending response events to the client easily.
- Ordered: The order of events is guaranteed from the client to the microservice.
In the following, you will learn how to set up the described architecture with the help of CloudFormation.
First of all, create the API as well as the default route.
In theory, the
RouteSelectionExpression in combination with an
AWS::ApiGatewayV2::Route allows you to route incoming events to different targets. For example, you could split events into different Kinesis Streams. Doing so is not necessary, and therefore all events are routed to the
DefaultRoute route in this example.
The default route sends all events to the
KinesisIntegration. The integration calls the
PutRecord action on the Kinesis Stream for each incoming event. The
default template defined in
RequestTemplates assembles the needed request. Note, the
connectionId - which can be used to send an event back to the client - is added to each event.
Hej, Andreas & Michael here!
We launched the cloudonaut blog in 2015. Since then, we have published 325 articles: small tips and tricks, best practices, and service reviews. We enjoy writing about all things AWS a lot.
Do you like our blog posts and podcast episodes? Have you learned something new? Consider supporting us create in-depth and independent AWS content. Please help us with a monthly or one-time payment through GitHub Sponsors.Start supporting us today!
What else is needed to set up the API Gateway? You need to define a stage and a deployment.
Next, create a Kinesis Stream to buffer events.
The WebSocket API, as well as the Kinesis Stream, are ready to receive events.
In order to process the events, a microservice needs to be attached to the Kinesis Stream. The following snippet shows how to create the necessary resources:
EventStreamConsumerregisters an HTTP/2 based consumer at the Kinesis Stream.
EventSourceMappingthe source mapping connecting the consumer with the Lambda Function.
StreamFunctionthe Lambda Function implementing a microservice processing events from the stream.
The following implementation of the
StreamFunction sends back each incoming event to its sender.
I’ve skipped a few resources, mainly IAM roles. You can find the whole CloudFormation template at api-gateway-websocket.yaml. Use the following command to create a CloudFormation stack based on the template:
aws cloudformation deploy --template-file apigateway-websocket.yaml --stack-name apigateway-websocket --capabilities CAPABILITY_IAM
Get the WebSocket URI from the CloudFormation stack.
aws cloudformation describe-stacks --stack-name apigateway-websocket --query 'Stacks.Outputs[?OutputKey==`WebSocketURI`].OutputValue' --output text
Use wscat to send events to your WebSocket API. The API will return the event immediately.
wscat -c wss://f124m4srw3.execute-api.eu-west-1.amazonaws.com/v1
That’s it. Building a WebSocket API with an API Gateway, a Kinesis Stream and Lambda Functions is a great approach when developing a real-time and event-driven API.
Do you want to learn more about cutting-edge architectures on AWS? Join Michael and me for our session Cutting-Edge Architectures Based on AppSync, Lambda, and Fargate on February 26th at the AWS Summit in Berlin. Also, if you stumble upon Michael or me during the summit, please say “Hi!”.