streaminsight

    1熱度

    1回答

    我遇到了一個問題,我不知道它爲什麼會出現。 我有一個InputAdapter接收隨機生成的事件用於測試目的。 以下代碼創建一個查詢,其中會丟失大量事件。我實際上想要保留它。 var atgs = new AdvanceTimeGenerationSettings(config.Input.EventCount, TimeSpan.FromSeconds(config.Input.

    0熱度

    2回答

    創建動態查詢我在查找有關如何使用更新的StreamInsight 2.1反應式擴展模型創建動態查詢的信息。具體來說,我想在IQStreamable中使用CreatQuery()方法或類似的方法(在IQueryable中)。在我創建的工作流程中,這個新查詢將作爲常規查詢插入到StreamInsight中。我已經做了相當多的研究,但還沒有找到解決方案。此外,大部分文檔似乎都引用了現在是「傳統」適配器模

    1熱度

    1回答

    我使用啓用了WCF的源和接收器並使用嵌入在我的項目中的StreamInsight進行查詢。它在我運行我的查詢時創建源代碼。這是可以的,但它不會創建匯,直到一些數據元組進入源代碼(並通過沉沒)。因此,我的客戶端無法連接到接收器(通過WCF),然後輸入數據到我的查詢。我怎麼解決這個問題?!

    -3熱度

    1回答

    我是Microsoft BI開發人員,我正在爲我的客戶之一進行復雜事件處理的工具評估過程。 我遇到了很多來自WSo2,Jboss + drools,Nesper和Microsoft StreamInsight等不同背景的工具以及我從Microsoft SQL Server後臺獲得的更多我喜歡的微軟工具。 我們最終確定這個工具之前有一個擔憂是Streaminsight事件處理能力每秒的限制。 標準版

    0熱度

    1回答

    我們一直在使用StreamInsight來處理各種事件。在尋找一個好的ESB平臺時,我們也想知道我們是否可以將StreamInsight用於相同的目的。 一對夫婦的的StreamInsight和類似NServiceBus之間的主要區別是 最大郵件/事件大小(的StreamInsight在這方面顯然是有限的) 的Pub/Sub(需要一些工作,使的StreamInsight工作) 輕鬆地將東西放到一個

    1熱度

    1回答

    我安裝的StreamInsight 2.1和init的服務器在這樣的代碼 using (var server = Server.Create("Default")) 我用2個控制檯應用程序的代碼。它會拋出像下面的錯誤。 我不明白的是爲什麼應用程序A工作,但應用程序B沒有工作。 我也試着爲2個應用程序使用2個實例。但是隻有申請A有效,而B沒有。 請注意,A和B沒有配置。由於StreamInsig

    0熱度

    1回答

    我卡上關於建築的問題如下: 編輯: 所以我可能會在思考這個問題,否則我可能會改寫這個問題。 NServiceBus似乎爲Messaging和Routing到進行(類似於流的數據?),而的StreamInsight似乎爲Event Stream Processing,Event Querying和Correlating進行。 :)。 是否有任何好處(例如,在可擴展性方面,冗餘)使用方法1超過方法2的

    0熱度

    1回答

    我錯過了什麼,或者是將傳統商務智能解決方案與SSAS/SSRS/SSIS結合起來的更簡單的方法。 傳統: Sources->SSIS->Staging area->SSIS->warehouse->SSAS/SSRS/PowerPivot/.. 的StreamInsight: Sources->StreamInsight->SSAS/SSRS/PowerPivot 在我們沒有實時分析能力的

    1熱度

    1回答

    我有一個IQStreamable對象,其使用DefineObservable的Microsoft.ComplexEventProcessing.Application。 該代碼看起來很正常,但我不明白的是,當我使用從Task.Run()到DefineObservable的傳入參數時,出現異常。 但是,當我直接使用該屬性,而沒有將它傳遞到Task.Run()裏面的方法,它的工作。 異常 An unh

    1熱度

    1回答

    我託管了一個StreamInsight服務器到Windows服務。 Windows服務使用LocalSystem運行。 在OnNext()方法,我有代碼訪問服務器 using ( var server = Server.Connect( new EndpointAddress(@StreamInsightConfiguration.Default.St