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

Сводка

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

Подробности

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

Содержимое

...	...	@@ -98,12 +98,25 @@
98	98	Этот триггер выполняется периодически с более крупной временной задержкой. В случае обнаружения потери TriggerEvent, он поднимет заклинивший родительский процесс и он будет обработан (но позже). Можно установить этому триггеру низкий приоритет.
99	99	)))
100	100	|(% style="width:870px" %)[[image:Родительский дочерний процесс. Sequence.jpg]]
	101	+|(% style="width:870px" %)(((
	102	+Возможен вариант №2, когда мы просто ставит timerTrigger на условно 1-5-10 минуту (насколько важна задержка) и перепроверяем условие завершения. Из минус, что родительский процесс узнает о завершении дочерних процессов с задержкой (хотя в задержке можно использовать функцию от количества необработанных дочерних процессов, но тогда нужно считать количество или хотя бы что оно не больше N).
	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 процессы упавшие в ошибку не будут генерировать нагрузку (если использовать фильтрующий индекс).
101	101	)))
	113	+)))
102	102	|(% style="width:32px" %)2|(% style="width:171px" %)Transaction outbox stream process.|(% style="width:1066px" %)[[image:TransactionOutbox. Sequence.jpg]]
103	103	|(% style="width:32px" %)3|(% style="width:171px" %)Stream trigger|(% style="width:1066px" %)(((
104	104	|(% style="width:94px" %) |(% style="width:1002px" %)(((
105	105	* Позволяет убрать лишние запросы пробуждения процесса (когда он и так запущен).
106	106	* Позволяет полностью убрать задержку после остановки процесса (если есть новое сообщения, то он сразу же будет пробужден).
	119	+За счет того, что триггер точно знает, что есть новые сообщения и процесс только что уснул.
107	107	* Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - процесс идет спать (содержит offset значение).
108	108	* Вводит дополнительное состояние в триггер: максимальный offset сообщения, максимальный offset обработанного процессом сообщения, флаг состояния сна процесса.
109	109	)))
...	...	@@ -125,4 +125,26 @@
125	125	)))
126	126	)))
127	127
128		-
	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	+----