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

Сводка

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

Подробности

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

Содержимое

...	...	@@ -3,6 +3,9 @@
3	3	Очередь задач, Система обработки процессов, Движок обработки процессов.
4	4	[[Процесс>>doc:Архитектура и модели.Модели.Процесс.WebHome]]
5	5	)))
	6	+|(% style="width:132px" %) |(% style="width:1301px" %)Универсальный движок для выполнения процессов и очередей задач, позволяющий комбинировать несколько подходов к обработке (см особенности).
	7	+|(% style="width:132px" %) |(% style="width:1301px" %)Процесс является единицей выполнения.
	8	+Система триггеров используется для таймеров и передачи сигналов для процессов (с оптимизацией нагрузки).
6	6	|(% style="width:132px" %)Особенности|(% style="width:1301px" %)(((
7	7	|(% style="width:159px" %)Батчинг|(% style="width:1168px" %)(((
8	8	Возможность использовать и комбинировать разные типы выполнения как
...	...	@@ -28,17 +28,19 @@
28	28	)))
29	29	|(% style="width:159px" %)Передача сигналов для процессов через систему триггеров.|(% style="width:1168px" %)(((
30	30	В том числе для передачи сигналов реализована система триггеров.
31		-Она позволяет оптимизировать операции с БД.
	34	+Она позволяет оптимизировать операции с БД и уменьшить конкуренцию между процессами за общее состояние (родительский процесс).
32	32
33	33	см. пример 1.
34	34	)))
35		-|(% style="width:159px" %)Перехват ошибок|(% style="width:1168px" %)Перехват и обработка ошибок, если процесс выкинул exception в движок. Реализацию простого retry с задержкой.
	38	+|(% style="width:159px" %)Перехват ошибок|(% style="width:1168px" %)Перехват и обработка ошибок, если процесс выкинул exception в движок. Реализацию простого retry с задержкой (создается триггер на следующую попытку).
36	36	|(% style="width:159px" %)Параллельное выполнение|(% style="width:1168px" %)Допускается запуск нескольких раннеров (на разных нодах), работающих с одной таблицей процессов для распределения нагрузки между ними.
37		-Допускается фильтрация типов процессов между нодами (чтобы нода выполняла только определенные типы процессы, в том числе по приоритету).
	40	+Допускается фильтрация типов процессов между нодами (чтобы нода выполняла только определенные типы процессов, в том числе по приоритету).
38	38	Доступно для раннеров процессов и триггеров.
39		-\\В перспективе возможны решения с шардиванием.
	42	+\\Также возможна частичная поставка новой версии процесса и этот процесс будет браться в обработку только ограниченным количеством новых нод исполнителей.
	43	+\\В перспективе возможны решения с шардированием.
40	40	|(% style="width:159px" %)Soft timeout|(% style="width:1168px" %)Возможность указывать soft timeout, который будет мягко приостанавливать цикл (внутри шага процесса), чтобы ограничить общее время транзакции (не делать транзакции долгими (например горизонт postgres)).
41	41	Например родительский процесс может создать N/2 дочерних процессов за 1 сессию и N/2 за 2 сессию выполнения.
	46	+|(% style="width:159px" %)Range preload process data|(% style="width:1168px" %)(Необязательно) возможность пакетно предзагружать данные и бизнес сущности для процессов из обрабатываемого батча (Range query) для оптимизации чтения.
42	42	)))
43	43	|(% style="width:132px" %)Примеры|(% style="width:1301px" %)(((
44	44	|(% style="width:32px" %)1|(% style="width:171px" %)Родительский процесс, N дочерних процессов.|(% style="width:1066px" %)(((
...	...	@@ -51,7 +51,7 @@
51	51	)))
52	52	|(% style="width:870px" %)TriggerEvent публикуются без использования TransactionOutbox напрямую в брокер после коммита транзакции (иначе мы бы нагружали БД).
53	53	|(% style="width:870px" %)(((
54		-Предполагаем, что основную часть времени система работает стабильно, но допускается ситуация, что транзакция закоммитилась, но TriggerEvent не смогли опубликоваться (остановка сервиса без graceful shutdown, проблемы соединения или работы с брокером сообщений.
	59	+Предполагаем, что основную часть времени система работает стабильно, но допускается ситуация, что транзакция закоммитилась, но TriggerEvent не смогли опубликоваться (остановка сервиса без graceful shutdown, проблемы соединения или работы с брокером сообщений).
55	55
56	56	Для таких случаев создается страхующий триггер (1 общий на тип процесса). Этот триггер запускается периодически и проходится по всем ожидающим процессам, проверяя условие (в реализации можно использовать keyset пагинацию) (в реализации можно использовать join для проверки условия).
57	57	Этот триггер выполняется периодически с более крупной временной задержкой. В случае обнаружения потери TriggerEvent, он поднимет заклинивший родительский процесс и он будет обработан (но позже). Можно установить этому триггеру низкий приоритет.