2025-11-12T22:13:10.653124

SigSPARQL: Signals as a First-Class Citizen When Querying Knowledge Graphs

Schwarzinger, Steindl, FrÃ¼hwirth et al.

Purpose: Cyber-Physical Systems (CPSs) integrate computation and physical processes, producing time series data from thousands of sensors. Knowledge graphs can contextualize these data, yet current approaches that are applicably to monitoring CPS rely on observation-based approaches. This limits the ability to express computations on sensor data, especially when no assumptions can be made about sampling synchronicity or sampling rates. Methodology: We propose an approach for integrating knowledge graphs with signals that model run-time sensor data as functions from time to data. To demonstrate this approach, we introduce SigSPARQL, a query language that can combine RDF data and signals. We assess its technical feasibility with a prototype and demonstrate its use in a typical CPS monitoring use case. Findings: Our approach enables queries to combine graph-based knowledge with signals, overcoming some key limits of observation-based methods. The developed prototype successfully demonstrated feasibility and applicability. Value: This work presents a query-based approach for CPS monitoring that integrates knowledge graphs and signals, alleviating problems of observation-based approaches. By leveraging system knowledge, it enables operators to run a single query across different system instances within the same domain. Future work will extend SigSPARQL with additional signal functions and evaluate it in large-scale CPS deployments.

academic

SigSPARQL: Signals as a First-Class Citizen When Querying Knowledge Graphs

基本信息

论文ID: 2506.03826
标题: SigSPARQL: Signals as a First-Class Citizen When Querying Knowledge Graphs
作者: Tobias Schwarzinger, Gernot Steindl, Thomas Frühwirth, Thomas Preindl, Konrad Diwold, Katrin Ehrenmüller, Fajar J. Ekaputra
分类: cs.DB (数据库)
发表时间: 2025年7月
论文链接: https://arxiv.org/abs/2506.03826

摘要

本文针对信息物理系统(CPS)监控中的数据查询问题，提出了一种将知识图谱与信号处理相结合的新方法。传统方法基于观测数据，在处理传感器数据计算时存在局限性，特别是在采样不同步或采样率不一致的情况下。作者提出SigSPARQL查询语言，将运行时传感器数据建模为时间到数据的函数(信号)，实现了RDF数据与信号的统一查询。通过原型系统验证了技术可行性，并在典型CPS监控用例中展示了应用效果。

研究背景与动机

问题定义

核心问题：信息物理系统产生大量时间序列传感器数据，需要与系统上下文信息结合进行分析，但现有基于观测的方法在表达传感器数据计算时存在复杂性和局限性。
重要性：随着数字化发展，CPS广泛应用于建筑、能源网络、制造业等领域，有效利用传感器数据对系统分析、监控和控制至关重要。
现有方法局限性：
- 基于本体的数据访问(OBDA)方法将时间序列映射为图结构时，单个传感器的时间值分散在数千个表示独立观测的元素中
- 查询复杂度增加，需要从独立观测重构时间值概念
- 在处理异步时间序列时面临挑战，不同时间戳的观测难以组合
- 缺乏对观测值之间数据建模的统一概念
研究动机：引入信号(Signal)概念作为"一等公民"，抽象化独立观测，克服当前方法在传感器数据计算表达上的不足。

核心贡献

提出了语言无关的框架：定义了三个核心操作符(Signal、ApplySF、LiftVal)用于集成知识图谱查询语言与信号处理
设计了SigSPARQL查询语言：扩展SPARQL语法和语义，支持信号作为查询结果的一等公民
构建了原型系统：基于Oxigraph实现，验证了技术可行性
提供了完整的理论基础：基于函数响应式编程(FRP)理论，建立了信号与时间序列数据的形式化关系
展示了实际应用价值：通过电动汽车充电站监控用例证明了方法的适用性

方法详解

任务定义

输入：信号注释的RDF数据集 <D, S, φ>，其中D是RDF数据集，S是RDF信号集合，φ是信号注释函数输出：时间解序列(TSS)或连续更新的RDF图约束：支持连续查询，处理异步传感器数据流

核心概念与数据模型

1. 信号定义

Definition 7.1: RDF信号ψ是形式为T→RDF的(可能部分的)函数
其中T是时间域，RDF是RDF项集合

2. 信号注释RDF数据集

Definition 7.2: <D, S, φ>
- D: 常规RDF数据集
- S: RDF信号集合  
- φ: IRI×IRI→S的部分函数(信号注释函数)

语言无关框架

作者提出三个核心操作符：

Signal(s, p)：基于信号源s和信号属性p构造信号
ApplySF(f, a⃗)：将n元信号函数f应用于长度为n的信号参数列表
LiftVal(v)：将值v提升为常量信号

SigSPARQL语言设计

语法扩展

SIGNALS子句：

SIGNALS {
    ev:ActivePower FROM ?device AS ?ap
    ev:Envelope FROM ?garage AS ?env
}

WHEN子句：

WHEN {
    SUM(?ap * ?sign) > ?env
    BECOMES TRUE AT ?violation_time
}

语义定义

时间解序列(TSS)：允许解将变量绑定到RDF项或RDF信号，可在时间点τ评估
连续查询：SELECT查询返回TSS，CONSTRUCT查询返回连续增长的RDF图
信号计算：通过点式应用提升SPARQL函数和操作符到信号域

技术创新点

信号抽象：使用FRP中的信号概念替代基于观测的方法，提供更自然的时间数据建模
统一查询模型：在单一查询中结合图结构知识和时间信号处理
类型系统扩展：扩展SPARQL代数支持信号类型，自动处理类型提升
连续查询语义：定义触发事件机制，支持实时监控应用

实验设置

原型实现

基础框架：基于Oxigraph图数据库
时间模型：离散时间，使用"最后观测"策略建模观测间数据
评估方式：两步骤评估 - 构造信号计算描述，然后注册连续查询引擎

验证用例

电动汽车充电站监控场景：

系统组成：多个EV充电器、光伏系统、电池
监控目标：检测功率消耗超过运营封装限制的违规事件
数据源：有功功率(AP)传感器、电池状态(SoC)传感器、运营封装限制

查询示例

CONSTRUCT {
    ?garage ev:hasEnvelopeViolation [
        ev:description "Envelope Violated!" ;
        ev:startTime ?violation_time
    ]
}
WHEN {
    SUM(?ap * ?sign) > ?env
    BECOMES TRUE AT ?violation_time
}
SIGNALS {
    ev:ActivePower FROM ?device AS ?ap
    ev:Envelope FROM ?garage AS ?env
}
WHERE {
    ?garage a ev:Garage ; sosa:hosts ?device .
    ?device a ?ap_device_type .
    BIND(IF(?ap_device_type = ev:PVSystem, -1, 1) AS ?sign)
}
GROUP BY ?garage