0

我试图通过在 .NET 中使用 AzureStorage.Queue 来解决 1 个问题。

首先，我有 2 个项目，1 个 Web API 项目，1 个 WebJob 项目。（全部写在 .NET Core 2.2 中）

  • 我的项目 API 在创建新产品时，会将产品的 1 个消息存储 ID 插入 Azure 中的消息队列（队列名称：产品）

  • 同时在我的项目 Web Job 中，当新消息插入我的“产品”队列时，我有 1 个函数使用 [QueueTrigger["product"]] 来监听。但我不知道为什么将消息插入“产品”队列后，我的消息会自动删除并插入另一个队列名称“产品毒药”？

  • 我在 2 Project 中使用与 Azure 存储相同的连接字符串。我尝试使用不同的连接字符串，但结果是一样的。

谢谢你支持我。

4

1 回答 1

0

您的队列触发器函数使用了您的 API 项目生成的消息，并且该函数似乎没有以正确的格式使用它。

这里有一篇文章讲述了为什么会生成毒队列：毒消息

当队列触发函数失败时，Azure Functions 会针对给定的队列消息重试该函数最多五次，包括第一次尝试。如果所有五次尝试都失败，函数运行时会将消息添加到名为 -poison 的队列中。

于 2021-02-02T09:15:37.060 回答