问题标签 [streaminsight]

所以我对 Stream Insight 相当陌生，这可能是一个相当基本的问题，但似乎不支持按事件类型过滤查询（见下文），那么应该如何完成呢？

为了充实我的问题，这是我的 CepStream ......

..这是我的查询...

...运行时产生此异常： Microsoft 复杂事件处理 LINQ 提供程序不支持以下表达式：（x 是 FxSpot）

据我了解，我可以创建多个适配器而不是有效地执行过滤器，但这似乎不是它“应该”完成的方式。

任何建议将不胜感激！

马特

我遇到了 StreamInsight 的情况，其中我有 1 个输入源，其中包含不同类型的事件，需要区别对待，但最终与来自同一源的其他事件匹配。

我在下面创建了一个（非常）更简单的场景，其中输入源生成随机数（为简单起见，1 和 0）。如果数字是偶数，我们想保存它，直到另行通知（未知持续时间）。如果数字是奇数，我们希望将其与偶数流中的 n-1 匹配，然后从偶数流中删除 n-1。如果不匹配，奇数将直接处理，无需进一步计算。在从偶数流中删除匹配的 n-1 之前，我的一切都按预期工作。进行匹配，并将匹配推送到输出适配器，但仍可用于对给定事件进行另一个连接。我收集了几天的实验和研究，不知何故我需要剪辑均匀的流事件持续​​时间（ClipEventDuration），大概作为 GenerateEvenJoinQuery 中过滤器的一部分，但是，我尝试过的一切都没有产生任何变化或不希望的结果。我还尝试将 evenStream 更改为 Interval 形状，但运气更差。任何帮助或建议将不胜感激。

例如，给定一个简化列表： [ 1, 0, 1, 1, 0, 0, 1, 1, 1 ]

我希望输出看起来像： [ 1, 100, 1, 100, 100, 1 ]

我也会接受我正在使用的真实场景，第一个输出实际上是不可能的：注意第二个和第三个 0 连接到一个 1. [ 1, 100, 1, 100, 1, 1 ]

解决方案：

虽然我希望一些更精细且可能更快的东西，但延迟处理可能有助于提高性能。

我是StreamInSight开发新手。我已经下载了几个示例，现在我正在尝试编译它们。我收到错误，因为“找不到类型或命名空间名称 'IQStreamable'（您是否缺少 using 指令或程序集引用？）”我已经在我的项目中包含以下引用 -

• Microsoft.ComplexEventProcessing
• 系统
• System.Reactive.Core
• System.Reactive.Interfaces
• System.Reactive.Linq
• System.Reactive.PlatformServices
• System.Reactive.Providers

如果我遗漏了什么，请告诉我。

我已经安装了 StreamInsight 2.1。我已经能够打开它并使用 Server.Create()，公开一个 WCF 端点，并使用事件流调试器连接到它。我发现了很多创建假事件源的例子。

我想知道如何创建我认为可能的：针对 SQL 2012 数据库的常规查询。我还没有找到任何连接到 RDB 的示例代码 - 只是声明“这只是为了展示，实际上你可能会连接到 RDB”。

它只能使用 LINQ-to-SQL 吗？实体框架 4？更简单的 ADO.NET？一些特定于 MS SQL 的协议？

我想真正让我困惑的部分是这些常设查询应该如何工作。这些天来，微软在 SQL Server 中拥有一个只能由某个独立 SKU (StreamInsight) 访问的公开功能，这对我来说似乎很奇怪。因此，它必须是以下两者之一：

SQL 是否知道查询的持久性，或者 StreamInsight 是否只是修改 LINQ 语句以有效地轮询（例如通过添加AND @LastExecution <= InsertedOn和适当的索引）。

如果 SQL 将其视为一种特殊的查询，那么 StreamInsight 使用什么机制来创建这种常设查询？程序员可以在没有 StreamInsight Services 的情况下使用它吗？

在 StreamInsight 中，许多示例解决了流的 count、sum、filter 的 linq 用法。

定义提取在一定时间长度内发生的记录的查询有一些困难。例如step1存储的是“RedCar”的积分事件，但是如何提取10分钟内连续发生的两个“RedCar”事件呢？

真的被困在这里，非常感谢任何帮助！

是否可以通过streaminsight获得连续的输出流？我的问题是，当我使用跳跃/翻滚窗口对输入流进行查询时，当没有输入事件时，查询不会给我任何输出。这听起来很正常，但是在没有输入事件的情况下，是否有可能获得一个每 5 秒输出一次的窗口机制？

