Я изучаю технологии для захвата и хранения системных событий (чтобы, возможно, в будущем внедрить некоторые системы "источников событий").
Мне интересны концентраторы событий Azure, так как мне нравится идеяпостроения служб обработки в приложениях функций и логики Azure и их запуска по инициируемому событию.
Я создал свой концентратор событий клиента и включил «захват», поэтому мои события и полезные данные хранятся в BLOB-объекте Azure.хранилище (файлы .avro)
Мне интересно, как, да и вообще, если бы я вообще мог запрашивать события, скажем, у меня есть поток, захватывающий все мои взаимодействия с «Клиентами», такие как Register / Update_Contact_Address и т. д...... и я хотел найти все события для определенного идентификатора клиента, как это достигается?Я видел задания Stream Analytics, но, похоже, они предназначены для «анализа данных в реальном времени», а не для того, чтобы я мог запросить параметр из приложения, скажем, мой Guid клиента.
Я надеялся создать небольшойПриложение администратора, которое позволило бы мне выбрать клиента и собрать все события клиента, захваченные для этого идентификатора?
Ниже приведен пример события, которое я сохранил (извлечено из файла .avro)
{
"EventId": "51e3610f-8520-406d-8736-45f382bc5110",
"EventName": "ReceiveCustomerReview",
"ReceivedAt": "0001-01-01T00:00:00",
"Client": 1,
"customerGuid": "x45y57x2-5dcc-45c4-86c5-78942db363w1"
"Payload": {
"stars": 5,
"comment": "OMG..... Beautiful product",
"ClientId": 1
}
}