iot-journey icon indicating copy to clipboard operation
iot-journey copied to clipboard

Describe the event consumption scenarios in https://github.com/mspnp/iot-journey/blob/master/docs/08-event-processing.md

Open mabsimms opened this issue 8 years ago • 0 comments

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.

mabsimms avatar Oct 16 '15 18:10 mabsimms