Sourcing, Processing and Publishing Telemetry Data

Thin-edge.io primary use-case is to:

1. collect telemetry data on a device from various sources, sensors, and child devices,
2. process these data with analytics components
3. forward part of the processed to the cloud.

This flow of data is organized over :

1. an MQTT bus where the local components publish and exchange messages,
2. a canonical data format, thin-edge-json, that let the components exchange telemetry data independently of the connected cloud
3. a mapper process that translates canonical messages and forward them to the cloud.

graph TD
    src(Source)
    c8y(C8y Cloud)
    az(Azure Cloud)

    mapSrc((Source Mapper))
    proc((Analytics))
    mapAz((C8y Mapper))
    mapC8y((Azure Mapper))

    subgraph Mqtt Bus
        raw>Source specific messages]
        tej>Thin Edge Json messages]
        cloud>Cloud specific messages]
        bridge>Bridge]
    end

    src --> raw
    raw --> mapSrc --> tej
    tej --> proc --> tej
    tej --> mapC8y --> cloud
    tej --> mapAz --> cloud
    cloud --> bridge --> c8y
    cloud --> bridge --> az