Размер запроса Stream Analytics достигает предела размера

Question

Я новичок в Azure Stream Analytics. У меня есть источник событий в качестве источника ввода, и теперь я пытаюсь выполнить простой запрос в этом потоке. Пример запроса выглядит так:

SELECT
count(*)
INTO [output1]
FROM
[input1] TIMESTAMP BY Time
GROUP BY TumblingWindow(second, 10)

Поэтому я хочу подсчитать события, поступившие в течение определенного периода времени.

При выполнении этого запроса я всегда получаю следующую ошибку:

Превышен максимально допустимый размер запроса

Поскольку я уже сузил проверенное временное окно, и я уверен, что количество событий в этом временном интервале не очень велико. (максимум несколько сотен) Я не уверен, как избежать этой ошибки.

У вас есть подсказка?

Спасибо!

Answer 1

Запрос превысил максимально допустимый предел размера

Эта ошибка (я думаю, она должна быть более явной) указывает на то, что вы нарушили Azure Stream Analytical resource и пределы объекта .

Это не только количество, но и размер. Пожалуйста, проверьте размер входов источника или попробуйте уменьшить размер окна и повторите тестирование.

---

1. Означает ли размер записи исходного запроса, что одно событие может иметь только 64 КБ, или этот параметр означает события 64 К?

Этоозначает, что размер одного события должен быть ниже 64 КБ.

Есть ли возможность использовать Stream Analytics для выбора только определенных подполей события или это единственный способ уменьшить размер события перед его отправкой в ​​концентратор событий?

Как я знаю, ASA только собирает данные для их обработки, поэтому размер зависит от стороны источника и вашего запроса sql. Поскольку вам нужно использовать COUNT, я боюсь, что вам нужно что-то делать на стороне концентратора событий. Пожалуйста, обратитесь к моим мыслям:

Использование Триггер функции Azure Event Hub , когдасобытие направляется в концентратор событий, запускает функцию, выбирает только частичные значения ключей и сохраняет его в пространстве имен другого концентратора событий (просто для того, чтобы уменьшить размер исходного события). В любом случае, вам нужно всего лишь COUNT записей, я думаюэто работает для вас.