Я планирую использовать Служебную шину, вызванную функцией Azure , для обработки сообщений об ошибках. При этом я клонирую сообщение и удаляю все кавычки из клонированного сообщения, если оно есть. Итак, по сути это будет новое сообщение с новыми идентификаторами. После этого я отправлю это клонированное сообщение в основную очередь для обработки.
Крайний случай, на который я обращаюсь, заключается в том, что, если само мое сообщение повреждено таким образом, что оно может быть доставлено успешно, но обработка не удалась по какой-то причине. Таким образом, сообщение доставляется получателю максимальное количество раз, а затем перемещается в DLQ. После этого моя функция DLQ Azure забирает его, клонирует сообщение и отправляет обратно в основную очередь. Теперь это может продолжаться бесконечно .
Цели:
Как определить, сколько раз это сообщение был перемещен из DLQ в основную очередь? Моя цель здесь - остановить доставку в основную очередь через фиксированное количество раз.
Каков подходящий дизайн для обработки таких поврежденных сообщений. Я думаю, что, как только я смогу идентифицировать такие поврежденные сообщения, я перенесу их в какое-нибудь хранилище таблиц для ручной проверки.