0

我在 StreamInsight 中有以下问题。我有一个查询，订单中的新任务来自哪里，并触发输出适配器进行预测。输出适配器将预测的任务周期时间写入表（在 Windows Azure 中）。预测基于神经网络并插入输出适配器。在表中写入预测后，我想对所有预测时间做其他事情。所以在第二个查询中，我想在 5 分钟的时间窗口内计算书面任务的数量。当表中保存的预测值数量等于订单中的任务数量时，我想从表中获取所有的预测值，并对订单周期时间进行预测。

对于这个想法，我需要在我的输出适配器中创建一个新事件，以了解预测的时间写在表中。但我认为不可能从输出适配器将新事件排入流洞察服务器中。

也许这个数字说明了问题：http: //i40.tinypic.com/4h4850.jpg

希望可以有人帮帮我。谢谢卡洛

4

1 回答 1

1

首先，根据您对术语“输出适配器”的使用，我假设您使用的是 2.1 之前的 StreamInsight。

根据您发布的内容，我强烈建议您的适配器进行输入或输出，但不能同时进行。这降低了复杂性，使实现更容易，并且根据您编写适配器的方式，您现在在解决方案中拥有一段可重用的代码。

如果您想将数据从 StreamInsight 发送到您的神经网络预测引擎，您需要编写一个输出适配器来执行此操作。然后我将创建一个输入适配器，该适配器将从神经网络预测引擎获取结果并将数据排入 StreamInsight。从神经网络预测引擎输入适配器创建流后，您可以使用动态查询组合将流共享到 Windows Azure 存储输出适配器和您的下一个查询。

如果您的神经网络预测引擎可以将数据“推送”到您的输入适配器，那将是可行的方法。如果没有，您将不得不轮询结果。

这还有很多，但如果没有更多细节，就很难深入了解更多细节。

希望这可以帮助。

于 2013-05-15T04:40:43.190 回答