StreamPipes can consume and produce data streams via Apache Pulsar, using Pulsar as a high-performance message broker for IIoT data ingestion and distribution.
StreamPipes can consume Kafka streams for industrial IoT analytics and processing.
StreamPipes uses PLC4X as its connectivity layer for S7, Modbus, and other PLC protocols. PLC4X handles the low-level protocol communication while StreamPipes provides the visual pipeline editor and analytics on top.
StreamPipes can sink processed data to InfluxDB for time-series storage, and read from InfluxDB as a data source for historical analysis pipelines.
StreamPipes processes and enriches IIoT data streams, then routes results to databases like PostgreSQL or InfluxDB where Grafana visualizes them. StreamPipes handles the real-time analytics pipeline; Grafana provides the dashboarding layer.
StreamPipes connects to Mosquitto as an MQTT data source via its built-in MQTT adapter, enabling real-time ingestion of sensor and telemetry data from the factory floor into StreamPipes analytics pipelines.