Page tree
Skip to end of metadata
Go to start of metadata
НазваниеКоличество одновременно выполняемых экземпляровГде и как настраивается расписаниеЧто делает
Отправка данных в RabbitMQСоздается по одному экземпляру регл. здания на каждое Расписание, указанное в Получателях, выполняется постоянно (ожидание через компоненту sleep), перезапуск при падении согласно расписанию

Расписание отправки сообщений каждым заданием указывается в справочнике "Расписание обмена".

После отправки всех сообщений заданя ждет 3 секунды и снова проверяет наличие сообщений на отправку. Продолжительность выполнение одного задания 10 мин.

Через консоль регл. заданий можно отключить или изменить интервал перезапуска при падении

Отправляет данные, накопленные в РС "Лог не доставленных сообщений"
Получение данных из RabbitMQ

Создается по одному экземпляру регл. здания на каждый источник данных (для источников схем и данных лога не создается)

В рамках каждого регл задания по пакетному источнику данных создается несколько фоновых заданий (из реквизита Количество потоков при пакетном получении сообщений)

Все задания по получению данных выполняются постоянно, и ожидают сообщения в очередях, используя таймаут в компоненте обмена

Расписание и таймаут ожидания новых сообщений каждым заданием указывается в справочнике "Расписание обмена" (которое задается для каждого Источника данных)

По умолчанию получение работает постоянно, перезапуск при ошибке через 60 секунд

  1. Получает сообщение из очереди
  2. Разбирает его и помещает в базу
  3. Результат обработки (в т.ч. ошибки) пишется в лог
  4. Если возникла ошибка, то в зависимости от настройки источника, либо пропускает проблемное сообщение, либо останавливает чтение очереди
  5. Если объект требует отложенной обработки, то пишется в регистр для отложенной обработки
Получение логов из RabbitMQВсегда 1 экземпляр, выполняется постоянно (ожидание через компоненту sleep), перезапуск при падении через 1 мин

Интерактивной настройки не предусмотрено.

Через консоль регл. заданий можно отключить или изменить интервал перезапуска при падении

  1. Для каждого получателя читает логи из соответствующей очереди.
  2. При возникновении ошибок останавливает чтение очереди
Отложенная обработка объектовВсегда 1 экземпляр, выполняется постоянно (ожидание через компоненту sleep), перезапуск при падении через 1 мин
Расписание можно задать через консоль регл. заданий, по умолчанию запускается каждые 60 сек. Выбирает из регистра объекты, требующие отложенной обработки, и выполняет эту обработку
Удаление истории изменения состояния сообщений обменаВсегда 1 экземпляр по расписаниюВ источниках и получателях данных задается количество дней хранения состояния отправки/получения сообщений (по умолчанию 30 дней). После этого периода сообщения удаляютсяУдаляет старые записи из РС Состояние получения сообщений обмена
  • No labels

2 Comments

  1. Valeriy Dykov

    1. Почему при отправке данных в RabbitMQ у тебя написано, что интерактивной настройки расписания не предусмотрено? Расписание натстраивается в справочнике РасписанияОбмена
    2.  У тебя здесь не освящены впросы с обменом XSD схем, ты отдельно об этом будешь писать?
  2. Valeriy Dykov Отложенная обработка объектов тоже выполняется в sleep-е. Я сделал аналогично ПолучениюЛогов