streaminsight

    1熱度

    1回答

    假設我有一個具有已知結束時間的間隔事件,是否有方法在所述間隔事件到期之前觸發另一個事件。這樣做的目的是在那時我需要做一個聚合。 或者是有沒有辦法做一個查詢(這是不理想的,但我可能不得不求助於它) (from input in inputStream select input).AddDelay(input.EndTime - DateTime.UtcNow) 如果我的理解是完全關閉,請提出一

    0熱度

    2回答

    我一直在嘗試創建一個基於奧斯汀示例的示例應用程序。首先,我有一個404樣本,我通過調整App.Config中的connectionString來修復它(我忘了那個,我的壞)。 現在我創建了第二個接收器,它應該將消息發送到服務總線隊列而不是Azure表。 啓動SampleApplication和EventSourceSimulator時,前兩個消息似乎正確傳遞,但第三個消息顯示404錯誤。 以下是錯

    0熱度

    1回答

    如果沒有事件,StreamInsight TumblingWindow會觸發嗎? 我看到喜歡這裏的一個所有案例中,總是有每個窗口內的事件:http://sqlblog.com/blogs/stream_insight/archive/2010/12/15/windows-in-streaminsight-hopping-vs-snapshot.aspx 但問題是,當存在一個特定的窗口任何情況下,它

    0熱度

    1回答

    在StreamInsight 2.0中處理異常的最佳做法是什麼? 當發生異常時(我不是在談論丟失的事件,而是像代碼中的NullReferenceException someware一樣的實際異常)如何處理它並安全地將應用程序停下來考慮所有事件都是異步執行的?

    1熱度

    2回答

    我正在嘗試StreamInsight,並遇到了需要查詢的問題。 我試圖在最近30分鐘內對測量值(最多20%更改)進行若干更改時發出警告。 這是我現在提出的查詢,但它不工作,我認爲它甚至不正確。 顯然我不能過濾窗口...? var deviationQuery = from s in wcfStream group s by s.SensorId into grouped

    1熱度

    1回答

    我正在使用StreamInsight 2.1處理StreamInsight應用程序。 輸入適配器將成爲每秒數千個事件的實時股票數據流。 我想使用相同的數據流運行多個獨立查詢,並且能夠在流正在運行時添加更多查詢,並在流中的當前位置進行拾取。 但是,每當我編寫查詢時,它都會創建一個全新的輸入適配器。所以,我最終有25個輸入適配器全部加載並推送相同的數據。 我在想這個錯嗎?輸入適配器是否獨立於每個查詢?

    1熱度

    1回答

    我一直在努力實現以下適配器的StreamInsight與BizTalk連接: http://seroter.wordpress.com/2010/07/09/sending-streaminsight-events-to-biztalk-through-new-web-soaprest-adapter/#comment-11635 在結束時,他確實下到查詢到適配器綁定: var allQuery

    0熱度

    3回答

    我正在使用StreamInsight 2.1並遇到意外的性能問題。 我有一個金融數據輸入適配器,每秒可以處理5,000到10,000個事件。然後我有大量的查詢針對該輸入進行操作。每個查詢連接到完全相同的傳遞查詢,所以我有1000個查詢使用完全相同的輸入數據。 爲了測試該系統將能夠處理這個問題,我創建了1000次的查詢什麼也沒做,但直通(從d在FULLSTREAM選擇d)的事件只發布事件的輸出適配器

    -3熱度

    1回答

    我是LINQ的新手,上面的代碼對我來說執行得很好。 但我不明白爲什麼在最後一句c.payload.Quantity寫入而不是c.Quantity。 當我谷歌搜索時,我才知道從我們從c中的結果得到的有效載荷中獲得的數量值是否意味着有效載荷是filterQuery的最終輸出? var orderData = new[] { new {OrderDate = new DateTime(2011,1,

    0熱度

    1回答

    也許這可以在沒有StreamInsight的情況下完成,但我很好奇。 我有一個應用程序正在用「消息」填充表(在表中插入一行)。 我想創建一個監控應用程序,監控該表的消息「到達」的速率,以及它們「處理」的速度(標誌被更新)的速度。 由於這是一個供應商應用程序,我不想放棄觸發器或任何東西。但我可以查詢數據庫,並且該表使用標識列具有PK。 我怎樣才能到跳頻窗口查詢?我希望在過去的30分鐘內顯示消息的速率