SpecsModelExplore
Overview
Actors
External Systems
IoT Platform
Edge
Ingestion
Stream Processing
Stream Processor
Batch Processor
Device Management
User-Facing Apps
Platform
SpecsModelExplore
Stream Processing
OverviewGuideLinks and Communications
IDproduct.processing
DescriptionReal-time and batch processing of telemetry.
Keyprocessing
Typesystem
TeamStream Processing
Ownerstream-processing@iotgateway.example
Statusactive
TechnologiesApache Flink, Apache Spark, Kafka
Attributeslatency: <2s, throughput: 1M events/s
Tags
Table of contents
Guide
Stream Processing
System at a glance
Containers
Two paths for one stream
Responsibilities
Related workflows

Guide

Stream Processing

Stream Processing is where raw telemetry becomes useful. It runs the real-time pipelines that power live dashboards and alerts, and the nightly batch jobs that produce curated, query-ready datasets for analytics.

Responsibility in one sentence

Consume the telemetry firehose, compute aggregates and anomalies in near real time, and archive curated history to object storage.

System at a glance

Could not build diagram for model "example-iot".

Containers

Stream Processor

Stateful Flink pipelines for windowed aggregates and anomaly detection.

Batch Processor

Daily Spark jobs that build curated datasets and archive history.

Two paths for one stream

Responsibilities

  • Real-time windowed aggregation of telemetry.
  • Anomaly detection and alert emission.
  • Daily curated dataset generation and archival.

Related workflows

The alert pipeline is driven end-to-end by the streaming side of this system:

Links and Communications

2 incoming links · 2 outgoing links

Incoming Links(2)

Source objectLabelLink typeRelationRaw idRequiredDescription
Data Engineer

example-iot.actors.data_engineer

actor
builds pipelines in—linksproduct.processing——
Ingestion

example-iot.product.ingestion

system
feeds—linksproduct.processing——

Outgoing Links(2)

Target objectLabelLink typeRelationRaw idRequiredDescription
User-Facing Apps

example-iot.product.user_facing

system
feeds dashboards in—linksproduct.user_facing——
Object Storage

example-iot.external_systems.object_storage

external:storage
archives to—linksexternal_systems.object_storage——