Перейти к содержимому

Изменения документа Stream триггер

Редактировал(а) Alexandr Fokin 2026/08/28 11:44
От версии 1.2
отредактировано Alexandr Fokin
на 2026/08/26 18:59
Изменить комментарий: К данной версии нет комментариев
К версии 1.4
отредактировано Alexandr Fokin
на 2026/08/28 11:43
Изменить комментарий: К данной версии нет комментариев

Сводка

Подробности

Свойства страницы
Содержимое
... ... @@ -9,11 +9,12 @@
9 9  * Позволяет не выполнять wakeup код в конце сессии обработки (если отключить wakeup, оставить только stream trigger)
10 10  (блокировка и обновление wakeup entity, проверка wakeup условия).
11 11  )))
12 -|(% style="width:147px" %)Offset stream триггер.|(% style="width:1334px" %)(((
12 +|(% style="width:147px" %)Offset stream триггер|(% style="width:1334px" %)(((
13 13  Можно также хранить в триггере offset (по аналогии с kakfa), в таком случае триггер может избежать перепроверки условия пробуждения (не проверять наличие необработанных сообщений в БД), достаточно только отслеживать значения смещений.
14 14  
15 -* Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - процесс идет спать (содержит offset значение).
15 +* Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - сообщение от процесса об обработанном смещении (содержит обработанный offset).
16 16  * Вводит дополнительное состояние в триггер: максимальный offset сообщения, максимальный offset обработанного процессом сообщения, флаг состояния сна процесса
17 17  )))
18 +|(% style="width:147px" %)Каскад триггеров|(% style="width:1334px" %)Способ для обработки конкурентных сигналов (несколько триггеров). Для процесса создается один корневой триггеров, а все другие (дочерние) триггеры передают сигнал на него.
18 18  
19 19