Запрос событий в хранилище концентраторов событий BLOB Azure
Я изучаю технологии для захвата и хранения системных событий (с целью, возможно, в будущем внедрить некоторые системы "источников событий").
Мне интересны концентраторы событий 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
}
}
2 ответа
Чтобы зарегистрироваться, пожалуйста, нажмите на ссылку выше
В потоковой аналитике появилась новая функция, с помощью которой вы можете разделить вывод в хранилище BLOB-объектов по любым атрибутам или полю по вашему выбору. Это с помощью простого запроса SQL сделает его очень простым.