Azure Stream Analytics Как обработать более 5 запросов? - PullRequest
Новая
       119

Azure Stream Analytics Как обработать более 5 запросов?

1 голос
/ 29 января 2020

Я создал одно задание ASA, а также создал один вход (eventhub) и 6 выходов (2 космоса и 4 очереди служебной шины). Запросы аналогичны приведенным ниже. SA позволяет написать более 5 запросов, но выдает ошибку в журналах активности. Из-за чего я также получаю задержку с водяным знаком. 

1: Select
             *
          INTO
             CosmosOutput
          FROM
             eventhubinput ;
2:       Select
             id,long,lat,timestamp
          INTO
             CosmosOutput1
          FROM
             eventhubinput ;
3:       Select
             *
          INTO
             SB1
          FROM
             eventhubinput 
           Where <condition>;

4:          Select
             *
          INTO
             SB2
          FROM
             eventhubinput 
           Where <condition>;
5:          Select
             *
          INTO
             SB3
          FROM
             eventhubinput 
           Where <condition1>;
6:          Select
             *
          INTO
             SB4
          FROM
             eventhubinput 
           Where <condition1>;

Вопрос:

Как мне написать более 5 запросов эффективным способом? Заранее спасибо!

1 Ответ

1 голос
/ 30 января 2020

Поскольку у вас есть несколько запросов, вы можете попытаться выделить Настройки потоковых единиц .

Потоковые единицы (SU) представляют вычислительные ресурсы, выделенные для выполнения задания Stream Analytics. Чем больше SU, тем больше ресурсов процессора и памяти выделяется для вашей работы. Выбор количества необходимых SU для конкретного задания зависит от конфигурации раздела для входов и запроса, определенного в задании.

enter image description here

Определенно, SU дает больше затрат. Другой обходной путь, вы можете установить azure выход функции для замены некоторых запросов. Например, я заметил, что вам нужно поместить sh данные в другой вывод служебной шины с абсолютно одинаковыми условиями. Вы можете объединить их в один запрос и добавить те же данные в функцию Azure в качестве параметров. Внутри функции Azure настройте несколько выходных привязок служебной шины .

...