Руководство пользователя Менеджера Сценариев

6.Администрирование.

6.3.Просмотр необработанных сообщений.

Блок «Просмотр необработанных сообщений» представляет собой специализированный инструмент мониторинга и управления для работы с сообщениями Apache Kafka, которые не смогли быть корректно обработаны в автоматическом режиме.

Этот функциональный модуль обеспечивает полную видимость проблемных сообщений в асинхронной шине данных, аккумулируя в едином интерфейсе всю информацию о сообщениях, завершившихся ошибками обработки.

Система автоматически идентифицирует и классифицирует сбои, предоставляя администраторам и разработчикам централизованный доступ к диагностическим данным. Особое внимание уделено диагностике причин сбоев: система предоставляет полную трассировку ошибок, стек вызовов, контекст выполнения и параметры повторных попыток, что позволяет точно идентифицировать корневые проблемы на уровне кода приложения, конфигурации сервисов или инфраструктурных ограничений. Интеграция с системой заданий обеспечивает сквозную трассировку от сообщения Kafka до конкретных экземпляров обработки в планировщике.

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

Область «Просмотр необработанных сообщений» показывает необработанные или вызвавшие ошибки сообщения. Пример некоторых необработанных сообщений приведён на рисунке 50.

Расположение блока:

1. Раздел «Администрирование»: общий просмотр всех необработанных сообщений.
2. В карточке расписания: фильтрованный просмотр по конкретному сервису.

{
  "orderId": "CUST-5567",
  "action": "update"
}

<Rows>
  <Row>
    <data>
      <header>
        <shop>71</shop>
        <id_doc>659846</id_doc>
        <year_doc>2024</year_doc>
        <num_doc>27221</num_doc>
        <typ_otgr>1</typ_otgr>
      </header>
      <t_rev nil="true"/>
      <!-- ............... -->
      <test_id>564</test_id>
      <id_test>14135596</id_test>
      <unit_test>
        <unit_control nil="true"/>
        <test_print_if>ПОУМ</test_print_if>
        <typ_test nil="true"/>
        <desc_head>V</desc_head>
        <norma_min>0</norma_min>
        <norma_max>0.01</norma_max>
      </unit_test>
    </data>
  </Row>
</Rows>

{
  "X-Scnman-Priority": "9",
  "X-Scnman-Session": "422f8394-bc33-42ea-937e-ea0cd6d0b662",
  "X-Scnman-Uid-Enc": "VS5leHRfY2xuX216dW10el9zZXJ0Lkluc2VydENhckZvclNlbmRBbGw=",
  "sourceRequest": "<sourceRequest><root/></sourceRequest>",
  "X-Scnman-Address": "192.168.1.64:7799",
  "X-Scnman-Store-Response": "N",
  "X-Scnman-Request-Content-Type": "application/xml",
  "X-Scnman-Task": "2096838",
  "X-Scnman-Unique-Id": "U.ext_cln_mzumtz_sert.InsertCarForSendAll",
  "X-Scnman-Timestamp": "1738220990000",
  "X-Scnman-StartDateTime": "2025-01-30 12:09:50.521",
  "X-Scnman-Sched-Id": "671",
  "X-Scnman-Repeats-Count": "10",
  "X-Scnman-Target-System": "parent.child.item/dbbroker",
  "X-Scnman-UseObjectStorage": "N",
  "X-Scnman-System-Name": "parent.child/dbbroker",
  "Uber-Trace-Id": "4c54b5f833cc384f:89058c1d5e304f50:4c54b5f833cc384f:1",
  "REST_URL_PREFIX": "http://polusesb-test4.esb.corp.mzumtz.kmtmz.su:8280",
  "Content-Type": "application/xml"
}

Ссылка в столбце «УИ Сервиса» открывает страницу описания сервиса в Реестре Сервисов.

Кнопка в столбце «Сообщение» открывает всплывающее окно просмотра сообщения в том формате, в котором оно было передано (рисунок 51).

Кнопка в столбце «Заголовки сообщения» открывает всплывающее окно просмотра заголовков сообщения в подсвеченном формате JSON (рисунок 52).

Ссылка в столбце «Тип/код ошибки» открывает всплывающее окно просмотра сообщения об ошибке в текстовом формате рисунок 53).

