问题标签 [streaminsight]

我开始使用 StreamInsight 并将其用作 wcf 服务。我已经尝试在“ A Hitchhiker's Guide to Microsoft StreamInsight Queries ”中寻求帮助，并尝试了这些示例以及 codeplex 中的示例。

我的问题是这样的：

我的事件生产者向适配器提供 AlertEvent 的：

当 AlertEvent 的 IsError = false 时，标志 IsToNormalize 为 true；

我试图实现的行为是，当我收到带有 IsError 的流时，我想看看在接下来的“x”分钟内，是否有任何带有 IsToNormalize 的 alertEvent 到达。然后我发送以输出开始搜索的 IsError AlarmEvent。

我所做的是，当我收到与过滤器相对应的输入时，我会在“x”分钟内延长其生命周期并创建一个 TumblingWindow 以查看在此期间是否有另一个 AlertEvent 与另一个标志一起到达（使用 ExtensionMethod 进行迭代通过窗口中的所有有效负载）。

然后，为了获得触发 TumblingWindow 的 AlarmEvent，我与原始输入进行了连接。

这根本不起作用......：/有什么想法可以帮助解决这个问题吗？

我的另一个疑问是，是否会为每个通过过滤器的输入创建一个带有新 startDate 的新窗口，或者是否只创建一个 tumblingWindow。

谢谢。

我正在寻找一些可能的选项来使用 Microsoft StreamInsight 流式传输数据库级别发生的所有更改。一种可能的方法是使用数据库触发器（我不认为这是一个好方法）。如果有人有这方面的经验，请提出建议。

我也对其他产品持开放态度，我真正想做的是监控数据变化并针对它们引发相应的事件。任何帮助将不胜感激 ：）

从评论中查看以下详细信息可能会有所帮助：我们有一个信息系统，其中很少有用 C++ 编写的组件，很少用 PowerBuilder 编写，其余全部用 C# 编写。它们都位于通用数据库之上。简而言之，我们没有单一的数据库入口点。我们现在正在研究的是添加基于事件触发的可配置规则。这可以使用 3rd 方规则引擎轻松实现。我们现在唯一的挑战是如何根据数据的变化生成这些事件。我从 SQL Server 端读到了大约 2 个选项：更改跟踪更改数据捕获甚至不确定是否有帮助。我还试图了解 StreamInsight 如何帮助我们实现这一目标。我希望这增加了问题的清晰度。

在 Intranet 设置中，我有多个客户端，并且每个客户端都需要将数据发送到 StreamInsight 服务器。数据是事件驱动的，例如，当用户点击页面时，需要将数据（哪个用户点击了哪个对象）发送到 streaminsight 服务器。

此外，每个客户端都可以发送大量数据，因此设计需要具有可扩展性。

我是 StreamInsight 的新手，如果有人能指导我如何将数据从客户端发送到 StreamInsight 服务器，我将不胜感激？

谢谢

PS：当我发现/弄清楚更多事情时，会不断更新。

在设置一个简单的 streaminsight 应用程序时，我遇到了 server.create() 工作且 server.connect() 失败的问题。我不确定可能是什么潜在原因。

编辑：这里的源代码：http: //pastebin.com/XigdxXLd

我的设置：

• 客户端发送数据的私有 msmq
• 服务器使用输入适配器读取此 msmq 并将输出生成到文本文件

使用上述设置，如果我创建了一个 streaminsight 服务器的内存实例（使用server.create("MyInstance")，它会消耗 msmq 中的所有消息并且工作正常（应用程序退出前大约需要一分钟，因为它喜欢坐在 server.dispose () 叫了一会儿）。

如果我使用以下命令切换到 server.connect：

它只消耗 msmq 的一条消息，并且应用程序永远不会完成。该项目在一分钟后超时application.Delete()（其中应用程序是 MS.CEP.application）。

有人可以帮我解决我可能做错的事情吗？

另外，我最近尝试打开该StreamInsightHost.exe.config文件，但记事本和 Visual Studio 都不允许我打开它。不确定这是否会影响任何事情，但我只是想我会把它放在那里。

I/O 适配器是否必须与 StreamInsight 服务在同一台计算机上运行？换句话说，当 StreamInsight 在后端服务器上运行时，是否可以在应用程序服务器上运行输入适配器？

我想向我的输出适配器发送一个有效负载窗口。我需要所有这些都同时进入我的输出适配器，而不是一个一个。

所以，到目前为止我有：

var filteredCepStream = (from window in cepStream.HoppingWindow( TimeSpan.FromMinutes(outputConfig.WindowLength), TimeSpan.FromMinutes(outputConfig.WindowHopSize), HoppingWindowOutputPolicy.ClipToWindowEnd) select window);

但 StreamInsight 不允许我通过窗口发送。有什么方法可以使用户定义的聚合或其他东西将其转换为有效负载列表以发送到输出适配器？我要这样做是错误的方式吗？我真的需要将窗口中的所有有效负载同时发送到输出适配器。

谢谢！！

迪娜

搜索 StreamInsight 文档，似乎应该可以为给定的事件流表达形式的查询，当事件 A 后跟事件 B 时生成输出，但我看不出如何将其表达为LINQ 查询，我在文档中也找不到任何示例。

任何人都可以帮忙吗？提前谢谢。

我想在 StreamInsight 应用程序中实现一个输入适配器，它从网络获取事件，给定 ip:port（更多详细信息：http: //social.technet.microsoft.com/Forums/en-US/streaminsight/thread/ e7bcc2c4-45b8-4225-836a-102fd3be437b）。我阅读的所有示例都以拉取方式工作，而我的场景需要推入方式。你知道这样的样本吗？或者你能给点建议吗？网络编程不是我的领域，但如果我知道从哪里开始，我可以快速学习。

谢谢

我已经安装了 StreamInsight，并且能够运行示例示例。但是当我尝试打开 StreamInsight 事件流调试器和“连接到服务器”时，它显示以下错误：

我创建了名为“StreamInsightInstance”的实例，我使用此链接连接到服务器。

有人可以建议答案吗？

我最近开始学习 CEP。我计划在我的项目中实施这些 StreamInsigh CEP

我的应用程序是这样的：我需要编写一个应用程序来监视表中新插入的行。需要对这些新行进行操作。

我们可以在不使用 Sql Dependency 的情况下实现这一点吗？或者我可以使用 SqlDependecy+CEP。

请建议我最适合的解决方案