使用用户定义的事件将实时传感器数据记录到 RDBMS 中



我有一个由两个主要组件组成的系统,传感器和触发器。

该系统负责记录从传感器发送的信息,并向用户报告某些触发器处于活动状态或非活动状态的时间。

有关传感器的几条信息:

  • 所有传感器记录同一组字段
  • 传感器发送带有记录时间的时间戳

触发器:

  • 触发器由用户定义
  • 输入只是一个传感器的一个读数(即,不是随时间变化的读数或多个传感器)
  • 只有活动/非活动状态

传感器在多对多的基础上分配给触发器。

我遇到的问题与跟踪触发器"何时"处于活动状态或不活动状态有关。

例如,对于触发器检查值> 1

sensor_id | reading             | value | trigger_value
1           2011-04-25T20:09:00   0       false
1           2011-04-25T20:11:00   1       false
1           2011-04-25T20:13:00   4       true
1           2011-04-25T20:15:00   5       true
1           2011-04-25T20:17:00   3       true
1           2011-04-25T20:19:00   6       true
1           2011-04-25T20:21:00   1       false

它可能会返回:

sensor_id | reading             | event
1           2011-04-25T20:13:00   1 -- 'went active'
1           2011-04-25T20:21:00   0 -- 'went in-active'

我目前的方法涉及记录每个传感器的触发器集的当前状态。当传感器的下一个输入进入并评估触发器时,它会将其与该传感器的当前触发状态列表进行比较。对于状态的每次更改,都会记录"激活"或"停用"。

这种方法非常简单,但它生成的有关数据库中"已经存在"的状态更改的数据;但是数据不在单个元组中,而是驻留在元组之间的关系中(在同一表中)。

所以,问题是:

是否因为数据"已经存在"而改变我的方法;通过更改模式以使其不那么依赖于元组之间的关系,或者创建视图/存储过程来分析它 apon 请求

我是否保留这个系统,因为它解决了问题并隐藏了同一表中元组之间存在时间关系的事实(我知道这很糟糕)。

以更一般的形式:

您如何在表中存储基于时间的统计信息/数据,并在不破坏RDBMS的情况下分析连续统计信息之间的差异。

当前实现结构示例:

-- log incoming sensor data, keyed by sensor and when it was recorded
create table sensor_log (
  sensor_id integer references sensors (sensor_id),
  reading timestamp,
  data_point_a integer NOT NULL, -- example name only
  data_point_b integer NOT NULL,
  -- ...  various other data points
  primary key(sensor_id, reading)
);
-- data storage for trigger configuration
create table triggers (
  trigger_id integer,
  -- ...  configuration for the triggers
  primary key(trigger_id)
);
-- associate triggers with particular sensors on a many to many basis
create table sensor_triggers (
  sensor_id integer references sensors (sensor_id),
  trigger_id integer references triggers (trigger_id),
  -- ...  configuration for the triggers
  primary key(sensor_id, trigger_id)
);
-- record which triggers were active for a particular sensor input
-- not necessary, unless to save on recomputing past trigger activations
create table sensor_trigger_activations (
  sensor_id integer,
  reading timestamp,
  trigger_id integer references triggers (trigger_id),
  primary key (sensor_id, reading, trigger_id),
  foreign key (sensor_id, reading) references sensor_log (sensor_id, reading)
);
-- record trigger 'activations' & 'deactivations'
-- activation: active state preceded by in-active state (for a particular trigger)
-- deactivation: in-active state preceded by an active state ""
-- absense
create table sensor_trigger_events (
  sensor_id integer,
  reading timestamp,
  trigger_id integer,
  event_type smallint CHECK (event_type = 0 OR event_type = 1), -- 0 = deactivation, 1 = activation
  primary_key (sensor_id, reading, trigger_id),
  foreign key (sensor_id, reading) references sensor_log (sensor_id, reading)
);

首先,我认为同一表中元组之间的时间关系不一定是坏的。 它不是很直接,所以隐藏它是可以的。

鉴于您的要求,我真的没有看到太多可以改进的地方。

最新更新