Краткая информация
Процессор Контроллер объема событий можно применять для фильтрации числа уникальных записей событий, обработанных за итерационный интервал времени. Записи событий, отправленные процессору, которые превышают максимально допустимые события за интервал, отбрасываются и недоступны для дальнейшей обработки.
Примеры
- Процессор Контроллер объема событий, расположенный непосредственно перед выходным коннектором на основе уведомлений, например, над отправкой электронной почты, текста или мгновенных сообщений, может использоваться для регулирования скорости отправки сообщений. Например, если сообщение электронной почты должно быть отправлено после того, как грузовик доставки прибывает на место доставки, процессор может использоваться для обеспечения отправки только одного сообщения электронной почты каждые 10 минут, а не каждые пять секунд, когда грузовик доставки сообщает о своем местоположении.
- Процессор Контроллер объема событий, расположенный непосредственно перед процессором Соединитель событий, может использоваться для обеспечения соответствия скорости самого быстрого источника входных данных скорости самого медленного источника входных данных. Например, транспортное средство, сообщающее о своем местоположении каждую секунду, может быть настроено на передачу данных каждые пять секунд, чтобы соответствовать другому каналу данных, который сообщает о транспортном средстве каждые пять секунд.
Примечания по использованию
- У записей событий, отправленных к процессору Контроллер объема событий, должно быть определение GeoEvent с тегом TRACK_ID. Процессор использует это поле с тегом для оценки уникальности записи события и отслеживания того, когда уникальная запись события превысила максимальное число событий за интервал времени.
- Уникальные записи событий, превышающие максимальное число событий за интервал времени для текущего интервала, отбрасываются и недоступны для дальнейшей обработки. Например, если процессор настроен с Интервалом 60 секунд и Максимальным числом событий на интервал равным 5, процессор будет обрабатывать только первые 5 полученных записей событий каждого TRACK_ID в итерационном 60-секундном интервале.
- Записи событий, отправленные процессору, оцениваются в порядке поступления. Это означает, что сначала оцениваются и обрабатываются первые записи событий, полученные процессором.
- Записи событий, превышающие максимальное пороговое значение для текущего интервала, отбрасываются и недоступны для дальнейшей обработки. Отброшенные записи не кэшируются.
- Если значения по умолчанию остаются неизменными, процессор будет обрабатывать только одну запись события любого заданного TRACK_ID каждые 60 секунд. Например, если тег TRACK_ID применяется к полю номерного знака транспортного средства, так как в GeoEvent Server поступают данные реального времени о транспортных средствах, то каждые 60 секунд будет обрабатываться только первая отчетная запись события для каждого уникального номерного знака. Если номерной знак ABC-1234 только что был обработан процессором Контроллер объема событий, последующие записи событий для номерного знака ABC-1234, полученные в том же 60-секундном интервале, будут отброшены. Как только следующий 60-секундный интервал начнется, знак ABC-1234 будет обрабатываться снова один раз в этом следующем 60-секундном интервале. Та же логика применима и к другим автомобилям с уникальными номерными знаками.
Параметры
| Параметр | Описание |
|---|---|
| Имя | Описательное имя процессора, используемое для справочной информации в GeoEvent Manager. |
| Процессор | Имя выбранного процессора. |
| Интервал (секунды) | Указывает период времени для интервала, в секундах, во время которого записи событий будут оцениваться для фильтрации по объему. Значение по умолчанию равно 60. |
| Максимальное число событий на интервал | Задает максимальное количество записей событий на уникальный TRACK_ID, которые будут обрабатываться каждый Интервал. Записи событий определенного TRACK_ID, превышающие Максимальное число событий за интервал, отбрасываются. Значение по умолчанию равно 1. |
Советы и ограничения
- Процессор Контроллера объема событий в настоящее время не поддерживает фильтрацию на основе очередей. Например, процессор не может выполнить логическое выражение, например, фильтр каждой третьей уникальной записи события.