Можете ли вы использовать динамические выходные данные / выходные данные во время выполнения с аналитикой потока Azure

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

Выберите tableName, подсчитайте (отдельные записи) в tableName из inputStream

Надеюсь, это проясняет, чего я пытаюсь достичь, я пытаюсь вставить агрегированные данные в хранилище таблиц (определяемое как выходы). Я хочу получить имя выходного потока / хранилища таблиц из выбранного запроса. Есть идеи, как это можно сделать?


azure azure-stream-analytics
person Shahab Uddin    schedule 22.01.2020    source источник
comment
может ли это помочь в вашем случае? stackoverflow .com / questions / 45059617 /   -  person gusgonnet    schedule 13.05.2021

Ответы (1)


arrow_upward
0
arrow_downward

Я пытаюсь получить агрегированные данные, отправленные на разные выходы хранилища таблиц на основе имени столбца в запросе выбора.

Если я правильно понимаю ваше требование, вы хотите создать структуру case...when... или if...else... в ASA sql, чтобы вы могли отправлять данные в другой вывод таблицы на основе некоторых условий. Если так, я боюсь, что это не может быть реализовано до сих пор. Каждое место назначения в ASA должно быть конкретным, динамический вывод не поддерживается в ASA.

Однако в качестве обходного пути вы можете использовать функцию Azure в качестве выходных данных. Вы можете передать столбцы в функцию Azure, а затем выполнить переключение с помощью кода в функции Azure, чтобы сохранить данные в разных местах хранения таблиц. Дополнительные сведения см. В этом официальном документе: https://docs.microsoft.com/en-us/azure/stream-analytics/stream-analytics-with-azure-functions

person Jay Gong    schedule 29.01.2020
comment
Да, вы поняли. Вот что происходит. Я хочу создать агрегаты для нескольких клиентов, складов и сотрудников. Таким образом, устройство отправляет данные телеметрии в iothub на встроенной конечной точке, которая используется в качестве приемника ввода в потоковой аналитике. Потоковое задание объединяет сообщение телеметрии со входом ссылки (на основе идентификатора устройства в свойстве метаданных сообщения телеметрии), и теперь агрегаты создаются и отправляются в разные таблицы (для разных клиентов). Я выполнил справочную часть ввода, а часть агрегатов поместила в разные таблицы, чего не удалось достичь. - person Shahab Uddin; 29.01.2020