事件量控制器处理器

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

示例

以下是事件量控制器处理器的用例：

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

用法说明

使用事件量控制器处理器时，请记住以下事项：

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

参数

以下是事件量控制器处理器的参数：

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

注意事项和限制

事件量控制器处理器当前不支持基于队列进行过滤。 例如，处理器无法执行逻辑语句，例如对于每第三个唯一事件记录进行过滤。