问题标签 [streaminsight]

我有一个基于 StreamInsight 1.2 构建的应用程序，它有几个常设查询在用户定义的运算符中运行一些计算。有时，其中一个计算需要相对较长的时间才能完成（几秒钟），而且我看到它阻止了其他查询的执行。我不太熟悉 StreamInsight 的工作原理，因此我推测所有查询都在单个线程上运行。有没有办法让查询并行运行？

除了以某种方式将查询放在单独的线程上之外，我还能做些什么来防止一个偶尔长时间运行的查询阻塞其他查询？

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

我在 C# 中使用过 Microsoft StreamInsight。Microsoft StreamInsight 是否也支持 C++？

我有一个非常简短的问题：

MS StreamInsight 是基于云还是可以在机器上本地运行？

非常感谢。

几个月来，我一直在使用 StreamInsight for CEP，并且有兴趣转向 ASA。我有一个无法从 ASA 文档中回答的问题。在 StreamInsight 中，我可以更改事件的持续时间以从离散的时间点事件创建信号流。例如

我想要做的是检测这个高/低类型信号和另一个时间点事件流之间的重叠。我怎样才能在 ASA 中达到同样的效果？

背景：我有将来自多个源的事件发送到天蓝色事件中心的设备。其中一些事件是来自联系人的开/关事件。每个触点类型由“EventCode”表示，“Value”字段指示触点是打开还是关闭。我正在寻找的是一个 ASA 查询，它将告诉我 EventCode 512 何时处于“开启”状态，同时 EventCode X 也处于“开启”状态。

解决方案

下面是来自@Andrew 的修改后的代码，它在开关打开时检测到联系人正在关闭。'inStream' 是在以 Timestamp 字段加时间戳的 WITH 语句中定义的：

我有一个 StreamInsight 服务器，它通过常设查询流式传输数据。当 StreamInsight 运行时，我重新启动该服务器，在服务器重新启动后，我希望 StreamInsight 继续使用旧查询运行。

我可以这样做吗？如果可以，我该怎么做？

我将 StreamInsight 服务器托管到 Windows 服务。Windows 服务使用 LocalSystem 运行。

在 OnNext() 方法中，我可以访问服务器的代码

在线server.Applications[StreamInsightConfiguration.Default.StreamInsightApplicationName]; 我收到一条消息访问被拒绝。

我还将 NT\SYSTEM 添加到 StreamInsightUsers$Default 组。

如何解决这个问题？

我有 StreamInsight 服务器

StreamInsight 客户端 A：

我有另一个客户端 B，我想将客户端 B 的查询绑定到客户端 A 的此进程（该进程的名称为"serverProcess_Client_A"）。我不想从客户端 B 创建新进程

问题：我可以这样做吗？

另一个问题：我可以将查询绑定到现有的 StreamInsight 进程吗？

我有 StreamInsight 客户端：

我有100个客户。当我运行 100 个客户端时，StreamInsight 将崩溃。这是事件查看器中的例外：

如何解决这个问题？或者让我知道上述异常的原因是什么？

我正在使用“System.Linq.Dynamic”包来准备“WHERE”子句，如下所示，

上面的代码适用于普通的“客户”对象，但是当我尝试对“IQStreamable”客户做同样的事情时，我得到了错误，

代码，

我相信原因可能是由于客户的“IQStreamable”形式，有什么办法可以解决吗？