azure-servicebus-queues

2熱度

1回答

Azure函數 - c＃ - 帶Blob綁定的ServicebusTrigger

我有一個帶有servicebus觸發器和blob輸入綁定的python函數。 blob的名稱與隊列消息的內容相匹配。我function.json文件看起來像這樣： { "bindings": [ { "type": "serviceBusTrigger", "name": "inputMessage", "connection": "Omnibus_Va

0熱度

1回答

在Azure服務總線上接收有關主題訂閱的信息

我訂閱了使用Azure Service Bus中的過濾器的主題並使用Python 3.x開發，當我等待發送到該主題的信息（通過過濾器的信息）時，我無法接收它。我需要創建一個守護進程總是聽，當我收到信息，我把它發送到我的應用程序的內部服務，所以接收機在一個線程中運行循環While True 裏面的代碼我用它來接收消息如下： while True: msg = bus_service.re

0熱度

1回答

Azure服務總線消息重試TaskCancelationException

我正在使用帶自動完成選項的QueueClient消息泵。當從回調中拋出異常時，消息將被重試並最終失效。不幸的是，當從回調中拋出TaskCancelationException或OperationCanceledException時，情況並非如此。該消息會自動完成並且不會重試。另外OptionsOnExceptionReceived事件處理程序不被調用。 _queueClient = QueueC

0熱度

1回答

當您嘗試取消已排入隊列的預定Azure服務總線消息時會發生什麼情況？

我正在嘗試爲Azure服務總線隊列或主題安排消息的最佳方式，同時保留打開選項以立即發送消息而不是預定消息。如果我嘗試在第一封郵件的預定時間或之後發送替換郵件，我想確保自己能夠防止創建重複郵件。如果我在消息已經入隊之後嘗試使用CancelScheduledMessageAsync（對於QueueClient和TopicClient類）取消預定消息，會發生什麼情況？它會拋出異常嗎？

1熱度

1回答

我可以使用重複檢測來取消預定的Azure服務總線消息嗎？

我試圖想出安排Azure服務總線隊列或主題的消息的最佳方式，同時保留打開選項以立即發送消息而不是計劃的消息。如果我嘗試在第一條消息的預定時間或之後發送替換消息，我想確保自己能夠防止創建重複消息。如果你打開重複檢測，並且兩個消息具有相同的MessageId，那麼在第一個消息的排定入隊時間之前發送第二個消息是否有效地取消了預定消息？另外，如果預定的消息首先成功排隊，那麼假設第二條消息將被忽略是否安全

-2熱度

1回答

python azure中的PeekBatch

是否有Python讀取當前隊列中所有消息的API？我發現API爲.NET： https://docs.microsoft.com/en-us/dotnet/api/microsoft.servicebus.messaging.queueclient.peekbatch?view=azure-dotnet#Microsoft_ServiceBus_Messaging_QueueClient_Peek

0熱度

1回答

具有優先級的Azure服務總線隊列AND處理Docker容器以處理隊列消息

我有一個關於服務總線隊列機制的問題。我必須設置docker容器來運行不同的python腳本。每個腳本執行一個特定的圖像分析過程。其中一些是聚集的。現在我問題是： 1）Python腳本必須讀取隊列中的消息。如果2個容器試圖從同一隊列中拉取消息，應該沒有衝突。有沒有任何指導，我可以按照最佳實踐設置這樣的場景？我還不確定如何將這些單獨的腳本集羣到一個映像上，但我正在使用.yml撰寫文件來處理這個集

1熱度

1回答

邏輯應用程序 - 無法找到名稱中帶有斜槓的（NotFound）隊列

我試圖讓一個服務總線隊列在邏輯應用程序中觸發我的流程。我已經使用了服務總線隊列觸發器並傳遞了'test/test'的隊列名 - 我試圖讓它在名稱中使用斜槓的隊列工作。它不工作，我收到錯誤類型NOTFOUND和錯誤的輸入數據讀取： ... "method": "get", "path": "/test%2Ftest/messages/head", "queries"

2熱度

1回答

服務結構和縮放集羣中的長時間運行任務在

我們正在使用從Azure服務總線消息隊列獲取消息並對其進行處理的Azure服務結構（無狀態服務）。任務通常需要5分鐘到5小時。當它忙於我們想要擴展服務器，並且當它變得安靜時，我們又想縮回來。我們如何在不中斷長時間運行的任務的情況下進行擴展？有沒有一種方法可以告訴Service Fabric哪個服務器可以自由擴展？

0熱度

1回答

Azure流分析不會在物聯網集線器源輸入中列出自定義終端節點

我有一個具有將數據陷入到服務總線隊列中的自定義終端節點的IoT集線器。因爲我通過物聯網集線器&服務總線隊列中的自定義終端實現了自定義路由。當我嘗試創建Azure流分析（ASA）作業時，Azure門戶中的輸入面板不會列出自定義終結點，而只會列出僅用於默認消息終結點的使用者組。有沒有辦法讓ASA從物聯網集線器中的服務總線隊列或自定義終端選擇消息，因此我不需要修改我已有的自定義路由。感謝並期待着您的