azure-queues相关内容
我正在使用@azure/service-bus包和sendMessages函数向队列发送消息,如here中所述。 当我发送一个Java脚本数组[{ name: "Albert Einstein", "company": "xyz" }]时,它给出了一个错误TypeError: Provided value for 'message' must be of type ServiceBusMessag
..
我可以从 这个页面看到 当它们用作触发器时,您可以简单地访问队列消息元数据属性,但我想做相反的事情.我有一个将消息写入队列的 Azure 函数,但它当前具有默认的过期时间,我想设置一个更短的过期时间,以便它们只在队列中存活很短的时间. 有没有办法在将消息从 Azure Function 写入队列时设置过期时间? 谢谢 编辑 1:一个警告是我不提前知道队列的名称.那是传入消息的一部
..
我在 Linux 消费计划上有一个 Azure Function 应用,它有两个队列触发器.两个队列触发器都将 batchSize 参数设置为 1 因为它们每个都可以使用大约 500 MB 的内存而且我不想超过 1.5GB 的内存限制,所以他们一次只能接收一条消息. 如果我想允许这两个队列触发器同时运行,但不希望它们超出此范围,请将 functionAppScaleLimit 设置为 2 足
..
我能够在函数应用中使用 Key Vault 如此处所述,但是当我尝试使用 Key Vault 来保存具有队列触发器的函数的连接字符串时,我遇到了存储帐户连接字符串的问题.该函数似乎找到了我提供的参数,但是当它抛出错误找不到有效的帐户信息组合时,要么没有取回秘密,要么不喜欢该信息. 我的函数定义为: [FunctionName("ReadQueueForMessage")]公共静态异步任务
..
我在 Azure 中有一个函数应用程序,它在将项目放入队列时触发.它看起来像这样(非常简化): public static async Task Run(string myQueueItem, TraceWriter log){使用 (var client = new HttpClient()){client.BaseAddress = new Uri(Config.APIUri);client
..
我有这个队列触发器.预期是当我在 Queue 中插入消息时,触发器必须触发并处理出队的消息. [FunctionName("NewPayrollQueueTrigger")]公共异步静态无效运行([QueueTrigger(“myqueue",连接="AzureWebJobsStorage")]string myQueueItem,[DurableClient] IDurableOrchest
..
我知道有一种方法可以确定 Azure 队列(存储帐户)中的消息数量(或近似数量);但是,有没有办法查询 Azure Service Bus 队列中待处理消息的数量? 解决方案 var nsmgr = Microsoft.ServiceBus.NamespaceManager.CreateFromConnectionString(connectionString);长计数 = nsmgr.G
..
我有这个队列触发器.预期是当我在 Queue 中插入一条消息时,触发器必须触发并处理出队的消息. [FunctionName(“NewPayrollQueueTrigger")]public async static void Run([QueueTrigger(“myqueue", Connection =“AzureWebJobsStorage")]string myQueueItem,[
..
我有一个Azure队列存储触发的Webjob.我的webjob执行的过程是将数据索引到Azure搜索中.Azure搜索的最佳实践是出于性能方面的考虑(将索引花费一些时间才能完成),而不是一次将多个项目一起建立索引. 由于这个原因,我希望我的Web作业将多条消息一起出队,以便我可以遍历,处理它们,然后将它们一起编入Azure搜索. 但是,我无法弄清楚如何使我的Web作业一次出库.如何做到
..
我是否完全理解,在Windows Azure队列存储中,一条消息最多可以保留7天? 7天后该消息会怎样? 如果您在7天内阅读了一次并且不删除该消息,该怎么办?我的意思是您从队列中读取了消息,并将可见性超时设置为1分钟.阅读消息(不删除消息)并且1分钟超时可见性到期后会发生什么?我知道该消息已返回并可以在队列中使用,但是该消息的7天TTL会发生什么,是从该时间点更新到7天还是从消息创建以
..
我有一个使用HTTP触发器和队列触发器构建的C#Azure Functions(根据App Service计划)应用程序.该应用程序通过在客户端计算机上安装脚本来工作,该脚本使用SQL查询将客户端数据库中的各种文件移动到临时Azure Blob存储中,以从客户端数据库中提取各种文件.完成每个文件后,将调用HTTP触发器,该触发器将为队列触发器创建队列消息,以拾取该消息并将文件从临时Blob存储区移
..
我正在使用Windows Azure消息队列.我想知道是否有一种在收到消息时将消息锁定在队列中的方法吗? 解决方案 从队列中检索消息时,该消息被标记为不可见,直到将其删除(或达到超时期限)为止.标记为不可见时,其他人看不到该消息.我想这与您将要获得的“锁定"功能几乎一样. 如果在处理过程中感觉需要更多时间,则可以修改消息并延长隐身超时时间. 您确实需要关注Windows Azu
..
我无法将我的请求编码为base64,根据文档,我不必这样做,但我无法弄清楚. 如果我对Base64进行编码,则可以正常工作: PHNhbXBsZT5zYW1wbGUgbWVzc2FnZTwvc2FtcGxlPg == 将已解码的消息添加到队列中 示例
..
我能够在功能应用程序 如果我仅在我的 local.settings.json 中定义连接字符串,则此方法很好.我想做的是,不仅仅是将连接字符串放在json文件中,我想使用以下语法将函数指向Key Vault: "AzureWebJobsStorage":"@ Microsoft.KeyVault(SecretUri = https://myappkeyvault.vault.azure.n
..
我有这个队列触发器.预期是当我在 Queue 中插入一条消息时,触发器必须触发并处理出队消息. [FunctionName("NewPayrollQueueTrigger")]公共异步静态void Run([[QueueTrigger("myqueue",Connection =" AzureWebJobsStorage")]字符串myQueueItem,[DurableClient] IDu
..
使用Bus.SendToQueues时出现错误,问题末尾出现详细错误。 我有一个使用存储帐户和密钥设置的天蓝色队列并且我正在尝试使用Bus.SendToSites使用msmq将本地服务总线处理程序发送消息到azure站点。 试图使网关正常运行,因为每个: http://support.nservicebus .com / customer / portal / articles / 8
..
我正在使用带有队列触发功能的Azure webjob来监听多个Azure队列。每个队列的处理方法是相同的(但是队列仍然需要分开)。我想知道是否有办法在配置中存储队列名称列表并动态创建在启动时在这些队列上触发的函数? 我知道可能使用INameResolver为单个队列使用INameResolver ,但找不到多个队列的解决方案。 解决方案 实际上,您可以在Function中编写服务器处
..
我正在使用Windows Phone的Windows Azure工具包,但是我很难将队列消息发送到云服务。这是我的代码: public void SendQueueMessage(string queueReference,params string [] message) { CloudQueue cloudQueue =新的CloudQueue(); CloudQueueCli
..
我的功能是将有效载荷发送到不同的sftp服务器。这些服务器在可接受的连接数量上受到限制。 我需要一种解决方案来限制与这些服务器的连接。 该功能由存储队列触发,设计的第一稿为: 然后我了解到每个功能只能有1个触发器,这使我陷入了另一个聚集队列: 我可以设置 batchSize / newBatchThreshold ,但是我我不确定这是否行得通,因为始发队列不会知道何时将邮件
..
我在azure上有一个WebJob,它同时处理来自多个队列的消息: 公共异步静态任务ProcessQueueMessage1( [QueueTrigger(“ queue1”)]字符串消息) { 开关(message.Substring(message.Length-3,3)) { case“ tze”: 等待Parser.Process1(message); 休息时间;
..