使用Microsoft StreamInsight創建輸入適配器來觀察文件夾文件夾

Question

我需要使用sqlDependency編寫StreamInsight輸入適配器來觀察表格。實際上，通過使用SqlDependency，我們可以通知有關插入到表中的新行。所以我們計劃使用Streaminsight複雜事件處理來實現這些。所以任何人都可以幫助解決如何在輸入適配器中實現這些功能。

我的意思是在InputAdapter中的ProduceEvents（）函數中，我們是否需要連續運行查詢以更改表格？或者我們可以在輸入適配器中使用sqldependency嗎？如果是的話如何使用這些。

感謝， 桑迪

Answer 1

我會用內部隊列，要麼通過通知或由池會得到內存中的所有變化。

然後在ProduceEvents方法中，您可以使用參考代碼來嘗試從您的本地隊列中取出一個更改，如果沒有任何內容在持續閉環。