iot-journey
iot-journey copied to clipboard
Describe the event consumption scenarios in https://github.com/mspnp/iot-journey/blob/master/docs/08-event-processing.md
When processing incoming events there are three modalities:
- Processing a stream of events grouped by some arbitrary key (e.g. factory, state, etc), and performing time-window aggregates and delta functions over that subset of data
- Processing a stream of events grouped by a device, and performing time-window aggregates and delta functions over that subset of data.
- Processing a sequence of events group by a device, where each event triggers a potentially long-running business activity. May often require or involve per-device ordering semantics.
These then set the stage for implementation choices. For (3) call out the data pipeline code (and the docs). For (1) and (2), call out ASA.