Триггер инициализации
Событие
  • Событие с UI (по вводу пользователя)
  • Доменное событие
  • Поступление сообщения
  • Срабатывание планировщика или периодического таймера (например CRON).
Тип триггера
  • Ручной запуск (Инициирован пользователем)
  • По событию (Инициирован событием)
  • Автоматический по расписанию (Инициирован планировщиком)
Параметры инициализации
ТипПараметр 
По сущности1 ключ 
По группе сущностей ()Набор ключей сущностей 
На основе данных, по выборке с параметрамиdto с параметрами 
Инициализация на основе данных
Тип 
Выборка батчей до исчерпания

Выборка данных до тех пор пока они не исчерпаются.

Замечания:

  • Плохо подходит для больших объемов данных. Может привести к долгому выполнению выборки.
  • Плохо подходит для сложных условий т.к. может привезти к тому, что будет невозможно выразить полный набор условий в виде запроса или запрос получиться сложным и также будет долго выполняться.
  • Одна ошибка блокирует всю инициализацию.
    Если при обработке ключевого доменного объекта возникнет ошибка, то это окажет влияние на всю операцию инициализации.
    Может быть проблематично отбросить данный доменный объект, чтобы он не попал в выборку.

Пример:
Соединение таблицы доменных сущностей с таблицей процесса и выборка тех сущностей, по которым нет записи в таблице процесса.

Перебор батчей данных

Когда речь заходит о переборе данных, то явно касаемся вопрос Пагинация | Paging.

Стоит учитывать следующие моменты:

  • Фильтрация - перебор ограниченного подмножества от всего набора данных (условие).
  • Параллелизм - возможность выполнения операции параллельно (с распределением блоков между обработчиками).
  • Модификация данных - гарантия что в процессе, данные могут быть изменены (самой инициализацией или внешним воздействием).

Keyset пагинации может быть более эффективной (с точки зрения стоимости запроса).

Валидация перед запуском
Доменные объекты
  • Валидация доменных объектов на возможность запуска экземпляра процесса
    (с гарантией, что доменной объект не будет изменен до конца транзакции инициализации, иначе мы можем принять некорректное решение о запуске процесса).
  • В случае использования Оптимистичная блокировка, необходимо также гарантировать инкрементацию ключа доменных сущностей т.к. скорее всего их поля не изменятся напрямую.
  • Как вариант - использование более строго уровня изоляции.
Процессы

Если существуют предыдущие экземпляры процесса (по ключевому набору), то они также валидируются на возможность запуска нового экземпляра

Отношение экземпляров процесса и ключевых доменных сущностей.
Допускается создание только одного экземпляраКлючевые доменные сущности <-(1 к 1)-> Экземпляр процесса.
Для каждого уникального ключа может быть не более 1 экземпляра процесса.
Допускается создание более одного экземпляра

Здесь речь идет не только о том, что несколько экземпляров активны в один и тот-же момент времени, а о том, что допускается ситуация, что в случае если у нас уже есть существующий экземпляр процесса (выполнявшийся ранее), и вместо того, чтобы изменить его состояние и перезапустить, создаем новый экземпляр (при этом гарантируя валидность такого действия).

В таком случае мы можем представить следующую модель данных:
Ключевые доменные сущности <-(1 к 1)-> Ключевой сквозной контекст процесса <-(1 к N)-> Экземпляр процесса.
 

Ключевой сквозной контекст не всегда может быть выражен явно, но фактически он будет существовать.

Пример 1

Мы можем гарантировать, что в один момент времени имеется только один активный экземпляр процесса (и только он выполняется).

Мы можем использовать указатель на активный процесс из сквозного контекста,
или также мы можем добавить флажок активности в экземпляр процесса и наложить на него уникальный индекс.

Пример 2

Сквозной контекст может отслеживать была ли достигнута финальная цель ключевой связки.

Например:

  • Целью является создание некоторого доменного объекта, когда он будет создан, информация зафиксируется в сквозном контексте.
  • Эти данные не позволят запустить новый экземпляр процесса так как цель достигнута - объект создан.
  • Если вдруг выясняется, что по какой-то причине созданный доменный объект объявляется недействительным, и необходимо запустить новый экземпляр процесса (по тому же ключу) для создания нового экземпляра доменного объекта, то также нужно выполнить сброс данных в сквозном контексте.
    (ручной сброс или подписка на доменной событие, оповещающее о смене статуса созданного объекта (аннулирование, блокировка и др.))
  
Теги: