存储队列触发的 Azure Functions 是接收单个消息还是所有消息?
如果我创建一个由存储队列消息触发的 Azure 函数...系统会启动多个并行函数以访问队列中的每条消息，还是会调用一个读取所有可用消息的函数? 简而言之，排队的消息是单独处理还是批量处理? 解决方案 在 API 方面，您的函数将在队列中的每条单独消息中调用一次. 但 Azure Functions 运行时会批量检索和处理消息，并行调用函数的多个实例.
..
azure-storage-queues相关内容
为通过 Azure 函数输出绑定添加到 Azure 队列的消息设置 VisibilityTimeout
我有一个 TimerTrigger 函数，输出绑定是一个 Azure 队列. 这个想法是每 10 分钟计时器将运行一次，它会查看我的数据库中的一个视图并遍历返回的任何行，将它们作为消息添加到队列中. 下面是我的示例 TimerTrigger.将消息添加到队列中效果很好. 但是，在我的真实世界场景中，有些行需要立即执行，而另一些行会延迟几分钟(每行有所不同).我计划通过对消息使用
..
Azure函数和存储队列，如果函数失败怎么办
我正在研究一种将消息发布到 Azure 存储队列的方案.出于测试目的，我开发了一个控制台应用程序，我可以在其中获取消息，并且可以使用尝试计数来更新它，当逻辑完成后，我会删除消息. 现在我正在尝试将我的代码移植到 Azure 函数.一件似乎非常不同的事情是，当调用 Azure 函数时，消息会从队列中删除. 我发现很难找到关于这个特定主题的任何文档，而且我觉得我在结合这两者的概念方面遗漏了
..
在 Azure 队列存储中传递对象消息
我正在尝试找到一种将对象传递到 Azure 队列的方法.我找不到办法做到这一点. 正如我所见，我可以传递字符串或字节数组，这对于传递对象来说不是很舒服. 有没有办法将自定义对象传递给队列? 谢谢！ 解决方案 您可以使用以下类作为示例: [可序列化]公共抽象类 BaseMessage{公共字节[] ToBinary(){BinaryFormatter bf = new
..
Azure 函数和存储队列，函数失败怎么办
我正在设计一个向 Azure 存储队列发布消息的场景.出于测试目的，我开发了一个控制台应用程序，我可以在其中获取消息并使用尝试计数更新它，当逻辑完成后，我会删除该消息. 现在我正在尝试将我的代码移植到 Azure 函数.似乎非常不同的一件事是，当调用 Azure Function 时，消息从队列中删除. 我发现很难找到关于这个特定主题的任何文档，而且我觉得我在将这两者结合的概念方面遗漏
..
通过Logic App将JSON消息放置/发布到Azure存储队列
我希望能够使用Logic App在Azure存储队列中放置/发布消息，因为我想使用 HTTP Logic App acion提供的托管身份选项. 我有一个逻辑应用程序，该应用程序使用HTTP操作将XML消息发布到队列中，并且有一个“将消息放入队列中"操作，该操作将JSON消息放入队列中以进行调试. 我的最终目标是能够将HTTP操作与托管身份作为身份验证一起使用，但能够将JSON消息发布
..
使用多个Azure Functions QueueTriggers侦听同一存储队列
我有一个Azure Functions QueueTrigger，它在存储队列上侦听以下消息: 消息文本--------------------------{"ClientName":"client1"}{"ClientName":"client2"}{"ClientName":"client3"} 然后QueueTrigger具有如下代码: 如果'client1'== queue_msg
..
您可以对Azure功能或存储队列的输出进行评级吗?
我有一个由存储队列触发的Python Azure函数，该函数将作业提交给第三方限速API(每分钟1个请求).触发该函数的队列将定期接收一连串消息，因此，我需要一种方法来确保在接收到第一条消息后立即触发该功能，第二条消息后1分钟，第三条消息后2分钟，直到队列为空. 是否可以对队列或函数进行速率限制，所以我每分钟只运行一次函数，直到队列为空? 解决方案 没有办法对存储队列进行速率限制(除
..
Azure存储队列和最多一次交付
给我的印象是存储队列不支持此功能，但是经过调查后我找不到这方面的证据. MSDN文章说“至少一次"，但我能找到的最多信息是第一个使用者获得了该消息并将该消息设置为不可见. 然后，当它再次变得可见时，可以再次拾取它. 但是，我可以将“隐形"设置为较大的“时间跨度"，并且可以检查出队计数以将其限制为“一次发送". 这是基于这样一种假设，即竞争的消费者无法同时获得我无法验证的同一
..
带有Node.js createQueueService错误的Azure存储模拟器
当我尝试连接到模拟的存储队列服务时收到以下错误: 在HTTP请求"..."中找到的MAC签名与任何计算出的签名都不相同. 确保包括标题在内的Authorization标头的值正确形成. 这是我用来连接到Azure存储的方法: var storageAccount ='devstoreaccount1'var accessKey ='Eby8vdM02xNOcqFlqUwJPL
..
Azure WebJob QueueTrigger重试策略
我希望让我的队列每90分钟重试失败的Web作业，并且尝试3次. 创建队列时，我使用以下代码 CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();IRetryPolicy linearRetryPolicy = new LinearRetry(TimeSpan.FromSeconds(5400)，3)
..
使用一个或多个标准FIFO队列实施延迟队列
延迟队列是一个队列，其中每个消息都有一个与之关联的延迟时间，并且仅当其延迟到期时才可以获取消息.队列的开头是该消息，其延迟在过去最远的时候到期.如果没有延迟，则没有头，出队将返回null. 实际上，我正在使用Azure编写云应用程序，并且在Azure中只有FIFO队列可用，而没有优先级/延迟队列.所以我来到这里是为了寻找是否有人可以给我一些指导，让我从正确的方向开始.我在Google上搜索了
..
在Azure Webjobs SDK中设置nextVisibleTime
我正在使用Azure Webjobs处理队列中的消息. 我看到Webjobs SDK在10分钟后再次处理任何失败的消息，并且如果失败5次，则会将其移至中毒队列(我还可以在插入时间(我想对消息使用AzureSDK错误处理，但是我不能等待10分钟才能再次处理消息. 有什么办法可以将nextVisibleTime设置为几秒钟? 创建一个Azure App Service中的.NET W
..
Azure存储队列和多个WebJobs实例:QueueTrigger会在触发时设置消息租用时间吗?
场景:生产者将一条消息发送到存储队列中，一个WebJobs在QueueTrigger上处理该消息，每条消息只能被处理一次，可能有多个WebJob实例. 我一直在使用Google搜索，从阅读的内容来看，我需要编写将消息处理为幂等的函数，这样就不会对消息进行两次处理.我还读到一条消息的默认租用时间为10分钟. 我的问题是，当在一个WebJob实例上触发QueueTrigger时，它是否设置
..
通过WebJobs在Azure存储队列中重新排队或删除消息
我希望有人能澄清有关Azure存储队列及其与WebJobs交互的一些事情: 要执行重复的后台任务(即添加到队列一次，然后以设置的间隔重复)，有没有一种方法可以更新QueueTrigger函数中传递的相同消息，以便可以将其租期(可见性)扩展为一种重新排队并避免到期的方法? 使用上述重复出现的后台作业模式，我还试图找到一种“按需"删除/过期作业的方法.由于这在WebJobs的上下文之外似乎
..
Azure存储队列-处理时间长
我需要生成大量报告，并且一个报告可能需要大约5分钟才能生成，大量数据以及许多不同的来源. 客户端将消息发布到Azure存储队列.有一个工作人员角色来处理消息并生成报告. 如果我想扩大规模，可以说我有10个工作角色，这些角色将处理队列中的消息并生成报告.然后，我将消息添加到队列中，如下所示: 消息1:处理1-5中的报告 消息2:处理6-11中的报告 ........ 消息10:
..
Microsoft.WindowsAzure.Storage更新到V8.2.1.0破坏了我的代码
我创建了一个WebJob，将项目放入队列中，在我将 Microsoft.WindowsAzure.Storage 更新为 v8.2.1.0 并我现在收到此错误 “无效的存储帐户'devstoreaccount1'.请确保您的 凭据是正确的.' 在更新之前，它运行得非常好，这是一个问题吗?解决办法是什么? 解决方案 根据此 客户端库使用特定的存储服务版本.为了将Storage
..
如何加快Azure存储队列
我已尽我所能想到的一切来提高插入速度.这实际上只是几件事，没有任何改善. 我需要将标识符(Int64)块发送到队列，以便我的多个工作角色都可以在该队列上工作，而不必担心并发性. 我尝试了foreach循环(同时使用.ToString()和BitConverter.GetBytes()): foreach(long id in ids) { queue.AddMessage
..
Azure存储队列消息(在特定时间显示)
如何将消息添加到Azure队列存储中，该消息将在明天恰好在24小时后显示在队列中? 解决方案 如果使用的是存储客户端库，则可以在CloudQueue中使用addMessage重载，该重载将初始可见性延迟作为输入参数. 具体来说，您必须在2.0中使用以下重载: AddMessage(CloudQueueMessage message, TimeSpan? timeToLive =
..
Azure队列-功能-邮件可见性-工人?
我对有关Azure队列，函数和工作器的功能有一些疑问.我不太确定这是如何工作的. 场景: q-notifications是Azure存储帐户中的队列. fli-process-notification是Azure中绑定到q-notifications的函数.它的工作是获取队列中的第一条消息并对其进行处理. 理论上，当将消息添加到q通知时，应调用f-process-notific
..