We are developing an IoT cloud platform with known components like Cloud Gateway, Stream Processing, Device Shadowing, etc...
The question is what is the proper sequence of locating pre-validation of incoming device data (maybe there is no need to do this first!) and updating device shadow.
And could you give me some advice what is the best path of data from the creation to completion.
- Cloud gateway — MQTT broker from device sensor data first to ingest data to Apache Kafka.
- Device shadow service — which holds latest states of devices in the cloud side of platform that users can be informed about the latest state of their devices — (this service is using event sourcing method which stores all sensor data as well)
