azure-eventhub

0熱度

1回答

我有一個小小的概念證明，它包含eventhub，流式分析連接到它，然後將事件直接輸出到數據庫中。據我所知，這些事件在eventhub上持續了一段特定的時間。當我將事件發佈到集線器時，流式分析會讀取它們並將它們發送到數據庫中的表中。如果我關閉流式分析作業，發佈事件並開始作業，則不會從集線器讀取任何事件。事件是否應該持續下去，並且可以讓工作接受？謝謝。

0熱度

3回答

如何將壓縮數據發送到Azure流分析？

我有一個系統從設備收集數據並以JSON格式將數據發送到Azure Eventhub。有一個Azure流分析流，它從eventhub獲取數據並將其輸出到PowerBI。它每秒發送一次數據。有時，互聯網連接丟失，系統不斷收集來自設備的數據。當Internet連接恢復時，它會將所有收集的數據發送到eventhub。我希望它在發送之前壓縮或壓縮數據。但流分析輸入格式只有JSON，CVS或Avro。壓縮的

0熱度

1回答

調試天青流分析作業的任何日誌/步驟是否可用？

參考下面的鏈接 https://blogs.msdn.microsoft.com/streamanalytics/2016/04/18/troubleshooting-azure-stream-analytics-jobs-on-new-portal-2/ 在流分析工作中沒有這樣的事情叫做「審計日誌」！的問題是 - 我Eventhub具有「傳出的消息」，但「沒有可用的數據」，在流分析工作我提出

1熱度

1回答

根據最後消息日期改進代碼以從Event Hub讀取消息

以下代碼連接到Azure事件中心，它遍歷所有分區，然後讀取要處理並插入數據庫的消息（待完成），代碼工作正常，但每次讀取所有消息。這將作爲Azure WebJob安裝，因此它將持續運行，實時，不會停止。如何改進此代碼以僅讀取未處理的消息？有沒有更好的方法來編碼while/for section，你會以不同的方式做到嗎？ static void Main(string[] args) {

1熱度

1回答

從指定時間讀取EventHub數據

我有一個正在運行的EvenHub，它正在被一個Windows服務監聽。意外的是，WindowsService停止工作2天。如何從EventHub中讀取停止的數據？我的Offset設置將如下所示： processorOptions.InitialOffsetProvider = (partionId) => DateTime.UtcNow; 我試圖再次啓動Windows服務，但它從現在開始。對

1熱度

1回答

如何正確地將JSON寫入到事件中心

我將批量序列化的記錄（在JArray中）發送到事件中心。當我將數據寫入事件中心時，它似乎在JSON周圍插入額外的語音標記，即寫入的內容"{"myjson":"blah"}"而不是{"myjson":"blah"}，所以下游我無法閱讀它。基於此guidance，我必須將JSON轉換爲字符串，然後使用GetBytes將它傳遞給EventData對象。我懷疑我試圖遵循這一指導是我的問題出現的地方。 u

0熱度

1回答

設置事件中心中的Visual Studio診斷配置錯誤

我正嘗試通過診斷配置將Azure VM規模設置爲事件中心流設置。我有我的公共配置，其中包括了SinksConfig如下（我省略了配置的其餘爲簡潔起見）： { "WadCfg": { "DiagnosticMonitorConfiguration": { *** config for performance counters and ETW *** "Sink

0熱度

1回答

流分析事件集線器輸出

以下Stream AnalyticsQuery計數的事件的數量，按IP地址進行分組，在10秒的時間間隔Sliding Window： Select Min(Time) as FirstHit, Max(Time) as LastHit, Count(*) as Total, IPAddress From Input Partition By Pa

1熱度

1回答

得到錯誤信息未發現 - 天青EventHub

我試圖發送一個字符串到EventHub和我寫了這個代碼： private static void sendPOST(ValueChangeMessage valueChangeMessage) throws IOException { try { // final String namespaceName = ""; //sericebusnamespacename // f

1熱度

2回答

線程「main」中的異常java.lang.NoClassDefFoundError：org/apache/qpid/proton/engine/Extendable

我創建了一個EventHub接收一些隨機消息。我只是想看看我是否可以從Java應用程序發送消息。下面是代碼 package com.hasher.connectedcars.sender; import java.io.IOException; import java.nio.charset.*; import java.util.*; import java.util.concurr