c# - 使用 Microsoft StreamInsight 创建输入适配器以监视文件的文件夹

Question

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

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

谢谢，桑迪

Answer 1

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

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