事件量控制器处理器—GeoEvent Server

摘要

事件量控制器处理器可用于过滤在迭代时间间隔内处理的唯一事件记录数。发送到处理器的超过每个间隔所允许最大事件数的事件记录将被放弃，不可用于进一步处理。

放置在基于通知的输出连接器（例如电子邮件、文本或即时消息输出）之前的事件量控制器处理器可用于限制发送消息的速率。例如，如果要在配送货车进入配送位置后发送电子邮件，则处理器可用于确保每 10 分钟仅发送一封电子邮件，而非配送货车每 5 秒钟报告一次其位置。
放置在事件连接器处理器之前的事件量控制器处理器可用于确保最快输入源的速率与最慢输入源的速率相匹配。例如，可以将每秒报告一次其位置的车辆限制为每 5 秒钟，以匹配每 5 秒钟报告一次车辆诊断的单独馈送。

发送到事件量控制器处理器的事件记录必须具有带 TRACK_ID 标签的 GeoEvent 定义。处理器将使用此已标记字段来评估事件记录的唯一性，并追踪唯一事件记录何时超过当前间隔的最大事件阈值。
超过当前间隔的最大事件数/每个间隔的唯一事件记录将被放弃，不可用于进一步处理。例如，如果处理器配置的间隔为 60 秒且每个间隔的最大事件数为 5，则处理器应在迭代 60 秒间隔内仅处理每个 TRACK_ID 的前 5 个接收的事件记录。
将按照先进先出的原则对发送到处理器的事件记录进行评估。这意味着会对处理器接收的第一个事件记录进行相应的评估和处理。
超过当前间隔最大事件阈值的事件记录将被放弃，不可用于进一步处理。放弃的记录不会进行缓存。
如果保持默认值不变，则处理器每 60 秒将仅处理任何给定 TRACK_ID 的一个事件记录。例如，如果将 TRACK_ID 标签应用于车牌字段，则在 GeoEvent Server 中添加实时车辆数据时，每 60 秒将仅处理每个唯一车牌的第一个报告的事件记录。如果事件量控制器处理器刚对车牌 ABC-1234 进行处理，则在相同 60 秒间隔内接收的车牌 ABC-1234 的后续事件记录将被放弃。当下一个 60 秒间隔开始后，将能够在下一个 60 秒间隔内再次对 ABC-1234 进行处理。相同的逻辑适用于具有唯一车牌号的其他车辆。


参数	描述
名称	用于在 GeoEvent Manager 中引用的处理器的描述性名称。
处理器	所选处理器的名称。
间隔（秒）	用于指定间隔时段（以秒为单位），将对事件记录进行评估以进行事件量过滤。默认值为 60。
每个间隔的最大事件数	用于指定每个间隔将进行处理的每个唯一 TRACK_ID 的最大事件记录数。超过每个间隔的最大事件数的特定 TRACK_ID 的事件记录将被放弃。默认值为 1。