问题标签 [queuetrigger]

我的情况是。

功能超时设置为 1 小时

功能 1 开始，需要 2 小时才能完成

功能 2 从功能 1 开始 30 分钟后开始

当函数 1 达到超时时，它也会中断函数 2。

我想知道函数是否达到超时，会重试吗？会不会打断别人跑步？

我正在尝试在本地运行 azure queue trigger 功能。我安装了 Azure Storage Emulator 并运行命令“AzureStorageEmulator.exe init”在“(localdb)\MSSQLLocalDB”服务器上创建“AzureStorageEmulatorDb59”数据库。

在具有队列触发功能的天蓝色函数项目中，我有一个 local.settings.json 文件。应该在该文件中添加哪些设置，连接字符串到底应该是什么，我应该在哪里添加它？下面提到我的队列触发功能。应该添加什么来代替“QueueTrigger”属性后提到的“my-queue”？请在这件事上给予我帮助

我知道有一个规模控制器可以监视 Azure Functions 中的事件，但我想知道它如何在低级别与存储队列触发器一起工作：

• 它是否每 x 毫秒向队列发送请求以检查新消息？
• 是否有另一个过程可以完成这项工作并与秤控制器通信？
• 有没有办法看到这一点？
• 我们如何知道正在监视哪个存储帐户和队列？

提前致谢。

我正在尝试在 Azure Web 作业的队列中获取当前正在处理的消息的消息 ID。找不到任何关于如何获得它的适当文档。

添加 TestingMessageModel 作为参考，它没有任何指导。我想使用 azure 在将消息放入队列时创建的 GUID。

我正在使用 Python 中的 Azure 函数应用程序，它有两个函数 HTTPTrigger 和 QueueTrigger，在 QueueTrigger 中我调用了我的自定义代码，这需要 10 多分钟才能处理。我在 host.json 中将其从 5 分钟更改为 10 分钟{"functionTimeout": "00:10:00"}。我的问题是，有没有办法通过更新 QueueMessage 内容或 visibilityTimeout 或 Timeout 来延长处理时间？换句话说，如果将消息的不可见性延长到处理完，Function App 的处理时间会延长吗？请参阅 Python API QueueService.update_message() 是否还有其他无服务器选项可以运行长进程？

更新消息的可见性超时。您还可以使用此操作来更新消息的内容。

此操作可用于不断扩展队列消息的不可见性。如果您希望工作人员角色“租用”队列消息，此功能会很有用。例如，如果一个工作角色调用 get_messages 并认识到它需要更多时间来处理一条消息，它可以不断地延长消息的不可见性，直到它被处理。如果工作角色在处理过程中失败，最终消息将再次变得可见，并且另一个工作角色可以处理它。

update_message(queue_name, message_id, pop_receipt, visibility_timeout, content=None, timeout=None)

我在看这个博客

https://medium.com/@yuka1984/azure-functions-%E3%81%AE-singletonattribute%E3%81%A8mode%E3%83%97%E3%83%AD%E3%83%91%E3% 83%86%E3%82%A3-bb728062198e

这个批量大小为 1 的单例将使队列能够在一个实例上一次执行一次队列函数，即使函数横向扩展也是如此。为什么我需要这个，我想防止azure函数调用的数据库不同时更新同一个表，导致数据不一致。

例如，实例 A 在数据库中执行检查数据并修改了一些值。同时，实例 B 执行检查数据库中的数据并修改值。预期结果是 A 先于实例 B 修改数据，但 B 执行速度比实例 A 快，因此实例 B 先更新。这不是我的预期结果。

执行顺序很好，但我不想混淆插入数据。

实例 A 有数据 [1,2,3,4] 实例 B 有数据 [2,4,6,7]

如果执行 A 或 B，结果将是 [1,2,3,4,6,7] 如果同时执行，则有可能有 [1,2,2,3,4,6,7]

在执行A时，执行B时表中可能还没有'2'。因此B也插入了'2'。在这种情况下，我有重复的数据。

博客是否保证满足要​​求？还有其他选择吗？

我有一个带有 QueueTrigger 的 Azure WebJobs：

WhereMyCustomStorageConnection与默认作业连接不同（这就是我在 QueueTrigger 属性中定义它的原因）。我还有两个本地文件，它们定义了 dev 和 prod 环境的设置：appsettings.json和appsettings.Production.json.

当我启动 WebJobs 时，我正在读取config对象的有效配置和设置

并且存储了有效的连接，config.GetConnectionString("MyCustomStorageConnection")但没有地方可以与主机设置它。并且每当主机启动时，都会QueueTrigger从 读取值appsettings.json并完全忽略appsettings.Production.json.

如何强制 QueueTrigger 使用正确的配置或仅定义 QueueTrigger 连接字符串的值？

Azure 队列触发函数应用如何确定方法是否成功？

我有一个 Azure 队列触发器应用程序。它尝试尽快处理消息，但是当我在队列中有 1000 条消息时，我想限制它每秒处理的队列消息数。有没有办法设置限制？

我的目标是减慢我的函数处理消息的速度。

我有一个函数应用程序，它在上传或更新 blob 时触发。但在我的要求中，我的容器一次可能会收到数千个 blob（客户将批量上传 blob 到容器）。在这种情况下，据我所知，函数应用程序将为容器中的每个 blob 并行运行。但我需要在队列中处理它们。所以，我想在这里使用队列存储。每当上传 Blob 时，让我通过 Blob 触发函数应用程序将该 Blob 名称作为队列消息添加到队列存储，然后我将拥有一个队列触发函数应用程序，它将触发和处理队列中的 Blob。如果我的方法有误，请纠正我？另外，我需要知道有没有办法从函数应用程序中添加队列消息。