Исходный код вики Инициализация процесса

Версия 1.17 от Alexandr Fokin на 2024/01/11 13:38
Скрыть последних авторов
Alexandr Fokin 1.4 1 |(% style="width:15px" %) |(% style="width:1470px" %)(((
Alexandr Fokin 1.17 2 (% border="1" %)
Alexandr Fokin 1.5 3 |(% style="width:179px" %)Ручной и автоматический запуск процесса|(% style="width:1271px" %)
4 |(% style="width:179px" %)Валидация перед запуском|(% style="width:1271px" %)(((
Alexandr Fokin 1.17 5 (% border="1" %)
Alexandr Fokin 1.4 6 |(((
Alexandr Fokin 1.14 7 * Валидация доменных объектов на возможность запуска экземпляра процесса (с гарантией, что доменной объект не будет изменен до конца транзакции планировщика, иначе мы можем принять некорректное решение о запуске процесса).
8 * В случае использования [[Оптимистичная блокировка>>doc:Архитектура и модели.Блокировки.Оптимистичная блокировка.WebHome]], необходимо также гарантировать инкрементацию ключа доменных сущностей т.к. скорее всего их поля не изменятся напрямую.
9 * Как вариант - использование более строго уровня изоляции.
10 )))
11 |(((
Alexandr Fokin 1.4 12 Если существуют предыдущие экземпляры процесса (__по ключевому набору__), то они также валидируются на возможность запуска нового экземпляра
13
Alexandr Fokin 1.6 14 |(% colspan="2" style="width:157px" %)Отношение экземпляров процесса и ключевых доменных сущностей.
15 |(% style="width:157px" %)Допускается создание только одного экземпляра процесса|(% style="width:1078px" %)Экземпляр ключевой доменной сущности <-(1 к 1)-> Экземпляр процесса.
Alexandr Fokin 1.4 16 Для каждого уникального ключа может быть только 0 или 1 экземпляр процесса.
Alexandr Fokin 1.6 17 |(% style="width:157px" %)Допускается создание более одного экземпляра|(% style="width:1078px" %)(((
18 Здесь речь идет не о том, что запуск возможен в один момент времени, а в целом, что допускается ситуация, что в случае если процесс уже выполнялся, мы не меняем его состояние и перезапускаем, а создаем новый экземпляр (при этом гарантируя валидность).
Alexandr Fokin 1.5 19 \\В таком случае мы можем представить следующую модель данных:
Alexandr Fokin 1.6 20 Ключевые доменные сущности <-(1 к 1)-> Ключевой сквозной контекст процесса <-(1 к N)-> экземпляр процесса.
21
Alexandr Fokin 1.4 22
Alexandr Fokin 1.6 23 |Ключевой сквозной контекст не всегда может быть выражен явно, но фактически он будет существовать.
24 |(((
25 Пример 1
26
27 Мы можем гарантировать, что в один момент времени имеется только один активный экземпляр процесса (и только он выполняется).
28 \\Мы можем использовать указатель на активный процесс из сквозного контекста,
29 или также мы можем добавить флажок активности в экземпляр процесса и наложить на него уникальный индекс.
Alexandr Fokin 1.4 30 )))
Alexandr Fokin 1.6 31 |(((
32 Пример 2
33
34 Сквозной контекст может отслеживать была ли достигнута финальная цель ключевой связки.
35
36 Например:
37
38 * целью является создание некоторого доменного объекта, когда он будет создан, информацию зафиксируется в сквозном контексте.
39 * Эти данные не позволят запустить новый экземпляр так как цель достигнута - объект создан.
Alexandr Fokin 1.8 40 * Если вдруг выясняется, что по какой-то причине созданный доменный объект объявляется недействительным, и не обходимо запустить процесс (по тому же ключу) для создания нового экземпляра доменного объекта, то также необходимо сбросить данные в сквозном контексте.
41 (ручной сброс или подписка на доменной событие, оповещающее о смене статуса созданного объекта (аннулирование, блокировка и др.))
Alexandr Fokin 1.4 42 )))
Alexandr Fokin 1.6 43 )))
44 )))
45 )))
Alexandr Fokin 1.5 46 |(% style="width:179px" %) |(% style="width:1271px" %)
Alexandr Fokin 1.4 47
48 |(% style="width:151px" %)На основе события|(% style="width:1188px" %)Событие запуска процесса поступает извне, и обязательства о выборке данных для процесса лежат на внешнем компоненте.
Alexandr Fokin 1.2 49 События могут помещаться в некоторый буфер - хранилище (брокер сообщений, БД) и разбираться обработчиком до исчерпания.
Alexandr Fokin 1.4 50 |(% style="width:151px" %)На основе данных|(% style="width:1188px" %)(((
51 |(% colspan="2" %)Замечания
52 |Параллелизм|Гарантия, что код планировщика выполняются в эксклюзивном режиме, в случае если он запущен в нескольких экземплярах.
Alexandr Fokin 1.2 53 Предполагается [[Пессимистичная блокировка>>doc:Архитектура и модели.Блокировки.Пессимистичная блокировка.WebHome]] на уровне всех экземпляров.
Alexandr Fokin 1.4 54
55 |(% style="width:177px" %)Тип|(% style="width:993px" %)
56 |(% style="width:177px" %)Выборка до исчерпания|(% style="width:993px" %)(((
Alexandr Fokin 1.2 57 Выборка данных до тех пор пока они не исчерпаются.
58
Alexandr Fokin 1.3 59 Замечания:
60
61 * Плохо подходит для больших объемов данных. Может привести к тому,
62 * Плохо подходит для сложных условий т.к. может привезти к тому, что будет невозможно выразить полный набор условий в виде запроса или запрос получиться сложным и также будет долго выполняться.
63
Alexandr Fokin 1.2 64 Пример:
Alexandr Fokin 1.1 65 Соединение таблицы доменных сущностей с таблицей процесса и выборка тех сущностей, по которым нет записи в таблице процесса.
Alexandr Fokin 1.2 66 )))
Alexandr Fokin 1.4 67 |(% style="width:177px" %)Инициализация, привязанная к дате.|(% style="width:993px" %)Обработчик привязан к конкретной дате и рассматривает некоторый ограниченный набор, например одни сутки относительно указанной даты.
Alexandr Fokin 1.1 68 Таким образом мы явно ограничиваем блок данных. Но нужно учесть сценарии с возникновением ошибки, т.к. следующее срабатывание уже будет на основе новой даты.
Alexandr Fokin 1.4 69 |(% style="width:177px" %)Перебор всего сета доменных сущностей.|(% style="width:993px" %)(((
Alexandr Fokin 1.2 70 Необходимое условие: Наличие способа перебрать данные батчами, гарантия что данные не удаляются.
Alexandr Fokin 1.1 71
Alexandr Fokin 1.3 72 Вариант 1:
Alexandr Fokin 1.2 73 Если мы уверены, что доменные объекты не удаляются, то мы можем отсортировать их по дате создания и первичному ключу. Таким образом мы получим фиксированные страницы данных, которые можно обрабатывать параллельно. Невозможно выполнить, если допускается удаление объектов.
74
Alexandr Fokin 1.3 75 Вариант 2:
76 Если есть уникальный автоинкреметный числовой ключ, то можно использовать его.
77
78 Вариант 3:
79 Если кол-во записей не очень велико и мы можем без проблем полностью уместить сет всех ключей в оперативной памяти.
Alexandr Fokin 1.9 80 (Не требует гарантии, что сущность нельзя удалить, т,к. в случае обнаружения удаления можно просто пропустить ключ).
Alexandr Fokin 1.3 81
Alexandr Fokin 1.2 82 Can queries that users ORDER BY using date to sort data be non deterministic?
83 [[https:~~/~~/dba.stackexchange.com/questions/241056/can-queries-that-users-order-by-using-date-to-sort-data-be-non-deterministic>>https://dba.stackexchange.com/questions/241056/can-queries-that-users-order-by-using-date-to-sort-data-be-non-deterministic]]
Alexandr Fokin 1.1 84 )))
Alexandr Fokin 1.2 85 )))
86 )))
Alexandr Fokin 1.4 87 |(% style="width:15px" %) |(% style="width:1470px" %)
Alexandr Fokin 1.1 88
89