问题标签 [queuetrigger]

我有一个连续运行的 webjob 被触发来执行后台任务。当工作被触发完成工作时，我找不到跟踪或检查工作是否成功完成的方法。

有没有一种方法可以轻松检查特定消息的触发作业的状态？

功能：

我试图了解队列触发器和服务总线队列触发器之间的区别以及我需要哪一个！

我有一个用于创建和调度类的 asp.net mvc 站点，它将在 db 表中表示为一行。课程结束后，我想向所有学生发送一封电子邮件，要求他们给老师打分

据我所知，最好的方法是创建一个 Azure 函数来创建和发送电子邮件，但我迷失的是如何在特定日期和时间触发该函数？

我使用队列触发器还是服务总线队列触发器？两者之间有什么区别，哪一个最适合我的场景？

如果课程被取消，我需要能够取消队列中的消息。

我有一个 azure 函数，我希望有 2 个不同的队列。
我真的不想拥有 2 个单独的存储库来管理并尝试保持它们相同。为了测试我的函数，我一直在使用预编译器语句，并认为我可以像这样简单地扩展它：

（不知道如何使用“#”符号正确格式化）

我尝试在开发环境的设置中添加一个键值对： CONFIGURATION DEV 无济于事。

我在 Azure webjob 中同时运行多个 QueueTrigger 实例。它是一个函数，但被并行调用多次。

我的函数使用静态变量来缓存多次使用的数据。

有时，当函数运行时，我会在静态对象上发生冲突，这只能由多个尝试同时访问它们的进程来解释，但我被引导相信 queuetrigger 的每个实例都是独立运行的。

所以我的问题是；

queuetrigger 实例是单独执行的吗？

如果没有，是否有在加载“实例”时触发特定事件以便可以加载静态对象？

上下文：我有一个 Azure 存储队列，用作队列触发函数的输入队列。因此，每当一条消息被添加到队列中时，某个函数 X 就会被触发并开始运行。我想测试消息是否已成功放入队列并被使用。如何仅从队列中执行此操作（假设我无法查看函数 X，并且无法更改队列触发函数的设置）？为了进一步分解这个问题：

• 在队列触发函数将消息出列后，我在测试时是否仍可以从中读取该消息？如果是，我该如何访问它？
• 由于这里存在竞争条件，如果我在队列触发器功能开始之前测试时将消息出列，这将如何干扰队列触发器的功能？是否可以在测试时将消息出列，但同时，队列触发器是否可以将其出列并触发我的函数 X 而不会受到任何干扰？
• 最重要的是，我在 Azure 存储队列中有一条队列消息，我想从两个不同的源读取两次，这两个操作之间没有干扰。这可能并得到支持吗？如果是，我该怎么做？

谢谢！

我正在动态创建多个队列，例如 workbook1、workbook2...workbook100。我已经编写了一个 queuetrigger 函数，一旦任何消息到达，它就需要为所有动态创建的队列触发

每当多个队列中有消息时，我想并行触发相同的触发功能。

我正在本地使用 QueueTrigger 在 host.json 文件中使用以下配置测试我的 Azure 功能（v2 目标 .Net Core）

“队列”：{“batchSize”：1，“newBatchThreshold”：0}

目的是限制每个 Function App 实例一次只处理一个队列消息。

根据这个 Azure 函数文档，

如果要最小化函数应用中队列触发函数的并行执行，可以将批处理大小设置为 1。只有当函数应用在单个虚拟机 (VM) 上运行时，此设置才会消除并发。

在 host.json 文件中，有这些配置

{“队列”：{“maxPollingInterval”：2000，“visibilityTimeout”：“00:00:30”，“batchSize”：16，“maxDequeueCount”：5，“newBatchThreshold”：8}}

在我们的例子中，我并不是要消除并发性，而是要确保每个函数应用程序实例一次只处理一个队列消息。然后，如果我们横向扩展函数应用以在多个 VM 上运行，则可以保证每个 VM 一次只处理一个队列 msg。更具体地说，计划是在App Service计划下运行azure功能，而不是Consumption计划（b/c您对Consumption计划几乎没有控制权），并设置Scale Out规则来监控队列，最多N 个实例 (VM)。此设置允许我们将每个 VM 专用于一次运行一个 Azure Function App 实例，最多可运行 N 个 VM。

当我在本地对此进行测试时，我的天蓝色函数总是同时从队列中获取多个消息，即使在 host.json 文件中使用“BatchSize：1”配置也是如此。我想知道是否是 b/c 我正在本地 Azure 函数运行时测试它。我尚未在 Azure 中对此进行测试。希望它在 Azure 中按预期工作。

我正在尝试使用 SDK 3.0.x 开发 WebJob，并在本地对其进行测试。我已经按照 github 中的示例进行了操作，但没有成功。

在本地运行它时一切正常，它也可以看到该ProcessQueueMessage功能，但它不会从队列中选择消息。

程序.cs

函数.cs

这是输出的屏幕截图

感谢你的帮助

队列消息“newrequests”的屏幕截图

在此处输入图像描述

Azure 函数有一个 Queue 触发器，来自 Queue 的数据是序列化的 Json ......即，Web 应用程序序列化 DataType1 类型的对象并将其写入 Queue。Azure 函数必须能够解析 DataType1 的命名空间，以便它可以反序列化它以在函数中使用。

这样做的最佳做法是什么？两个项目都使用 IDataType1 引用的某种帮助程序库？还有其他方法吗？

有一些关于使用 .net 框架在 webjobs v2 中使用 customQueueProcessor 为不同队列配置不同批量大小的文档。我想知道这在 webjobs v3 中是如何处理的？

此批量大小适用于代码中的所有 QueueTrigger。如何为不同的队列使用自定义值？