azure-eventhub

    1熱度

    1回答

    我在Jupyter筆記本中使用HDInsight中的火花。我使用%%配置「magic」來導入包。每當有一個與包有問題,火花與錯誤崩潰: The code failed because of a fatal error: Status 'shutting_down' not supported by session.. 或 The code failed because of a fatal err

    0熱度

    1回答

    我對Azure中的解決方案方法有疑問。問題是如何決定使用哪些技術以及如何找到它們的最佳組合。 假設我有兩個數據集,每天增長: 我有每天來我ADL商店CSV文件,它包含氣象數據的所有可能Lattitudes和Longtitudes組合和zip爲他們編碼,以及50個不同的天氣變量。 我有另一個POS數據集(銷售點),它也作爲每日CSV文件到我的ADL存儲。它包含所有零售地點的銷售數據。 所需的輸出是擁

    0熱度

    2回答

    所以我得到這個異常: com.microsoft.azure.servicebus.PayloadSizeExceededException: Size of the payload exceeded Maximum message size: 256 kb 我相信例外是自我解釋,但是,我的不知道該怎麼辦纔好。 private int MAXBYTES = (int) ((1024 * 256

    0熱度

    2回答

    我有這個問題,我從SQL服務器讀取消息(數據可能會有所不同,某些字段是varchar(max)),並通過將它們序列化到JSON Azure事件中心批量發送它們批量發送機制的限制爲250Kb,是否存在容易檢查在提交之前被傳送的eventdata列表的大小?大多數時候數據很小,所以我想批量處理幾條消息。我怎麼知道有效載荷將會是多大。我真的不想數字和計算大小,並認爲有一個更好的方式,你們可以幫助?

    2熱度

    1回答

    當我將Log to EventHub操作添加到我的傳入處理時,Microsoft提供的基本示例很有用,但我希望能夠記錄請求內容和內容長度。目前我找不到任何有關上下文或上下文的文檔或定義。本示例中使用的請求對象。 <log-to-eventhub logger-id ='logger-id'> @(string.Join(",", DateTime.UtcNow, context.Depl

    1熱度

    1回答

    我想獲得一些建議,用於在Azure中設計IoT消息的路由。 我有以下情況: Senator以Google Protobuf格式向Azure IoT Hub發送消息。根據消息的類型,我想將消息路由到服務結構中的不同應用程序。 我目前的方法是使用服務結構應用程序接收來自IoT中心的所有消息,解析protobuf消息,根據消息的類型(protobuf內的屬性)將消息發送到特定於類型的Azure事件中心。

    2熱度

    2回答

    我是Powershell和Azure(C/C++背景)世界的新手,我想編寫一個監視Azure事件中心的PowerShell腳本。解決這個問題的一種方法(迄今爲止我發現的唯一方法)是使用來自Microsoft.​Azure.​Event​Hubs.​Processor的.NET類。我假設的代碼來創建EventProcessorHost類的實例會是這個樣子: $eventPHost = [Micros

    1熱度

    1回答

    我有一個生成流式數據的Python程序。每條數據都存儲爲一個名爲message的變量。 由於事件中心沒有提供Python SDK,因此我選擇使用their REST API。我試圖將數據推到我的活動中心實例作爲我的Python程序的一部分如下生成數據: r = requests.post("https://{Instance name}.servicebus.windows.net/{Path}/

    1熱度

    2回答

    我目前正在使用Adruino Uno來收集諸如溫度和溼度等天氣數據的項目,然後將這些數據傳遞到Azure IOT中心,然後將消息處理並存儲到SQL數據庫再次在Azure中。最後,數據將顯示在網站上,用戶可以註冊並查看我收集的天氣數據。 我正在嘗試將短信通知發送到系統中,以便如果溫度達到某個閾值,例如0攝氏度,系統上的用戶將收到通知他們低溫的SMS消息。 我的問題是可以觸發和發送的SMS消息包含在流

    5熱度

    2回答

    我正在構建.Net控制檯應用程序以讀取DocumentDB中的信息。控制檯應用程序具有來自EventHub的數據,並在進入雲時插入/更新最近的數據。 我想從DocumentDB讀取單數文檔,並且我可以在請求文檔之前確認文檔存在。 if (DocumentDBRepository<DocumentDBItem>.DoesItemExist(name)) { device = await