在输出适配器流洞察力中创建新事件



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

为了实现这个想法,我需要在outputadapter中创建一个新事件,以了解表中所写的预测时间。但是我不认为从outputadapter在streaminsight服务器中排队新事件是可能的。

也许这张图清楚地说明了问题:http://i40.tinypic.com/4h4850.jpg

希望有人能帮助我。由于卡洛

首先,根据您对术语"输出适配器"的使用,我假设您使用的是2.1版本之前的StreamInsight。

从你发布的内容来看,我强烈建议你的适配器要么输入要么输出,但不要两者都做。这降低了复杂性,使实现更容易,并且根据您编写适配器的方式,您现在在解决方案中拥有了可重用的代码段。

如果你想从StreamInsight发送数据到你的神经网络预测引擎,你需要写一个输出适配器来做这件事。然后我将创建一个输入适配器,它将从神经网络预测引擎获得结果,并将数据排队到StreamInsight中。从神经网络预测引擎输入适配器创建流之后,您可以使用动态查询组合将流共享到Windows Azure存储输出适配器和下一个查询。

如果你的神经网络预测引擎可以将数据"推送"到你的输入适配器,那将是这样做的。如果没有,你将不得不投票获得结果。

还有很多,但是如果没有更多的细节,就很难深入了解更多的细节。

最新更新