问题标签 [streaminsight]

我们正在使用 StreamInsight 进行一些测试，我们想知道是否有类似事件信息缓存的东西，以及它是否可配置。

提前致谢。

布鲁诺

我安装了 StreamInsight 2.1 并用这样的代码初始化服务器

我将此代码用于 2 个控制台应用程序。它会抛出如下错误。

我不明白为什么应用程序 A 工作，但应用程序 B 没有工作。

我也尝试将 2 个实例用于 2 个应用程序。但只有应用程序 A 有效，而 B 没有。

请注意，A 和 B 没有配置。由于 StreamInsight 不需要任何配置。

我正在使用评估版。

我被困在一个关于以下方面的架构问题上：

编辑：

所以我可能会过度思考这个问题，或者我可能会改写这个问题。NServiceBus 似乎是为 Messaging和（类似流的数据？）而制作的，Routing而 StreamInsight 似乎是为 和制作的。:)。Event Stream ProcessingEvent QueryingCorrelating

与方法 2相比，使用方法 1是否有任何好处（例如，在可扩展性、冗余方面）？

“方法一”

这是一条总线（例如 NServiceBus），用于将数据导入数据库并仅使用 StreamInsight 进行查询/关联。

“方法 2”

哪个不使用 NServiceBus，而是利用输入/输出适配器作为 Pub/Sub，而 Sub 是“主动将数据推送到数据库”的输出适配器？

原来的：

我们正在创建一个应用程序，将 Twitter 数据流式传输到我们的环境中。这个数据是：

1. 存储为原始（事件）输入数据
2. 解析/过滤
3. 已查询（使用 StreamInsight CEP）
4. 先前步骤之后的剩余数据存储为复杂事件

对于第 1 步，我不确定最需要的方法是什么：

1. 使用 StreamInsight 将数据流一分为二，其中一个输出适配器将原始数据存储在一侧的数据库中，另一个输出适配器将数据发送到另一个输入适配器以供进一步解析/过滤（步骤 2）。

-或者-

2. 使用不同的技术（MSMQ？Azure 服务总线？）“将原始数据流路由到数据库”

非常感谢任何指导！

我的项目使用嵌入流洞察实例运行良好。但是当我尝试在 Windows 上使用标准的 StreamInsight 服务时，运行此代码时出现异常

类型异常'Microsoft.ComplexEventProcessing.ConnectionException' occurred in Microsoft.ComplexEventProcessing.Diagnostics.dll

它说The management service encountered an error: Could not load file or assembly 'MyApplication, Version=1.0.5198.16312, Culture=neutral, PublicKeyToken=null' or one of its dependencies. The system cannot find the file specified.

我的问题

1.为什么StreamInsight 不能识别dll？

2.我需要将 dll 安装到 GAC 吗？

我正在使用 StreamInsight 2.1

我的系统是 64 位的。

我的项目配置了任何 CPU。

I have a problem I am stuck for two days now. Maybe someone of you guys can help me.

I try to get the starttime of a window passed to a user defined aggregate. Unfortunately I don't know how to do this. The way I thought it should work looks like that:

And the UDA looks like this:

I tried to pass the window start to the config of the UDA and read it from there. Has anyone an idea why this doesn't work that way and how I could get the starttime of the window passed to the UDA to use it for calculation there?

I am very grateful for any hint.

Joe

我观察到我的 StreamInsight 应用程序中的事件处理非常奇怪。有一个 InputAdapter 将 Stream 划分为 TumblingWindows。然后我有多个查询同时运行。他们应该使用来自同一个 Stream 的所有相同的 TumblingWindows。我用这段代码来定义窗口：

然后我从这个流中执行两个不同的查询。使用此代码：

像这样将每个绑定到自己的 OutputAdapter：

以下链接显示了我收到的输出。

https://dl.dropboxusercontent.com/u/15482726/outputissue.jpg

不幸的是，我收到的输出不是我所期望的。看起来每个查询都有自己的输入适配器。并且消息被分发到两个输入适配器。即使 dstream 只创建一次，但工厂被调用了两次。但为什么以及何时？这怎么可能？如果我只使用一个查询，一切都会完美。

我使用了这个链接的解释http://technet.microsoft.com/en-us/library/ff518536.aspx 认为它应该这样工作。

非常欢迎任何帮助。

最好的问候乔

我遇到了一个问题，我不知道它为什么会出现。我有一个 InputAdapter 接收随机生成的事件用于测试目的。

以下代码创建了一个删除大量事件的查询。我实际上想保留它。

有谁知道为什么在 DataInputStream 和 DatainputStream_CleanseInput 之间只有五分之一的事件通过？见下图。有没有办法避免这种情况？

https://dl.dropboxusercontent.com/u/15482726/CleanseIssue.jpg

我非常感谢任何帮助。

最好的问候，乔

我正在考虑将 StreamInsight 用于我正在研究的CEP系统，但是我可以在网上找到的任何文档中似乎都不存在横向扩展的故事。StreamInsight 似乎设计为在单个服务器上运行。我正在查看的系统规模可能达到每秒数万个事务，并且需要具有高 SLA。因此，我需要了解（如果有人）如何水平扩展 StreamInsight 部署，这意味着在多个服务器上实现高可用性。

看起来 SI 团队在 2011 年就考虑过这个问题，但由于SI 的最新版本是从 2012 年开始的，因此不清楚是否有任何结果。

We've been using StreamInsight for a while to process various events. In the search of a good ESB platform, we also wonder if we could use StreamInsight for the same purpose.

A couple of the key differences between StreamInsight and something like NServiceBus are

1. Max message/event size (StreamInsight is obviously limited in this area)
2. Pub/Sub (takes some work to make StreamInsight work)
3. Easily turn something into a WCF endpoint (NServiceBus is good for this)

But limitations aside, couldn't StreamInsight serve as a poor man's ESB? Or I'm just trying to fix a square peg in a round circle?

我正在使用作为 Windows 服务托管的 StreamInsight 2.1，并希望将传感器事件从传感器服务器发送到它。有必要使用WCF吗？如果是，请给我一个很好的帮助。