我需要使用 sqlDependency 编写一个 StreamInsight 输入适配器来监视表。实际上,通过使用 SqlDependency,我们可以通知插入到表中的新行。所以我们计划使用 Streaminsight 复杂事件处理来实现这些。那么任何人都可以帮助如何在输入适配器中实现这些。
我的意思是在 InputAdapter 的 ProduceEvents() 函数中,我们是否需要不断地对表运行查询以进行更改?或者我们可以在输入适配器中使用 sqldependency 吗?如果是这样如何使用这些。
谢谢,桑迪