这是我的代码，也许在此之后问题变得清晰：

我想要的输出让我们说这个输入：

希望这种窗口机制在streaminsight中是可能的，我在谷歌上搜索了很多东西，阅读了开发人员指南，但注意到处理有争议的输出或类似的东西。希望可以有人帮帮我！

当数据输入到表中时，它会触发触发器，然后将其复制到不同的表中

当此触发器触发并将修改后的数据复制到另一个表时，我想使用流洞察力。

如何从表（事件）中的触发器将数据获取到输入适配器我如何将触发器用作输入适配器的事件以在 streaminsight 中获取数据？

我在 StreamInsight 中有以下问题。我有一个查询，订单中的新任务来自哪里，并触发输出适配器进行预测。输出适配器将预测的任务周期时间写入表（在 Windows Azure 中）。预测基于神经网络并插入输出适配器。在表中写入预测后，我想对所有预测时间做其他事情。所以在第二个查询中，我想在 5 分钟的时间窗口内计算书面任务的数量。当表中保存的预测值数量等于订单中的任务数量时，我想从表中获取所有的预测值，并对订单周期时间进行预测。

对于这个想法，我需要在我的输出适配器中创建一个新事件，以了解预测的时间写在表中。但我认为不可能从输出适配器将新事件排入流洞察服务器中。

也许这个数字说明了问题：http: //i40.tinypic.com/4h4850.jpg

希望可以有人帮帮我。谢谢卡洛

我正在开发一个 StreamInsight 应用程序，它应该计算每N个输入的函数，即如果 N=10，那么我想计算：

等等

所以我想要的是一个Hopping Window，除了在 Count 而不是时间戳上参数化。

我不能使用计数窗口，因为每次计数改变时都会产生输出。

我正在寻找有关如何解决缺少"Hopping Count Window"的建议。

这是我最后一个问题的后续；设置是我正在使用 StreamInsight 进行时间序列预测。

扩展那里给出的描述，让我用x_n我的输入流来表示，为了这个例子，让我们假设每 10 次观察后我预测前面的 10 个值；我将这些预测称为p_n。系列索引将对应于时间，因此第一个p_n将是p_11.

所以我们有

我有一个用户定义的流运算符，它从我的输入流中收集，当有足够的事件时，它会为该循环x_n吐出所有的；p_nTXPower275 证实这是一个合理的策略。

我的下一步是将预测与输入时的实际值进行比较；为此，我想加入这两个流。加入使用事件时间戳，所以我需要时间戳正确排列。

（除此之外：虽然我有点事件，但我也可以使用间隔事件较短的间隔，以便我得到重叠的连接......当我到达它时我会越过那座桥）。

（为了完整性：当我收到处于周期中间的输入事件时，我的 UDSO 会输出一个“虚拟事件”，我使用事件有效负载中的一个字段来识别它。我过滤掉虚拟事件以创建预测的 -事件流。）

为了更清楚地说明这一点，这是我的接收器的一些输出。这些是上面提到的虚拟事件。每行开头的时间戳是 StreamInsight 事件时间（这些是点事件），每行末尾的时间戳实际上是我的有效负载中的一个字段。

实际的预测是这样的：

请注意，所有这些事件的时间都是相同的。这是因为我的 UDSO 将触发其计算p_n的时间戳分配给所有（一个周期） 。x_n

这与MSDN 文档一致—— “每个输出事件的时间戳是基于相应输入事件的时间戳”。

我想做的是使用有效负载字段中的时间创建预测事件。

我认为我应该使用的是

，我尝试将其插入的方式是这样的：

我prediction_query的类型是IQStreamable<MyPayload>.

这是行不通的。如上所示，事件即将到来并正在生成预测，但我的“ separated_stream”可能不存在。

使用与我的其他查询相同的模式打印到控制台 -

所以我认为那里没有任何错误。

我正在使用事件流调试器，但找不到此查询...但我确实找到了两个进程，我只识别其中一个中的流，所以我认为第二个可能与此有关separated_stream。诊断告诉我在此过程或其任何操作员中没有事件。查询和操作员一样“正在运行”，调试器中的任何内容都不像错误。

我的定义separated_stream不正确，我应该如何解决？

谢谢。

编辑：事件流调试器中的第二个进程与问题查询有关 - 如果我注释掉查询，则进程不会显示。