Кнопки «Удалить собщение» и «Повторить отправку собщения» (рисунок 54) появляются после выбора хотя бы одного необработанного сообщения аналогично выбору состояний в разделе 5.2. «Просмотр состояний». Кнопка «Удалить собщение» при нажатии удаляет выбранные сообщения, а кнопка «Повторить отправку собщения» повторяет их отправку.

1. Функциональные возможности.
   1. Поиск и фильтрация.

      Поле «Фильтр» в верхней части таблицы позволяет осуществлять:

      • быстрый поиск по всем видимым полям таблицы;
      • нечеткий поиск (регистронезависимый);
      • поиск по частичному совпадению.
   2. Сортировка данных.

      Большинство колонок поддерживают сортировку:

      • клик по заголовку колонки для сортировки по возрастанию;
      • повторный клик - по убыванию;
      • индикатор сортировки отображает текущее направление.
   3. Пагинация.

      Блок поддерживает работу с большими объемами данных:

      • выбор размера страницы: 50, 100, 250, 500, 1000 записей;
      • навигация между страницами;
      • отображение общего количества страниц.
   4. Детальный просмотр.

      Диалоговые окна для детального анализа.

      A. Просмотр содержимого сообщения:

      • полное тело сообщения в формате JSON/XML/Text;
      • возможность копирования содержимого;
      • форматированный вывод для удобства чтения.

      B. Просмотр заголовков сообщения:

      • все метаданные сообщения в структурированном виде;
      • информация о трассировке (traceId, spanId);
      • технические параметры обработки.

      C. Просмотр ошибки обработки:

      • детальное описание ошибки;
      • stack trace (при наличии): подробный отчет о выполнении программы в момент возникновения ошибки позволяет диагностировать корневую причину, определить точное место сбоя, идентифицировать проблемный метод или сервис, понимать последовательность событий.
   5. Групповые операции.

      Механизм выбора сообщений:

      • одиночный выбор: checkbox в колонке «Действия»;
      • групповой выбор: checkbox в заголовке таблицы;
      • визуальная индикация выбранных элементов.

      Доступные операции для выбранных сообщений.

      A. Удаление сообщения:

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

      B. Повторная отправка сообщения:

      • отправка сообщения на повторную обработку;
      • сообщение удаляется из текущей очереди после отправки;
      • используется для временных сбоев.
2. Бизнес-сценарии использования.
   1. Мониторинг проблемных сообщений:
      • регулярная проверка наличия необработанных сообщений;
      • анализ трендов по типам ошибок;
      • выявление проблемных сервисов.
   2. Диагностика сбоев:
      • анализ содержимого проблемных сообщений;
      • идентификация корневых причин ошибок;
      • определение шаблонов сбоев.
   3. Восстановление обработки:
      • массовая повторная отправка сообщений после устранения проблем;
      • выборочное удаление некорректных сообщений;
      • приоритизация критичных сообщений.
   4. Анализ качества данных:
      • проверка форматов входящих сообщений;
      • валидация бизнес-логики обработки;
      • мониторинг соответствия SLA.
3. Особенности работы.
   1. Контекстный просмотр.

      При открытии блока из карточки расписания:

      • автоматическая фильтрация по УИ сервиса;
      • фокус на сообщениях конкретного сервиса.
   2. Производительность:
      • загрузка данных при открытии панели;
      • оптимизированные запросы к API.
   3. Безопасность:
      • проверка прав доступа (accessLevel);
      • подтверждение деструктивных операций;
      • логирование всех действий пользователя.
4. Рекомендации по использованию.
   1. Регулярные действия:
      • ежедневная проверка наличия новых необработанных сообщений;
      • анализ сообщений с большим количеством повторов;
      • мониторинг сообщений с истекшим временем жизни.
   2. Действия при обнаружении проблем:
      • проанализировать тип ошибки и содержимое сообщения;
      • связаться с командой разработки проблемного сервиса;
      • принять решение о повторной отправке или удалении.
   3. Best Practices:
      • не удалять сообщения без анализа последствий;
      • документировать причины удаления сообщений;
      • согласовывать массовые операции с ответственными командами.

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