azure-servicebus-queues

    1熱度

    1回答

    是否有可能觸發Web任務從發佈請求執行?我的情景是,這項工作正在等待數據提供者通過https發佈數據,這應該會觸發數據處理 - 解析數據,然後應用一些業務操作。 我可以看到很多帶有隊列的示例,並且很容易測試並自行創建,但不知道如何填充隊列,但手動輸入某些數據除外。是否有可能以某種方式填充http post數據的隊列?

    1熱度

    2回答

    我開發蔚藍2個WebJobs:這是訂閱使用同一主題的ServiceBusTrigger一個將使用主題可以將消息在服務總線隊列和另一個。 的消息被正確地發送到服務總線隊列,但是當運行訂閱的消息不被在FIFO基礎處理的ServiceBusTrigger的WebJob。 對於這使消息在服務總線隊列WebJob的代碼如下: NamespaceManager namespaceManager = Names

    0熱度

    2回答

    我試圖在Java中實現與https://code.msdn.microsoft.com/Brokered-Messaging-Request-0ce8fcaf#content類似的內容,但無法從服務總線Java SDK中找到與示例中使用的QueueClient.AcceptMessageSession相匹配的功能。 那麼,如何才能讓客戶端輪詢響應隊列僅適用於與預期sessionId匹配的消息?我是

    1熱度

    2回答

    我正在使用ARM模板部署到Azure。但是,Azure服務總線部署部分證明是困難的。 誰能告訴我如何配置相同的設置中的經典門戶網站,如: 重複檢測的歷史時間 鎖定時間 最大列隊規模 最大傳遞計數 缺省消息生存時間 或者是有一種方法可以在Powershell中完成,然後從ARM腳本調用它?

    6熱度

    2回答

    我創建了一個Azure Function,每次將新消息添加到Azure ServiceBus隊列時都會觸發該觸發器。 有了這個代碼,它工作正常: #r "Newtonsoft.Json" #load "..\shared\person.csx" using Newtonsoft.Json; using Newtonsoft.Json.Serialization; public stat

    0熱度

    1回答

    我正在尋找一種管理來自多個發佈者的消息流的方法。 一個人爲的例子是這樣的。 我的每個發佈商都在提交可分解爲可以按任意順序處理的較小組件的作業。每個組件需要幾秒鐘來處理。 發佈者A將作業提交給由1000個較小組件組成的隊列。使用者X訂閱隊列並開始處理隊列消息並將結果發送到結果隊列。 通過這項工作的一半,發佈者B提交了一個包含1000個組件的作業。 我希望消費者X現在在來自發布者A和發佈者B的消息之間

    1熱度

    1回答

    我接收錯誤從我的SharePoint獲取-Item操作時我嘗試從服務總線消息中使用的數據觸發我邏輯應用(內XML中省略): 無法在行''1'和列'1641'的'Get_items'輸入中處理模板語言表達式:'模板語言函數'json'參數無效。提供的值'<?xml version="1.0" encoding="utf-8"?> <Projektaufgabe id="b92d6817-694e-e

    0熱度

    1回答

    我正在嘗試部署一個Azure邏輯應用程序,其中包含使用ARM模板在服務總線上發送消息的操作。 除了部署邏輯應用程序,ARM模板還部署了服務總線名稱空間,隊列和兩個授權規則(一個用於發送,另一個用於監聽)。 我想動態設置發送服務總線消息操作的連接信息,以使用爲支持發送的AuthorizationRule生成的連接字符串。 當我創建此在門戶編輯器(指定發送連接字符串),我注意到在代碼視圖生成以下...

    1熱度

    1回答

    我試圖遍歷一個JSON數組,該數組已被編碼爲一個字符串以用於存儲隊列。然而,我收到以下錯誤消息: { 「代碼」: 「ExpressionEvaluationFailed」, 「消息」:「的 模板行動 '的for_each' 執行失敗:結果「[{\ 」富\「 :'Bar''}]' 'foreach'動作表達的評估 '@ {json(decodeBase64(triggerBody()['Conten

    1熱度

    2回答

    我使用下一個代碼有天青webjob設置的處理: 的Program.cs: public class Program { static void Main(){ JobHostConfiguration config = new JobHostConfiguration(); config.Tracing.ConsoleLevel = TraceLevel.Verb