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