Использование программного компонента#

Базовые функции сервиса#

К основным функциям сервиса Batch Scheduler можно отнести:

• создание, обновление, получение, приостановка, удаление Задания;

• принудительный запуск вычислений через API;

• автоматический асинхронный запуск вычислительных заданий по расписанию;

• запуск Заданий в виде вызовов API по протоколу REST.

Примеры сценариев использования#

Сценарий 1. Обработка кредитного портфеля#

Вводные данные#

Дано:

1. Кредитный портфель банка (N банков с общим объемом Х млн продуктов).

2. Бизнес-логика формирования событий.

3. Бизнес-логика обработки событий.

4. Расписание (окно возможности) формирования и обработки событий конкретного банка.

Необходимо:

1. Обработать кредитный портфель банка в выделенное окно возможностей.

2. Уменьшать или увеличивать поток обработки событий в зависимости от доступности ресурсов БД и прочей инфраструктуры.

Решение#

Бизнес-логика обработки события должна быть реализована как запрос API с использованием протокола HTTP. Необходимо совместное использование сервисов Batch Scheduler и Batch Tasks.

Обработка кредитного портфеля#

1. На каждый из банков создается Задание через Batch Scheduler. Время старта Задания — начало окна возможностей. Задание вызывает HTTP API на стороне клиента.

2. HTTP API на стороне клиента выполняет следующую логику:

   • запрос на создание Очереди через Batch Tasks API. На основе количества и времени обработки каждого события возможно изменять параметр количества одновременно обрабатываемых Задач (maxRunningTasks);

   • накопленные события складываются в Очередь в виде Задач.

3. При запуске задачи из Очереди вызывается API с протоколом HTTP c бизнес-логикой обработки события.

Управление нагрузкой#

Через API или UI сервиса Batch Tasks можно управлять нагрузкой на клиентский сервис (HttpTarget):

1. С помощью параметра maxRunningTasks регулировать количество одновременно обрабатываемых Задач.

2. С помощью параметра label снизить или увеличить процент нагрузки обрабатываемых Очередей.

Сценарий 2. Отправка уведомлений#

Вводные данные#

Дано:

• список держателей кредитного договора;

• информация по условиям кредитного договора.

Необходимо:

• уведомление о внесении платежа приходит в день платежа в 12.00.

Решение#

Бизнес-логика обработки события должна быть реализована как HTTP API. Также необходимо совместное использование сервисов Batch Scheduler и Batch Tasks.

1. Сервис Batch Scheduler в 12:00 текущего дня запускает Задание (Job) на выполнение.

2. Задание создает в сервисе Batch Tasks Очередь (Queue) и Задачи (Tasks) для этой Очереди, состоящей из списка лиц, которым необходимо внести сегодня платеж.

3. Пользователь вызывает метод heartBeat через каждые 5 мин для мониторинга статуса выполнения Задания.

4. Задачи начинают выполняться с начала Очереди, отправляя уведомления о платеже по списку из указанных контактов (Очередь в процессе выполнения может дополняться новыми Задачами).

5. При выполнении последней Задачи (отправки последнего уведомления) пользователь вызывает финальный метод callback для завершения работы Очереди.

6. Пользователь отправляет финальный метод callback для завершения работы Задания (Job).

Управление нагрузкой#

Через API или UI сервиса Batch Tasks можно управлять нагрузкой на клиентский сервис (HttpTarget):

1. С помощью параметра maxRunningTasks отрегулируйте количество одновременно обрабатываемых Задач.

2. Чтобы глобально снизить/увеличить процент нагрузки, объедините Очереди в группы (с помощью параметра label).