Создание адаптера ввода с помощью Microsoft StreamInsight для просмотра папки для файлов

Question

Мне нужно написать входной адаптер StreamInsight, используя sqlDependency для просмотра таблицы. На самом деле, используя SqlDependency, мы можем уведомлять о новых строках, вставленных в таблицу. поэтому мы планируем реализовать их с помощью комплексной обработки событий Streaminsight. Так может кто-нибудь помочь, как реализовать их во входных адаптерах.

Я имею в виду, что в функции ProduceEvents () в InputAdapter нужно постоянно выполнять запрос к таблице изменений Или мы можем использовать sqldependency во входном адаптере? если да, то как их использовать.

Спасибо, Sandy

Answer 1

Я бы использовал внутреннюю очередь, которая либо по уведомлению, либо по пулу получала бы все изменения в памяти.

Затем в методе ProduceEvents вы могли бы использовать ссылочный код, чтобы попытаться снять изменения с вашеголокальная очередь, и если там ничего нет, просто продолжайте в замкнутом цикле.