2.12. Репликация объектов¶
Механизм репликации объектов позволяет отправлять объекты во внешние системы в нужном формате.
Для работы репликации в системе должна быть определена роль output_processor и
настроена конфигурация роли.
После успешной обработки на роли input_processor объект направляется в хранилище
(роль storage) с определенным ключом маршрутизации. Если в конфигурации
системы для данного ключа предусмотрена репликация, объект также отправляется в
очередь репликации. Далее объект проходит так называемый preprocessing —
обрабатывается в пайплайне, указанном в конфигурации
для роли output_processor, и отправляется во внешнюю систему при
помощи роли connector, где уже определен endpoint внешней системы.
Также возможно настроить репликацию определенных типов объектов, попавших в ремонтную очередь. Это тоже настраивается в конфигурации системы.
Если во время репликации объекта произошла ошибка, объект попадает в специальную ремонтную очередь репликации. Ее функционал идентичен ремонтной очереди, но различие в том, что ремонтная очередь репликации содержит объекты, которые не удалось реплицировать, а не объекты, которые не удалось сохранить. Администрировать объекты в ремонтной очереди репликации можно через web-интерфейс на вкладке Output_Processor.
Информация об объектах в этой ремонтной очереди, а также операции над ними (фильтрация, Try again, Delete и т.д.) аналогичны информации и операциям в основной ремонтной очереди. Отличаются только статусы объектов в этих двух очередях. В ремонтную очередь репликации объекты попадают в результате двух типов ошибок:
ошибка на этапе обработки реплицируемого объекта (preprocessing) — статус «Preprocessing error»;
ошибка на этапе отправки объекта во внешнюю систему — статус «Sending error».
При повторной операции (Try again) над объектом его статус меняется на «In Progress». Если повторная операция успешна, объект переходит на следующий этап обработки или удаляется из ремонтной очереди (в зависимости от предыдущего статуса). Если повторная операция завершилась ошибкой, статус объекта меняется на «Rereplicated (Preprocessing error)» или «Rereplicated (Sending error)» (в зависимости от предыдущего статуса) и объект остается в ремонтной очереди репликации.