azure-storage-queues

0熱度

1回答

我有一個Azure功能的應用程序在Node.js與幾個隊列觸發功能。這些工作很好，直到我在我的功能日誌中看到一些超時。從這一點來說，我的觸發功能都沒有實際做任何事情。在執行第一行代碼（它是一個context.log() -statement）以顯示執行時間之前，他們只是保持超時，即使是。什麼可能是這個原因嗎？

0熱度

1回答

清除Azure存儲隊列上的隊列

我在運行WebJob的Web應用程序上運行一些測試，以處理一些後端任務。我使用Visual Studio中的Cloud Explorer連接到隊列，並清除隊列中的所有消息。當我重新啓動WebJob時，它仍然會查找消息並嘗試處理它們。這些消息來自哪裏？如果我通過Visual Studio中的雲資源管理器清除隊列，是否該隊列不應該爲空？順便說一句，我也清除隊列poision。

0熱度

1回答

Azure存儲隊列和最多一次交付

我的印象是，這不適用於存儲隊列，但調查後我無法找到證明。 MSDN文章說，在-最不一次，但我能找到最多的信息是，第一個消費者獲取信息，並將該消息爲不可見。然後當它再次變得可見時，它可以再次拾起。但是我可以設置爲不可見的時間跨度大，我可以檢查出列數限制它在最多一次交付。這是使用假設競爭消費者不能搶在同一時間，我不能驗證相同的消息。

2熱度

1回答

在隊列的兩個消息讀取之間創建延遲？

我正在使用Azure隊列執行批量導入。我使用WebJobs在後臺執行該過程。隊列非常頻繁地出隊。如何在2條消息之間創建延遲？這是怎麼了增加一個消息隊列 public async Task<bool> Handle(CreateFileUploadCommand message) { var queueClient = _queueService.GetQueueClient(C

0熱度

1回答

我可以在爲我的天藍色存儲帳戶生成共享訪問簽名（SAS）時指定隊列名稱

這裏是描述如何Constructing a Service SAS的文檔。該文件說，您可以指定一個表名，以便sas只能訪問該特定的表。我可以用隊列做同樣的事情，所以sas只能訪問特定的隊列嗎？

0熱度

1回答

從Azure函數異步寫入文件

我有一個從Blob上載觸發的Azure函數，表示Blob包含一個帶有多行行的文本文件，每行包含有關某個人的信息。該函數讀取文件並將KeyValuePair插入到每行的Azure隊列中。然後我有另一個Azure函數，它是由我前面提到的隊列觸發的，它是異步執行的，因爲第一個函數將數千個KeyValuePair存儲到隊列中。我想要做的是，當第二個函數處理每個KeyValuePair時，我想寫入一個響

2熱度

2回答

Azure隊列 - 功能 - 消息可見性 - 工作者？

我對Azure隊列，函數和Worker的功能有一些疑問。我不確定這是如何工作的。場景： Q-通知處於Azure存儲帳戶的隊列。 f-process-notification是Azure中與q-notifications綁定的函數。它的工作是在隊列中獲得第一條消息並處理它。理論上，當消息被添加到q-notifications時，應該調用函數f-process-notification。問題：

0熱度

1回答

如何查看Azure隊列觸發的webjobs中一批消息中的項目數量？

在我的Azure的隊列觸發webjobs我要麼根本就不設置BATCHSIZE（默認爲16），或者我設置： JobHostConfiguration.Queues.BatchSize = ...; 據傳（按F5頻繁）好像不管什麼設置是隊列中的項數總是減少1.我想看看實際上發生了什麼 - 我怎麼看到在任何給定時刻抓取的消息的數量。該值似乎不是隊列觸發器元數據的一部分。

0熱度

1回答

Azure調度程序：將消息放入存儲隊列

我在Azure調度程序作業集合中創建作業。這個想法是在預定的時間將消息放入隊列中。我遵循this鏈接來配置https作業，但我堅持在一個點，我需要添加一個請求標題x-ms-date（或日期），這需要是「不超過15分鐘」根據MS文檔。我必須使用https動作類型，因爲Azure的調度門戶網站不支持ARM創建隊列。雖然這可以使用Scheduler SDK來實現，但我們可能會選擇它作爲最後的手段。請

1熱度

1回答

Azure Web作業 - 來自隊列的並行消息處理無法正常工作

我需要配置使用Azure隊列和Web作業的SharePoint Online團隊客房。我創建了一個控制檯應用程序，並公佈爲連續Web作業使用以下設置： config.Queues.BatchSize = 1; config.Queues.MaxDequeueCount = 4; config.Queues.MaxPollingInterval = TimeSp