Azure Stream Analytics - добавьте TopOne с Order с помощью input.EventEnqueuedUtcTime vs EventEnqueuedUtcTime - PullRequest
0 голосов
/ 25 октября 2018

Сегодня я пытался получить последнюю запись, основанную на времени в очереди событий.Первоначально я попытался выполнить запрос ниже, который не принес мою последнюю запись по времени.

SELECT 
    TopOne() OVER (ORDER BY (CAST(eventHubInput.EventEnqueuedUtcTime AS DATETIME)) DESC) as FirstRecord 
FROM 
    eventHubInput 
WHERE 
    eventHubInput.SensorType = 'My Condition' 
GROUP BY 
    TumblingWindow(minute, 2)

Позже вместо использования eventHubInput.EventEnqueuedUtcTime я попробовал запрос ниже, который выбрал мою недавнюю запись .

SELECT 
    TopOne() OVER (ORDER BY (CAST(EventEnqueuedUtcTime AS DATETIME)) DESC) as FirstRecord 
FROM 
    eventHubInput 
WHERE 
    eventHubInput.SensorType = 'My Condition' 
GROUP BY 
    TumblingWindow(minute, 2)

Обратите внимание, во втором запросе не используется eventHubInput.EventEnqueuedUtcTime , вместо этого я заменил его на EventEnqueuedUtcTime .

Я не был уверен, почему первый запрос не извлек мои недавние события, может кто-нибудь указать мне, в чем же разница?

Заранее спасибо.

...