问题标签 [streaminsight]

我需要使用 sqlDependency 编写一个 StreamInsight 输入适配器来监视表。实际上，通过使用 SqlDependency，我们可以通知插入到表中的新行。所以我们计划使用 Streaminsight 复杂事件处理来实现这些。那么任何人都可以帮助如何在输入适配器中实现这些。

我的意思是在 InputAdapter 的 ProduceEvents() 函数中，我们是否需要不断地对表运行查询以进行更改？或者我们可以在输入适配器中使用 sqldependency 吗？如果是这样如何使用这些。

谢谢，桑迪

任何人都可以帮助我使用 IObservable/IObserver 模型实现 streamInsight 应用程序。我没有足够的资源来实现这些。高度赞赏有关这些主题的任何有用链接。

提前致谢。

我正在尝试使用事件流调试器工具连接到在 Visual Studio（而不是 Windows 服务版本）中运行的进程内 StreamInsight 主机，但我没有成功。

这个事情谁有经验？我正在查看以下博客文章：

端到端 StreamInsight 示例：http: //blogs.msdn.com/b/masimms/archive/2010/08/10/building-your-first-end-to-end-streaminsight-application.aspx

进程内与独立主机部署模型：http ://seroter.wordpress.com/2010/06/27/leveraging-and-managing-the-streaminsight-standalone-host/

我有一个事件流，其中包含一些变量的值。值每秒都在变化。每个变量都有定义的上限、下限和阈值周期。

例如，假设变量 1 的上限 = 95，下限 = 5，阈值 = 5 秒。

因此，如果 Variable1 的值在阈值周期（5 秒）内保持在 95（上限）以上，那么我们应该创建一个输出事件。

我可以创建查询来检查各个事件（如果它们已超过限制），但我不确定如何创建窗口查询来检查阈值期间是否违反了限制。

谢谢，

目前是否有人在使用StreamInsight（不仅仅是演示）？如果是这样，它目前在您的环境中是如何工作的？我们目前正在研究实施它的可能性，但我们都不太了解它，或者它是否真的是一个可行的选择。

我找不到任何报价，只有下载（最新版本看起来像 1.2）。

任何提示/建议/评论都将受到欢迎。我们目前正在使用 .Net 和 SQL Server，因此它似乎非常适合我们的环境。

有谁知道这个的一个很好的实现？

我想做 CEP，但委婉地说，使用 StreamInsight 有点贵。仅许可成本就相当繁重。是否有实现 Qbservable 替代方案的反应式框架，可以插入任何 ODBC 数据库甚至写入磁盘？

流洞察用户定义函数的限制是什么？

对象是否需要可序列化？

它可以调用外部（远程）服务吗？

如果是这样的话，这些看起来非常 - 非常 - 非常强大！

我想考虑基于有效负载的最新事件，即 StockTicksData id 并忽略时间窗口内的任何重复项

有效载荷和查询

上面的查询工作正常，但是当我使用输入适配器时，我必须插入一个 cti 事件来刷新输出。这是代码

Ticks Generator 它的到达时间为

priceTick.TimeofArrival = DateTime.Now.AddTicks(1);

输入适配器

相同的查询没有给出带有输入适配器和 cti 事件的预期输出

任何帮助将不胜感激。

我是 LINQ 的新手，上面的代码对我来说执行得很好。

但我不明白为什么在最后一句中写的是 c.payload.Quantity 而不是 c.Quantity。

当我用谷歌搜索时，我知道值 Quantity 是从我们从 c 中的结果中获得的有效负载中获得的，这是否意味着有效负载是 filterQuery 的最终输出？

假设我有一个已知结束时间的间隔事件，有没有办法在所述间隔事件到期之前触发另一个事件。这样做的目的是在那一点上我需要做一个聚合。

或者有没有办法进行查询（这不是所希望的，但我可能不得不求助于它）

如果我的理解完全不正确，请提出更好的方法。