c# - ファイルのフォルダーを監視するために Microsoft StreamInsight を使用して入力アダプターを作成する

Question

テーブルを監視するために、sqlDependency を使用して StreamInsight 入力アダプターを作成する必要があります。実際に SqlDependency を使用すると、テーブルに挿入された新しい行について通知できます。そのため、Streaminsight 複合イベント処理を使用してこれらを実装する予定です。したがって、これらを入力アダプターに実装する方法を誰でも助けることができます。

つまり、InputAdapter の ProduceEvents() 関数では、変更のためにテーブルに対してクエリを継続的に実行する必要がありますか? または、入力アダプターで sqldependency を使用できますか? もしそうなら、これらを使用する方法。

ありがとう、サンディ

Answer 1

通知またはプーリングによってすべての変更がメモリ内に取得される内部キューを使用します。

次に、ProduceEvents メソッドで参照コードを使用して、ローカル キューから変更をデキューし、何もない場合はクローズド ループを続行します。