问题标签 [streaminsight]

如果没有事件，StreamInsight TumblingWindow 会触发吗？

我在这里看到的所有示例，每个窗口内总是有一个事件：http: //sqlblog.com/blogs/stream_insight/archive/2010/12/15/windows-in-streaminsight-hopping-vs-snapshot。 aspx

但问题是当特定窗口中没有事件时，它会触发吗？

我开始了解 StreamInsight (v2.1!) 并开始开发基于 StreamInsight 团队的 WCF 示例的应用程序。现在我想为该应用程序添加弹性和监控，但不知道如何。我已经尝试遵循检查点示例和这些教程，但没有运气： http: //msdn.microsoft.com/en-us/library/hh290476 (v=sql.111).aspx

http://msdn.microsoft.com/en-us/library/ee391166(v=sql.111).aspx

我应该调整 WcfObservable 吗？或者我应该如何为我的 observable、observer 和 query 添加弹性？

这是我的代码的一部分：

在此先感谢您的时间！

I'm trying out StreamInsight and I came across a problem with a query I need.

I'm trying to throw a warning if there are several changes in my measured values (of up to 20% change) in the last 30 minutes.

This is the query I came up with for now but it isn't working and it's not even correct I think.

Apparently I can't filter on a window...?

Thanks in advance!

我正在使用 StreamInsight 2.1 开发一个 StreamInsight 应用程序。

输入适配器将是每秒具有数千个事件的实时库存数据流。我想使用相同的数据流运行多个独立的查询，并能够在流运行时添加更多查询，在流中的当前位置获取。

但是，每当我编写查询时，它都会创建一个全新的输入适配器。所以，我最终得到了 25 个输入适配器，它们都加载和推送相同的数据。

我只是在想这个错误吗？输入适配器是否独立于每个查询？

将实时库存数据放在输入适配器后面并让每个输入适配器再次流式传输该数据的唯一解决方案是什么？

任何建议都会很好，很难找到关于 StreamInsight 的好的文档。

我一直在尝试实现以下适配器以将 StreamInsight 与 BizTalk 连接： http ://seroter.wordpress.com/2010/07/09/sending-streaminsight-events-to-biztalk-through-new-web-soaprest-适配器/#comment-11635

最后，他执行以下操作将查询绑定到适配器：

现在，如果我没记错的话，这在 StreamInsight 2.1 中不再起作用，我不知道如何做到这一点。有人可以帮我吗？提前致谢！

我正在使用 StreamInsight 2.1 并遇到了意外的性能问题。

我有一个财务数据输入适配器，每秒输入 5,000 到 10,000 个事件。然后，我有大量针对该输入的查询。每个查询都连接到完全相同的直通查询，因此我有 1000 个查询使用完全相同的输入数据。

为了测试系统是否能够处理这个问题，我创建了 1000 个查询，这些查询除了传递（from d in fullStream select d）事件到仅释放事件的输出适配器之外什么都不做。

当我以这种方式运行 1,000 个查询时，系统无法跟上数据流。它越来越落后。如果我将其减少到 100 个查询，则系统可以完美运行。

我是否只是在使用 StreamInsight 时遇到了性能壁垒？它无法处理我正在构建的解决方案类型吗？还是我在这里做一些愚蠢的事情......任何帮助都会很棒，不知道还有什么可以让它更快。我需要它能够执行超过 1000 个查询，并且我需要运行比这更复杂的查询。

也许这可以在没有 StreamInsight 的情况下完成，但我很好奇。

我有一个应用程序正在使用“消息”填充表（在表中插入一行）。

我想创建一个监视应用程序来监视此表的消息“到达”速率，以及它们“处理”的速度（标志更新）。

由于这是一个供应商应用程序，我不想插入触发器或任何东西。但我可以查询数据库，并且该表有一个使用标识列的 PK。

如何进行跳窗查询？我很想显示过去 30 分钟的折线图，显示消息进入的速度，以及消息被处理的速度。

在我的项目中，我需要跟踪数据库表中新插入的行。并将这些行提供给 .net 应用程序进行处理。我通过了 StremInSight，它非常适合。所以我想知道的是有什么选项可以捕获 StreamInSight 中的变化吗？否则我怎么能同时加入 ServiceBroker 和 StremInSight。我的意思是我们可以使用服务代理将更改流式传输到 StreamInsight 吗？

我一直在尝试基于 Austin Sample 创建一个示例应用程序。首先，我有一个带有示例的 404，我通过调整 App.Config 中的 connectionString 来修复它（我忘了那个，我的错）。现在我创建了第二个接收器，它应该将消息发送到服务总线队列而不是 Azure 表。启动 SampleApplication 和 EventSourceSimulator 时，前两条消息似乎正确传递，但第三条消息显示 404 错误。以下是错误的屏幕截图和我的接收器的类。如果您需要更多信息来帮助我，请告诉我。提前致谢，

更新：我在管理门户的服务总线队列中看不到任何东西，所以我想那里什么也没有。

在 StreamInsight 2.0 中处理异常的最佳实践是什么？

当发生异常时（我不是在谈论丢失的事件，而是在代码中的某些地方出现 NullReferenceException 之类的实际异常）考虑到一切都是异步执行的，您如何处理它并安全地停止应用程序？