问题标签 [queuetrigger]

我们如何通过服务总线队列触发函数将服务总线队列消息移动到死信

我查看了这篇文章，以便在一次 webjob 执行中一次获取多条消息（以累积多条消息的结果）。然而，这个 api: Microsoft.Azure.WebJobs.Extensions.GroupQueueTrigger 没有提供关于当我们无法处理下载的批次中的一条消息时会发生什么的文档，它会再次尝试整个批次吗？或者它只是将失败的消息移动到毒队列？有人知道吗？

我们有一个使用队列触发器调用的网络作业，每次提交订单时都会触发该队列触发器。

在过去的一周里，我们有一些非常高的订单活动，而我们的 webjob 并没有为少数这些订单运行。我们设置了电子邮件和松弛通知，以便在 Web 作业失败时发送，但根本没有触发这些通知，因为作业根本没有运行。有谁知道是什么原因造成的？我们的订单活动是否触发了这个 webjob 太多次？

队列功能在开发人员机器上运行良好。但是一旦发布到 Azure，一两天后，该功能就不会选择队列消息。队列消息显示在存储帐户队列中并且未出队。

当我们在监视器中使用 Run 命令时，它正在选择队列消息并成功处理。

供您参考：没有访问问题，所有应用程序和 id 和机密都已正确配置，都托管在同一个租户中，没有生成异常。

我在 Python 中设计了一个 Azure Queue Trigger 函数，具有以下功能。

1. 当一条消息添加到名为 Input 的队列中时，该函数会触发
2. 它处理添加到输入队列的消息并将结果存储在输出队列中

现在我的问题是当我在本地运行时它工作正常。但是在部署函数应用程序之后，如果我向 Input Queue 添加一条消息，该函数不会触发。

检查了一切。这是我的 function.json 供参考。

我无法在文档中找到与此相关的任何内容，并且不确定我缺少什么。

我在 C# 中开发了一个队列触发的 azure 函数。该函数在 AppService 计划上运行。我们想要实现自定义的自动横向扩展。我们计划在 CPU 百分比高于 60% 时将实例数增加 1

我的问题是：

1. 将实例数增加到 60% 是否是个好主意？
2. 我进行了研究，发现对于 blob 触发的 azure 函数，有一种机制可以防止两个实例选择相同的队列条目。C# Queue Triggered Azure Function 有相同的机制吗？
3. 在我的函数代码中，我编写了 Thread.Sleep(3000) 在某些情况下使线程休眠。横向扩展时会导致任何问题吗？
4. 在我的场景中进行扩展时，还有什么我应该记住的吗？

提前致谢。

我想通过使用由 Azure 队列触发的 azure 函数来创建团队。不幸的是，当我运行代码时，它在 Azure 函数中不起作用。

我在想。有没有办法在 Azure Function 中使用 PowerShell 创建 Microsoft Team？

在当地工作。在 Azure 函数中不起作用。

波纹管我得到的错误：

谢谢

我想了解一些关于如何做这样的事情的信息。

我已经安装了Visual Studio Code 的插件，我已经在我的 PowerShell 脚本的开头导入了模块，我已经用适当的模块名称填充了requirements.psd1 。不过，当我启动命令时，什么也没有发生。

我的目标是使用 PowerShell 在 Microsoft Teams 中创建一个团队。

我放了一个断点，它永远不会到达。我究竟做错了什么 ？

谢谢你。

我一直在使用QueueTrigger. 我通过使用以下代码将某些内容放入队列来测试我的队列。

这很好用，但是我需要做的是将此代码放入 Nuget 包中。困扰我的是我必须将ConnectionString我的 StorageAccount 硬编码在 Nuget 包中。这个包将被第 3 方应用程序使用。

我可以使用带有 的 Azure 函数HttpTrigger，但这违背了使用队列的目的。

QueueTrigger在不暴露ConnectionString我的存储帐户的情况下，使用 将 Nuget 包中的内容放入队列的最佳方法是什么？

或者HttpTrigger在这种情况下我唯一的选择是使用 a 吗？

我已将 QueueTriggered 函数应用部署到 Azure 门户。但似乎有时会抛出超时超出异常。我收到了这个错误，并想将 functionTimeout 值从 30 分钟更改为 2 小时。
但它仍然给我同样的错误。我担心的是，为什么 QueueTrigger 会抛出这个错误。它的工作是传递信息。
我从队列消息中获取一个 blob 名称，并将其作为参数传递给 Snowflake 过程以加载该 blob。雪花几乎不需要一分钟来加载那个 blob。但是为什么会发生函数应用超时。
我得到的错误是：

调用堆栈：

我使用 Python 开发的代码：

有什么帮助可以解决这个问题吗？