0

我需要使用 sqlDependency 编写一个 StreamInsight 输入适配器来监视表。实际上,通过使用 SqlDependency,我们可以通知插入到表中的新行。所以我们计划使用 Streaminsight 复杂事件处理来实现这些。那么任何人都可以帮助如何在输入适配器中实现这些。

我的意思是在 InputAdapter 的 ProduceEvents() 函数中,我们是否需要不断地对表运行查询以进行更改?或者我们可以在输入适配器中使用 sqldependency 吗?如果是这样如何使用这些。

谢谢,桑迪

4

1 回答 1

1

我会使用一个内部队列,通过通知或池化将获取内存中的所有更改。

然后在 ProduceEvents 方法中,您可以使用参考代码尝试从本地队列中取出更改,如果没有任何内容,则继续闭环。

于 2012-01-19T15:07:04.873 回答