поток аналитика концентратор Событие Выход

Question

Следующая Stream AnalyticsQuery подсчитывает количество событий, сгруппированные по IP-адрес, в 10-секундными интервалами: Sliding Window

Select 
    Min(Time) as FirstHit, 
    Max(Time) as LastHit, 
    Count(*) as Total, 
    IPAddress 
From 
    Input Partition By PartitionId TimeStamp By Time 
Group By 
    SlidingWindow(second, 10), IPAddress, PartitionId 
Having 
    Total >= 10 

В результате агрегации выводится на Event Hub.

Следующая JSON полезная нагрузка 10 простых объектов, расположенных точно в 1 секунду друг от друга, в пределах 10-втором окне публикуется Stream Analytics, должны быть обработаны описанным выше Query:

[{ 
    "IPAddress": "192.168.0.10", 
    "Time": "2016-09-02T11:40:01" 
}, { 
    "IPAddress": "192.168.0.10", 
    "Time": "2016-09-02T11:40:02" 
}, { 
    "IPAddress": "192.168.0.10", 
    "Time": "2016-09-02T11:40:03" 
}, { 
    "IPAddress": "192.168.0.10", 
    "Time": "2016-09-02T11:40:04" 
}, { 
    "IPAddress": "192.168.0.10", 
    "Time": "2016-09-02T11:40:05" 
}, { 
    "IPAddress": "192.168.0.10", 
    "Time": "2016-09-02T11:40:06" 
}, { 
    "IPAddress": "192.168.0.10", 
    "Time": "2016-09-02T11:40:07" 
}, { 
    "IPAddress": "192.168.0.10", 
    "Time": "2016-09-02T11:40:08" 
}, { 
    "IPAddress": "192.168.0.10", 
    "Time": "2016-09-02T11:40:09" 
}, { 
    "IPAddress": "192.168.0.10", 
    "Time": "2016-09-02T11:40:10" 
}] 

И Stream Analytics работа и Event Hub экземпляр только что создан.

Stream Analytics не выводит соответствующее событие, несмотря на то, что полезная нагрузка события соответствует критериям Query.

Однако при выдаче запроса , публикующего эту же полезную нагрузку до Stream Analytics, создается событие вывода с правильными метаданными.

Есть ли несоответствие в моей конфигурации или какая-то функция загрузки/перемотки/разминки/смещения Stream Analytics, что приводит к тому, что первая полезная нагрузка эффективно игнорируется?

Answer 1

Я предполагаю, что вы взаимодействуете с ним в следующем порядке:

1. События направляются к ступице.
2. Работа по StreamAnalytics запускается с текущего времени.
3. Другие события отправляются на концентратор.

Будучи EventHub поток, он не имеет понятия текущего времени, StreamAnalytics нуждается правильное смещение для начала обработки событий.

Если вы дадите нам более подробную информацию, мы сможем подтвердить это или исследовать проблему дальше.

Как из моего комментария, из входного лезвия StreamAnalytics в портале вы можете отбирать данные из ввода и подавать его в свой запрос, чтобы убедиться, что результат, который вы ожидаете, есть (временное окно будет проигнорировано , но вы можете просто запрограммировать временное окно, которое вы хотите с первого ввода).

Кроме того, поскольку вы указываете предложение TIMESTAMP BY, убедитесь, что ваш вход настроен с допуском для событий, не входящих в порядок, в случае, если ваш заказ не гарантирован (https://msdn.microsoft.com/en-us/library/azure/mt674682.aspx).

Более подробная информация о позднем прибытии/из заказа настроек для ввода: https://blogs.msdn.microsoft.com/streamanalytics/2015/05/17/out-of-order-events/