Блог

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

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

Спасибо, Сэнди

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

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