Описание тега azure-stream-analytics

Относится к системе Microsoft Azure Cloud Analytics
2 ответа

Потоковая аналитика в концентратор событий - неожиданно объединяющие события

У меня есть задание потоковой аналитики, которое использует Event Hub из авро-сообщений (назовем это RawEvents), преобразует / выравнивает сообщения и запускает их в отдельный Event Hub (назовем это FormattedEvents). Каждый экземпляр EventData в Raw…
1 ответ

SELECT строковое выражение распознает одинарные, а не двойные кавычки?

Я создаю запрос Azure Stream Analytics, и мне нужно было вывести постоянный заголовок / значение столбца, и я заметил, что если я включу строковое выражение в виде SELECT item, он должен быть заключен в одинарные ('), а не в двойные (") кавычки, в п…
16 сен '17 в 20:53
2 ответа

Потоковая аналитика и сжатые авро

Привет, мы отправили авро сообщение на eventhub. С помощью потоковой аналитики мы читаем из этого концентратора событий. Мы увидели, что возможно сжать наше avro в сжатие с дефляцией. Может ли Stre am Stre am аналитика читать дефлированный сжатый av…
10 фев '17 в 12:41
0 ответов

Непоследовательные результаты аналитики Azure Stream

Я использую Azure Stream Analytics для передачи данных в хранилище озера данных. Исходный файл | CSV с разделителями Выход также | CSV с разделителями Входящий файл в хранилище BLOB-объектов корректно форматируется при проверке в notepad++, что кажд…
4 ответа

Как получить данные из массива в json-файле с помощью Microsoft Azure Query

Как я могу вернуть значение элемента массива в одном из моих входов, в котором индекс, в котором он находится, постоянно изменяется? Я почти уверен, что структура моего запроса правильная. У меня есть два входа, и я использую соединение, и я успешно…
04 июн '18 в 12:40
1 ответ

Игнорировать данные из входного массива потоковой аналитики, содержащего определенное значение

Используя этот пример данных: { "device":"TestDevice", "id":30, "flags":[ "New", "Ignore"] } Я хочу выбрать все данные без флага "Игнорировать", я получил его с помощью udf: SELECT device, id, flags FROM input WHERE udf.ArrayContains(flags, "Ignore)…
09 янв '19 в 23:12
0 ответов

Уникальный тег событий аналитики Azure Stream

Так что я думаю, что мне не хватает понимания мета-свойства eventID. Я обрабатывал это как ограничение PK в SQL. Однако, если я хочу заполнить свою базу данных заданным временем запуска в прошлом, я получаю те же данные, что и ввод?
04 май '18 в 14:44
1 ответ

Обновите запрос аналитики потока Azure в PowerShell, передав параметр командной строки вместо указания его в файле.json.

Я обновляю запрос Azure Stream Analytics с использованием powershell, выполнив следующую команду. New-AzureRMStreamAnalyticsTransformation -ResourceGroupName StreamAnalytics-Default-Central-US –File "C:\Transformation.json" –JobName StreamingJob –Na…
30 янв '17 в 06:50
1 ответ

Azure Stream Analytics преобразует значения массива

Очень конкретный вопрос, если у меня есть следующий вход в мой компонент Streaming Analytics: //some input "outputs": [ { "name": "output1", "unit": "unit1", "value": "95813" }, { "name": "output2", "unit": "unit2", "value": "303883" }, // and more …
18 июн '18 в 14:47
1 ответ

Stream Analyatic(SA) множественный вход и один выход

Мне нужен способ, где я могу объединить вход от 2 входа SA до 1 выхода SA. Например Я пытаюсь прочитать данные из двух входных данных и хочу поместить их в один выход (таблица SQL). Получено исключение, в котором говорится: "Дублированные выходные и…
23 май '16 в 17:46
1 ответ

Объединение сообщений от нескольких устройств

Существует ли рекомендуемый способ в экосистеме Azure объединять сообщения JSON, отправленные двумя или более отдельными устройствами примерно в одно и то же время, для их запуска, например, через веб-службу Azure ML. Целью этого было бы проведение …
01 июн '17 в 16:19
1 ответ

Сколько потоковых аналитических заданий вы можете иметь для одного хаба

Я создал две аналитические работы для одного iothub с несколькими устройствами. Но данные принимаются только для первого созданного потокового аналитического задания. Даже если я остановлю это, никакие данные не будут отправлены на второе задание ан…
18 окт '17 в 15:02
1 ответ

Какова максимальная предельная продолжительность в функции LAG в ASA?

Я передаю данные с устройств и хочу использовать функцию LAG для определения последнего значения, полученного от определенного устройства. Данные не передаются в течение регулярного периода, и в редких случаях между получением данных от устройства м…
24 май '16 в 04:08
1 ответ

Может ли Azure Stream Analytics читать сериализованные события BOND?

Я пытаюсь подключиться к POC с помощью Azure Stream Analytics. Я хочу читать из концентратора событий Azure и сохранять в хранилище BLOB-объектов Azure. Я работаю с этим руководством. Проблема в том, что когда я определяю свой входной поток (как сущ…
1 ответ

Синтаксическая проблема в Stream Analytics Query, работающем в Azure: неверное имя столбца: "полезная нагрузка"

У меня проблема с синтаксисом в моем запросе потоковой аналитики. Ниже приведен мой запрос Stream Analytics, где я пытаюсь получить следующие поля из событий: Идентификатор автомобиля Разница предыдущего и текущего уровня топлива (для каждого трансп…
0 ответов

Azure Stream Analytics для концентратора событий очень медленный

Stream Analytics работа занимает несколько минут, чтобы вывести результаты на Event Hub, Stateless Web API Azure Service Fabric Приложение распределено по 8 узлам. Приложение очень простое, состоящее из одного Controller, который: Получает серию JSO…
2 ответа

Могу ли я иметь несколько запросов в одном выводе в задании Azure Stream Analytics?

Могу ли я иметь несколько запросов в одном выводе в задании Azure Stream Analytics? Например SELECT property1, property2 INTO Output1 WHERE Property3 ='Answer' SELECT property4, property5 INTO Output1 WHERE Property3 ='Question'
20 июл '18 в 14:06
2 ответа

Является ли роль Azure Cloud Service Worker единственным вариантом хостинга Azure для запуска EventHub EventProcessor?

В настоящее время я пробираюсь через Event Hubs и EventProcessorHost. Все рекомендации, которые я нашел до сих пор, предполагают запуск EventProcessor в рабочей роли облачной службы Azure. Поскольку их развертывание и обновление очень медленные, мне…
2 ответа

Запрос Stream Analytics (выберите * в выводе)(исключить определенные столбцы)

У меня есть запрос, как; SELECT * INTO [documentdb] FROM [iothub] TIMESTAMP BY eventenqueuedutctime Мне нужно использовать *, потому что данные являются динамическими и не имеют конкретной схемы. Проблема в том, что данные системы Iothub записываютс…
20 сен '18 в 14:22
1 ответ

Размер входных данных концентратора событий в три раза больше при чтении с использованием потоковой аналитики

Когда я принимаю файл данных 100 КБ в концентраторе событий, когда я читаю данные из концентратора событий с использованием потокового аналитического файла, размер выходного файла в три раза больше, чем у входного файла. Пожалуйста подтвердите