NEsper — это библиотека для .NET, предназначенная для сложной обработки событий.
Она позволяет анализировать потоки данных в реальном времени с минимальной задержкой, используя принципы, похожие на SQL, но для событий.
Основные возможности:
• Обрабатывайте события по мере их поступления, выявляйте аномалии или интересные паттерны без задержки.
• Язык для описания правил обработки событий, чем-то похож на SQL, что делает его удобным для разработчиков.
• Поддерживает распределённые системы и интегрируется с Кафкой и RabbitMQ.
Пример использования:
using EsperTech.NEsper;
using EsperTech.NEsper.Client;
using EsperTech.NEsper.Config;
var config = new Configuration();
config.AddEventType("MyEvent", typeof(MyEvent));
var epService = EPServiceProviderManager.GetDefaultProvider(config);
var epStatement = epService.EPAdministrator.CreateEPL("select * from MyEvent where value > 100");
epStatement.Events += (sender, e) =>
{
foreach (var ev in e.NewEvents)
{
Console.WriteLine($"Detected event: {ev.Get("value")}");
}
};
В этом примере создаётся обработчик событий, который срабатывает, когда значение события превышает 100.
Такой шустрый инструмент пригодится в финансах, мониторинге и для обнаружения аномалий.
➡️ Обработать все события
🐸Библиотека шарписта #буст
