1

我正在使用 StreamInsight 2.1 开发一个 StreamInsight 应用程序。

输入适配器将是每秒具有数千个事件的实时库存数据流。我想使用相同的数据流运行多个独立的查询，并能够在流运行时添加更多查询，在流中的当前位置获取。

但是，每当我编写查询时，它都会创建一个全新的输入适配器。所以，我最终得到了 25 个输入适配器，它们都加载和推送相同的数据。

我只是在想这个错误吗？输入适配器是否独立于每个查询？

将实时库存数据放在输入适配器后面并让每个输入适配器再次流式传输该数据的唯一解决方案是什么？

任何建议都会很好，很难找到关于 StreamInsight 的好的文档。

4

1 回答 1

1

由于您在谈论输入适配器，我假设您使用的是旧适配器模型，而不是较新的事件源/接收器方法。您需要看一下所谓的“动态查询组合”或 DQC。这种方法将允许您创建输入适配器的单个实例，然后与您的其他查询共享流。

简而言之，您需要创建一个包含所有股票代码数据的“来源”查询。从那里，您可以在查询上调用“ToStream()”，将查询结果转换回 CepStream。接下来让您的 25 个左右的其他查询/计算/等使用该流作为他们的数据源。

查看MSDN StreamInsight 文档中的在运行时编写查询。该页面的第一部分“重用现有查询的输出”应该正是您所需要的。

于 2012-10-11T04:49:47.600 回答