Использование очереди в хранилище Azure

Я пытаюсь решить 1 проблему с использованием AzureStorage.Queue в .NET.

Во-первых, у меня есть 2 проекта, 1 проект Web API, 1 проект для WebJob. (Все пишут в .NET Core 2.2)

  • API моего проекта при создании нового продукта вставляет 1 идентификатор хранилища сообщений продукта в очередь сообщений в Azure (имя очереди: продукт)

  • В то же время в моем проекте Web Job у меня есть 1 функция, использующая [QueueTrigger [product]] для прослушивания, когда новое сообщение вставлено в мою очередь продукта. Но я не знаю, почему после того, как сообщение было вставлено в очередь продукта, мое сообщение автоматически удалялось и вставлялось в другую очередь, имя продукта-яд?

  • Я использую ту же строку подключения к хранилищу Azure в 2 Project. Я пытался использовать другую строку подключения, но результат тот же.

Спасибо за поддержку.


person hai pham    schedule 02.02.2021    source источник
comment
Прочтите здесь об обработке ошибок и опасных очередях blog.tech-fellow.net/2019/02/06/   -  person silent    schedule 02.02.2021
comment
@silent Спасибо за вашу поддержку.   -  person hai pham    schedule 02.02.2021


Ответы (1)


Ваша функция триггера очереди использовала сообщение, созданное вашим проектом API, и, похоже, функция не использовала его в правильном формате.

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

Когда функция триггера очереди не работает, Функции Azure повторяют выполнение функции до пяти раз для заданного сообщения очереди, включая первую попытку. Если все пять попыток терпят неудачу, среда выполнения функций добавляет сообщение в очередь с именем -poison.

person Doris Lv    schedule 02.02.2021