Azure Stream Analytics с двумя входами концентратора событий присоединяется

Question

У меня есть два входа концентратора событий (Event-A и Event-B) для аналитики потока Azure. Входное событие-A: первичное (всякий раз, когда я получаю событие из "события-А", мне нужно выполнять соединения с данными из "события-Б" за последние 20 минут). Входное событие-Б: вторичное (своего рода ссылка данные, но из другого концентратора событий Azure)

       Select a.id,b.id,b.action into outputevent from eventA a
left join eventB b on a.id = b.id -- don't know how to consider last 20 minutes event-B data

Необходимо сопоставить / присоединиться к событию-B только в течение последних 20 минут и не знаю, какая оконная функция применима для этого варианта использования (и наблюдалось, что большая часть оконных функций ждет фактического запуска будущего, но мое требование - играть с прошедшим 'event-B', когда я получаю событие-A)

Answer 1

Я отформатировал ваш собственный ответ, чтобы он был более удобочитаемым для других:

      select 
  b.eventenqueuedutctime as btime,
  a.Id,
  a.SysTime,
  a.UTCTime ,
  b.Id as BId,
  b.SysTime as BSysTime 
  into outputStorage -- to blob storage (container) 
from 
  eventA a TIMESTAMP BY eventenqueuedutctime 
left outer join 
  eventB b TIMESTAMP BY eventenqueuedutctime 
on 
  a.id = b.id and 
  datediff(minute,b,a) between 0 and 180 -- join with last 3 hours of eventB data

Вы опубликовали этот ответ в 2020 году. Этот запрос все еще используется сегодня?