Search papers, labs, and topics across Lattice.
This paper introduces a context-aware semantic platform for Industrial IoT data stream management that leverages a Knowledge Graph to unify heterogeneous data sources and represent devices, streams, and processing pipelines. The platform utilizes Apache Kafka and Flink for real-time stream processing and SPARQL/SWRL-based reasoning for context-dependent stream discovery and role-based data access. Experimental results demonstrate the platform's effectiveness in enabling interoperable data workflows for Industry 5.0 environments by combining semantic models, context-aware reasoning, and distributed stream processing.
Unlock interoperable data workflows for Industry 5.0 with a context-aware knowledge graph platform that dynamically adapts stream processing and access based on agent roles.
Industrial IoT ecosystems bring together sensors, machines and smart devices operating collaboratively across industrial environments. These systems generate large volumes of heterogeneous, high-velocity data streams that require interoperable, secure and contextually aware management. Most of the current stream management architectures, however, still rely on syntactic integration mechanisms, which result in limited flexibility, maintainability and interpretability in complex Industry 5.0 scenarios. This work proposes a context-aware semantic platform for data stream management that unifies heterogeneous IoT/IoE data sources through a Knowledge Graph enabling formal representation of devices, streams, agents, transformation pipelines, roles and rights. The model supports flexible data gathering, composable stream processing pipelines, and dynamic role-based data access based on agents' contexts, relying on Apache Kafka and Apache Flink for real-time processing, while SPARQL and SWRL-based reasoning provide context-dependent stream discovery. Experimental evaluations demonstrate the effectiveness of combining semantic models, context-aware reasoning and distributed stream processing to enable interoperable data workflows for Industry 5.0 environments.
