Изменения документа Движок cccc1808. ProcessEngine

Сводка

• Свойства страницы (1 изменено, 0 добавлено, 0 удалено)

Подробности

Свойства страницы

Содержимое

...	...	@@ -98,25 +98,12 @@
98	98	Этот триггер выполняется периодически с более крупной временной задержкой. В случае обнаружения потери TriggerEvent, он поднимет заклинивший родительский процесс и он будет обработан (но позже). Можно установить этому триггеру низкий приоритет.
99	99	)))
100	100	|(% style="width:870px" %)[[image:Родительский дочерний процесс. Sequence.jpg]]
101		-|(% style="width:870px" %)(((
102		-Возможен вариант №2, когда мы просто ставит timerTrigger на условно 1-5 минуту (насколько важна задержка) и перепроверяем условие завершения (по нагрузке на БД будет еще меньше). Из минус, что родительский процесс узнает о завершении дочерних процессов с задержкой (хотя в задержке можно использовать функцию от количества необработанных дочерних процессов, но тогда нужно считать количество).
103		-
104		-* Но тут будет join нагрузка на БД (если шаг проверки выполняется пакетно), иначе будет просто много одиночны запросов на чтение (условно раз в минуту).
105		-* Если дочерний процесс остановиться в ошибке, то родительский либо также продолжит крутиться в проверке, либо должен также пробросить ошибку в себя чтобы приостановиться.
106		-При это если родительский процесс остановиться при обнаружении хотя бы одной ошибки в дочернем процессе, то стартануть нужно будет и родительский (он сам не узнает), а в случае с сигналом останавливать родительский процесс не нужно.
107		-В случае с решением 1, со страхующим триггером это можно обойти через фильтрующий индекс если мы начинаем идти сразу с таблицы процессов (т.е. процессы с ошибкой сразу будут игнорироваться).
108		-* Но все равно, именно данный движек может позволить настроить 2 процесса таким образом, что 1 процесс будет исполняться (1 процесс - 1 транзакция) в параллельном режиме (пока создаются множественные дочерние процессы), 2 процесс будет исполняться в пакетном режиме (N процессов - 1 транзакция) чтобы проверять выполнение условия завершения дочерних процессов через запрос (один пакетный).
109		-
110		-плюсы: меньше пишущей нагрузки (т.к. триггер со счетчиком будет делать условно одну запись на счетчик триггер в 5-20 секунд), а тут будет одна запись в 1-5 минуту на обновление таймера.
111		-минусы: больше читающей нагрузки с join (раз 1-5 минуту нужно будет выполнить join незавершенных процессов с дочерними). У решения 1 тоже есть такая нагрузка, но на страхующем триггер (условно раз 10-30 минут) и у решения 1 процессы упавшие в ошибку не будут генерировать нагрузку (если использовать фильтрующий индекс).
112	112	)))
113		-)))
114	114	|(% style="width:32px" %)2|(% style="width:171px" %)Transaction outbox stream process.|(% style="width:1066px" %)[[image:TransactionOutbox. Sequence.jpg]]
115	115	|(% style="width:32px" %)3|(% style="width:171px" %)Stream trigger|(% style="width:1066px" %)(((
116	116	|(% style="width:94px" %) |(% style="width:1002px" %)(((
117	117	* Позволяет убрать лишние запросы пробуждения процесса (когда он и так запущен).
118	118	* Позволяет полностью убрать задержку после остановки процесса (если есть новое сообщения, то он сразу же будет пробужден).
119		-За счет того, что триггер точно знает, что есть новые сообщения и процесс только что уснул.
120	120	* Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - процесс идет спать (содержит offset значение).
121	121	* Вводит дополнительное состояние в триггер: максимальный offset сообщения, максимальный offset обработанного процессом сообщения, флаг состояния сна процесса.
122	122	)))
...	...	@@ -138,26 +138,4 @@
138	138	)))
139	139	)))
140	140
141		-----
142		-
143		-==== Внутренние ссылки: ====
144		-
145		-====== Дочерние страницы: ======
146		-
147		-{{children/}}
148		-
149		-====== Обратные ссылки: ======
150		-
151		-{{velocity}}
152		-#set ($links = $doc.getBacklinks())
153		-#if ($links.size() > 0)
154		- #foreach ($docname in $links)
155		- #set ($rdoc = $xwiki.getDocument($docname).getTranslatedDocument())
156		- * [[$escapetool.xml($rdoc.fullName)]]
157		- #end
158		-#else
159		- No back links for this page!
160		-#end
161		-{{/velocity}}
162		-
163		-----
	128	+