我一直在尋找示例來輕松地使 Azure 存儲隊(duì)列出隊(duì)，就像將項(xiàng)目入隊(duì)一樣（通過在 Run 方法中注入 IAsyncCollector）。但遺憾的是，沒有成功。我發(fā)現(xiàn)的唯一的事情就是將項(xiàng)目排隊(duì)或?qū)μ砑拥疥?duì)列中的項(xiàng)目做出反應(yīng)。我的本地服務(wù)器上運(yùn)行一個(gè)應(yīng)用程序，它將定期調(diào)用該函數(shù)（并不斷調(diào)用直到隊(duì)列為空）以獲取隊(duì)列的項(xiàng)目。我想使用 Azure 函數(shù)來執(zhí)行此操作。歡迎任何幫助。
2 回答
拉風(fēng)的咖菲貓
TA貢獻(xiàn)1995條經(jīng)驗(yàn) 獲得超2個(gè)贊
如下：
ICollector 和 IAsyncCollector 可用作存儲隊(duì)列輸出綁定的參數(shù)類型。
目前，azure 函數(shù)綁定僅支持輸出綁定以將消息寫入隊(duì)列?；蛘撸绻恍枰褂?HTTP 請求調(diào)用隊(duì)列觸發(fā)器，則可以使用隊(duì)列觸發(fā)器來檢索消息。
如果您必須使用 HTTP 請求，假設(shè)您必須創(chuàng)建一個(gè) HTTP 觸發(fā)函數(shù)，然后檢索并刪除隊(duì)列以實(shí)現(xiàn)出隊(duì)操作，如下面的代碼。
public static async Task<IActionResult> Run(
? ? ? ? [HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = null)] HttpRequest req,
? ? ? ? ILogger log)
? ? {
? ? ? ? log.LogInformation("C# HTTP trigger function processed a request.");
? ? ? ? // Parse the connection string and return a reference to the storage account.
? ? ? ? CloudStorageAccount storageAccount = CloudStorageAccount.Parse(Environment.GetEnvironmentVariable("AzureWebJobsStorage"));
? ? ? ? CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();
? ? ? ? // Retrieve a reference to a queue
? ? ? ? CloudQueue queue = queueClient.GetQueueReference("myqueue");
? ? ? ? // Async dequeue the message
? ? ? ? CloudQueueMessage retrievedMessage = await queue.GetMessageAsync();
? ? ? ? Console.WriteLine("Retrieved message with content '{0}'", retrievedMessage.AsString);
? ? ? ? //Process the message in less than 30 seconds, and then delete the message
? ? ? ? await queue.DeleteMessageAsync(retrievedMessage);
? ? ? ? return? (ActionResult)new OkObjectResult(retrievedMessage.AsString);
? ? }
SMILET
TA貢獻(xiàn)1796條經(jīng)驗(yàn) 獲得超4個(gè)贊
為什么不創(chuàng)建一個(gè)應(yīng)用程序調(diào)用的 Webhook 函數(shù)，然后在該函數(shù)中，您可以根據(jù)需要使用適用于您使用的任何語言的標(biāo)準(zhǔn)存儲隊(duì)列 API 將項(xiàng)目出列。
- 2 回答
- 0 關(guān)注
- 171 瀏覽
添加回答
舉報(bào)
0/150
提交
取消