0

我正在寻找有关如何使用较新的 StreamInsight 2.1 反应式扩展模型创建动态查询的信息。具体来说，我想在 IQStreamable 中使用 CreatQuery() 方法或类似的方法（在 IQueryable 中）。在我正在创建的工作流中，这个新查询将作为常设查询插入到 StreamInsight 中。我做了很多研究，但没有找到解决方案。此外，大多数文档似乎都引用了现在的“遗留”适配器模型。任何帮助，将不胜感激。

4

2 回答 2

1

“动态查询”是什么意思？类似于动态查询组合的东西，您可以将一个查询的输出用作另一个查询的流输入？如果是这种情况，您可以为此使用主题。主题允许您为流拥有多个发布者/订阅者，并且还提供在运行时附加/分离发布者和订阅者的能力。

于 2015-07-02T23:53:33.860 回答
1

据我记得 StreamInsights 不支持该概念，存档的唯一方法是使用动态编译发布到基于动态生成的代码编译的 StreamInsights 查询实例。这是很有可能的。

于 2015-07-03T02:38:48.850 回答