问题标签 [streaminsight]

我在自托管 MSSI 服务器上部署了一个进程。绑定到这个过程我有一个简单的直通查询。

一些事件被丢弃在这里“cep:/Server/Application/Erp/Entity/Event_Events_Process1/Query/StreamableBinding_1/Operator/Stream_1_CleanseInput”

我可以看到事件计数器下降了，但我找不到它下降的原因。

有谁知道如何调试它？

有没有办法在 StreamInsight 中保留所有事件并根据需要添加或删除事件？在 Esper 中，有一个名为 keepall() 的方法可以应用于窗口。此方法保留所有传入事件，您可以对在窗口中插入事件或删除它们有不同的查询。

我尝试在 StreamInsight 中使用Hopping、和Snaphot，但它们都没有上述功能。TumblingCount Window

谢谢。

我有以下查询，我试图通过 TCount 获得 TopicCounts 的前 4 个：

每当我尝试构建时，我都会收到以下错误：

“Microsoft.ComplexEventProcessing.Linq.IQStreamable”不包含“OrderByDescending”的定义，并且没有扩展方法“OrderByDescending”接受类型的第一个参数

可以找到“Microsoft.ComplexEventProcessing.Linq.IQStreamable”（您是否缺少 using 指令或程序集引用？）

我错过了什么？

我正在考虑使用 Streaminsight 识别驾驶员行为数据中的模式，这些模式将包括在短期（几秒钟）和长期（超过 1 周）内发生的模式。我一直在努力寻找有关最大窗口长度或所需资源与窗口长度的任何信息，或在较长时间内使用复杂事件处理的示例。

我发现的最大窗口长度的唯一指示是它是流数据速率、有效负载大小、内存和 CPU 的函数，但并不准确。给定服务器的规格和它必须处理的数据量，我如何计算最大窗口长度？

我是否正在寻找用于处理长时间流的错误技术，或者是否存在涉及操纵流以降低资源需求的解决方法？

我可以在 UDSO 中做到这一点：

是否可以在查询中完成所有操作？所有这一切都是使 IEnumberable ：

我有一个从数据库读取的输入流，其中包含来自不同设备的测量值。数据库中记录的事件不按时间顺序排列，但通常在 2 分钟窗口内到达。但是，有些设备可以在过去几天发送带有时间戳的数据。

当我在输入流中插入 CTI 以处理最多只有几分钟的“正常”数据时，如何处理比其余数据晚几天的设备的数据？

在我插入 CTI 之前，是否可以将输入流拆分为每个设备的 1 个流，这样“旧”流将具有独立于其他输入流的 CTI？

提前致谢。

如果我有一个点流，其中包含来自多个用 UnitId 和开始日期标识的“单元”的点数据：

var input = CepStream<EventPayload>.Create("input", typeof(SQLPayloadInputAdapterFactory), inputConfig, EventShape.Point);

我将其转换为间隔流：

var signal = input .AlterEventDuration(e => TimeSpan.MaxValue) .ClipEventDuration(input, (e1, e2) => (e1.UnitID == e2.UnitID));

当输出适配器读取时，我可以获得信号流中事件的持续时间，因为它可以看到事件对象并读取它的开始和结束值。

我需要做的是查询“信号”流以找到 1 分钟翻滚窗口中最长的事件

...给我一组带有计数等的单位，但我无法让事件的持续时间传递给其他查询，因为我只能在groupWindowQuery.

如何查询事件属性以找到翻滚窗口中最长的事件？

或者是否可以在有效负载中设置值，以便在从点创建信号流时给我的点事件一个结束日期？

（对于跨越窗口的事件，持续时间为 1 分钟并不重要）

我们刚刚完成了一个小项目，主要目的是尝试 Microsoft StreamInsight。

这项技术看起来不错，但我担心它的行业牵引力。当我们遇到问题时，网络上只有少数材料，通常我会想念它周围一个充满活力的社区。

我们是否应该扩大对 StreamInsight 的使用，或者它会像 Silverlight 那样在几年内消失？

考虑一下我是 C# 世界的新手以及与 IObservable 术语相关的术语。我有一个关于如何从 Current 中提取信息的问题。这是我的 C# 代码：

如果我在源中传递此类的值：

有没有一种简单的方法可以从当前表示中提取 x、Id、Level 的值？

谢谢

我是 Microsoft BI 开发人员，我正在为我的一位客户评估复杂事件处理工具的过程。我遇到了很多来自不同背景的工具，比如 WSo2、Jboss + drools、Nesper 和 Microsoft StreamInsight，而且由于我来自 Microsoft SQL Server 背景，我只喜欢 Microsoft 工具。在我们最终确定此工具之前，有一个问题是每秒 Streaminsight 事件处理能力的限制。标准版每秒 5000 个，但我们正在寻找当前每秒 15000-20000 个（未来几年更多）事件
。所以我的问题是我们是否可以集群多个 Streamlight 服务器以增加每秒处理事件的能力，
如果是，Required 可以告诉我获取这些知识的位置“如何集群多个 Streaminsight 服务器”。