在 Azure 存储中使用队列
Using Queue in Azure Storage
我正在尝试在 .NET 中使用 AzureStorage.Queue 解决 1 个问题。
首先,我有 2 个项目,1 个 Web 项目 API,1 个 WebJob 项目。 (全部写在.NET Core 2.2)
我的项目API在创建新产品时,它会将产品的1个消息存储ID插入到Azure中的消息队列(队列名称:产品)
同时在我的项目 Web 作业中,我有 1 个函数使用 [QueueTrigger["product"]] 来监听新消息插入我的“产品”队列时。但我不知道为什么在消息插入到“product”队列后,我的消息自动删除并插入到另一个名为“product-poison”的队列中?
我在 2 Project 中使用与 Azure 存储相同的连接字符串。我尝试使用不同的连接字符串,但结果是一样的。
谢谢你支持我
您的队列触发器函数使用了您的 API 项目生成的消息,而且该函数似乎没有以正确的格式使用它。
这里有一篇文章说明了为什么生成毒队列:Poison messages
When a queue trigger function fails, Azure Functions retries the
function up to five times for a given queue message, including the
first try. If all five attempts fail, the functions runtime adds a
message to a queue named -poison.
我正在尝试在 .NET 中使用 AzureStorage.Queue 解决 1 个问题。
首先,我有 2 个项目,1 个 Web 项目 API,1 个 WebJob 项目。 (全部写在.NET Core 2.2)
我的项目API在创建新产品时,它会将产品的1个消息存储ID插入到Azure中的消息队列(队列名称:产品)
同时在我的项目 Web 作业中,我有 1 个函数使用 [QueueTrigger["product"]] 来监听新消息插入我的“产品”队列时。但我不知道为什么在消息插入到“product”队列后,我的消息自动删除并插入到另一个名为“product-poison”的队列中?
我在 2 Project 中使用与 Azure 存储相同的连接字符串。我尝试使用不同的连接字符串,但结果是一样的。
谢谢你支持我
您的队列触发器函数使用了您的 API 项目生成的消息,而且该函数似乎没有以正确的格式使用它。
这里有一篇文章说明了为什么生成毒队列:Poison messages
When a queue trigger function fails, Azure Functions retries the function up to five times for a given queue message, including the first try. If all five attempts fail, the functions runtime adds a message to a queue named -poison.