Azure Stream Analytics временные запросы

Я новичок в Azure, и я не уверен, что я получаю правильную систему запросов. У меня есть приложение, которое отправляет данные каждые 1,5 секунды на мою служебную шину, и мне нужно получить данные в PowerBI в режиме реального времени. Самый простой запросAzure Stream Analytics временные запросы

SELECT * FROM DataSource

возвращение все данные и я не могу использовать его, чтобы увидеть в реальном времени события. Поэтому я искал, и я нашел о Temporal Queryes, но каждый пример, который я следую, не помогает мне (возможно, я не делаю это правильно). Вот мой запрос:

SELECT id, pais, temp, vel, son, lon, lat, hora, dia, colisao, multa, motor, System.timestamp as time, COUNT(*) 
FROM fakentrance TIMESTAMP BY time 
GROUP BY 
id, pais, temp, vel, son, lon, lat, hora, dia, colisao, multa, motor, 
TUMBLINGWINDOW(s, 2)

неоспоримый более конкретно, то, что мне нужно сделать что-то вроде: Если мой игрушечный автомобиль ускоряется я могу иметь калибр, чтобы показать, что это увеличение или уменьшение ускорения, или реальная температура моя комната, поэтому, если она составляет 30 ° c, и она опускается до 16 ° C, она показывает это точно значение. Что я делаю неправильно?

источник

2016-03-03 Anonymous

Вы определили выходной сигнал мощности BI? Простой запрос должен передавать все входящие события на его вывод. Вам не нужно ничего больше, если у вас есть только выход sinlge. –

У вас есть столбец под названием «время» с типом datetime? Каково было поведение, когда вы начали работу с вышеуказанного запроса, вы видели события в powerBI? Вы видели какие-либо проблемы в журналах операций и на странице мониторинга Azure показывали статистику о количестве входных событий, ошибок и т. Д.? –

Vignesh Я не вижу какого-либо странного поведения, я отредактировал свой запрос, как показано на подменю, и он показывает данные на моем PowerBI, но он все еще показывает все данные, хранящиеся на сервере. –

Убедитесь, что вы правильно определили свой вход и выход и включили их в свой запрос.

SELECT id, pais, temp, vel, son, lon, lat, hora, dia, colisao, multa, motor, System.timestamp as time, COUNT(*) 
    INTO 
    <PowerBIOutput> 
    FROM <DataSource> TIMESTAMP BY time 
    GROUP BY 
    id, pais, temp, vel, son, lon, lat, hora, dia, colisao, multa, motor, TUMBLINGWINDOW(s, 2)

источник

2016-03-03 19:18:57

Я пробовал это, и мой запрос работает нормально, но у меня нет такого поведения, которое я хотел. Я отредактирую свой вопрос, чтобы уточнить его, и вы прокомментируете, возможно ли это или нет. Но спасибо, это помогло, оно не сработало –

Попробуйте использовать группу TUMBLINGWINDOW (s, 2), id –

ответ

Смежные вопросы