Azure Streaming Возвращаемые данные

Question

Как лазурный поток может возвращать обработанные данные в реальном времени? Я вижу, что большинство примеров подталкивают обработанные данные обратно к БД или панели мониторинга. Мне нужно, чтобы все происходило в режиме реального времени для одного запроса (шаг 4). Как вы достигаете этого с минимальной задержкой? Пример ниже:

1) страница, запрошенная клиентом 2) Страница отправляет некоторые данные лазурного потока 3) Лазурный поток делает логику и расчеты с данными и данными из 5 второго окна 4) Посылает результат обратно на страницу, так это может выполнять какое-то действие IMMEDIATE 5) Сохраняет результат в базе данных для отчетности

Answer 1

Вы можете настроить вывод как EventUub, Queue или Topic Azure Service Bus, и ваше приложение контролирует один из этих выходов. Рабочий будет что-то вроде:

1. Страница запрошенной клиентом
2. Page отправляет данные ASA (Azure Стрим Analytics). Примечание: вы действительно отправляете данные в концентратор событий Azure, у которого есть задание ASA, работающее с EH в качестве входа.
3. Задача ASA делает логику/запрос и выводит на другой Azure EventHub (или в очередь или тему).
4. У вас есть работа в Интернете или на стороне сервера, отслеживающая выход EventHub и использование веб-карт для передачи этой информации обратно клиенту.

Вы можете найти пример кода на примере Microsoft Connect the Dots. В этом примере устройства IoT отправляют метеорологические данные в Azure EventHub, и есть сайт ASP.NET, который контролирует этот EventHub и через веб-камеры, обновляющие клиентов.