linq - 我需要使用 StreamInsight 2.1 和响应式扩展创建动态查询

Question

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

Answer 1

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

Answer 2

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