sitewhere租户事件处理【译】

2022-04-24 00:00:00 队列 配置 事件 处理器 出站

租户事件处理

在通过事件源将数据拉入系统后,标准化数据由事件处理子系统处理。事件被交给一个入站处理策略 实现,该实现控制着待处理事件的排队和线程等方面。这些事件被传递给入站处理链 - 入站事件处理器的有序列表 ,这些处理器以链接的方式处理每个未保存的事件。如果事件存储处理器配置在入站链中,则事件将保存到基础数据存储区。成功保存后,事件将转交给出站处理策略它处理出站处理的排队和线程。然后,每个事件都由出站处理链处理,该出站处理链出站事件处理器的有序链每个出站处理器都处理已保存的事件以启动事件的自定义处理。

入站处理策略

入站处理策略负责将事件从事件源移入入站处理链。它负责处理线程并可靠地交付处理事件。入站处理策略必须实现 IInboundProcessingStrategy接口。

阻塞队列入站处理策略


入站处理链

在事件源将数据解码为SiteWhere设备事件后,入站处理策略将事件排队等待 入站处理链处理链是一系列入站事件处理器(实现IInboundEventProcessor),每个事件处理器都处理串联的入站事件。新的入站事件处理器可以添加到链中以增强现有功能。例如,度量处理器可以保持每秒处理事件的数量。

由于REST调用(或直接调用设备管理API的其他调用)不会通过事件源进入系统,因此不会由入站处理链进行处理。

事件存储处理器

默认情况下,在入站链中配置事件存储处理器的实例该处理器通过设备管理服务提供商接口来维护设备事件。如果这个处理器被移除,事件将不会被存储。默认配置如下所示:

  1. 相关文章