Streams
Atmo can handle several different types of input. The default is an HTTP request, which is defined with type: request in a Directive handler. There is another type of input called stream which allows Atmo to listen to streaming data sources and handle messages it receives from them.
A stream handler looks like this:
1
- type: stream
2
resource: /stream
3
steps:
4
- fn: handle-message
Copied!
By default, a stream handler allows a client to connect to Atmo's webserver using a standard websocket. The resource defines the URI that the websocket handler is available on, and it uses Atmo's built-in server to expose these endpoints. Each message sent by the client over this connection is handled by executing the steps in the handler.
Streams can also come from external sources such as NATS and Kafka, which is detailed in the next section.
Last modified 10d ago
Export as PDF
Copy link