Microsoft представила платформу Data Change Processing с открытым исходным кодом

Microsoft анонсировала Drasi (Data Change Processing), новую платформу обработки изменений данных с открытым исходным кодом. Она позволит разработчикам автоматизировать интеллектуальные реакции в динамических системах. Вместо копирования данных в центральное озеро данных или периодического запроса источников Drasi отслеживает изменения, наблюдая за событиями в журналах и лентах изменений.

При разработке Drasi использовали lowcode-подход на основе запросов, что позволяет разработчикам писать сложные графовые запросы для определения сложных правил, описывающих типы изменений, которые они хотят обнаружить. Затем платформа определяет, вызывают ли какие-либо изменения обновления наборов результатов. При их обнаружении Drasi выполняет контекстно-зависимые реакции. Весь этот процесс выполняется с использованием трёх компонентов: источников (Sources), непрерывных запросов (Continuous Queries) и реакций (Reactions).

Sources подключаются к различным источникам данных в системах, непрерывно наблюдая критические изменения. Они отслеживают журналы приложений, обновления баз данных или системные метрики и собирают соответствующую информацию в режиме реального времени.

Drasi использует Continuous Queries вместо ручных, постоянно оценивая их на основе предопределённых критериев. Эти запросы, написанные на языке Cypher, могут интегрировать данные из нескольких источников без необходимости предварительного сопоставления.

Когда зафиксированы изменения, Drasi запускает Reactions, которые могут отправлять оповещения, обновлять другие системы или выполнять шаги по исправлениям.

Continuous Queries пишутся как декларативные графовые запросы с использованием языка Cypher. Это позволяет создавать один запрос для описания изменений, которые нужно