Мои входные данные - это BLOB-объект и концентратор событий, а выход - это таблица хранилища Azure.
EventHub:
{"Time":"2017-05-14T06:41:26.2630811","PowerDC":5642.45849609375,"AccelX":0.011730000376701355,"AccelY":0.0048699378967285156,"Pressure":9.0,"PartitionKey":"718a6ebf-aea0-4b4b-bb68-9ad5e9697164"}
Blob:
{"PartitionKey":"1","RowKey":"1","Timestamp":"2017-02-16 19:27:42.7994902 +00:00","InstallTime":"2017-02-16 19:27:42.5010225 +00:00","Location":"Test","Site":"Test","UUID":"718a6ebf-aea0-4b4b-bb68-9ad5e9697164","UninstallTime":null}
У меня есть этот запрос, когда я просматриваю образец и тестирую, он дает мне выходные данные, но не отправляет никаких выходных данных в таблицу хранилища Azure.
Запрос:
SELECT UR.PartitionKey as PartitionKey,
maxpressure=50,
max(EH.AccelX) as MaxAccelX ,
max(EH.AccelY) as MaxAccelY,
Avg(EH.Pressure) as AvgPressure,
DateAdd(hour,-8,max(EH.Time)) as maxtime
INTO OutputToTable
FROM FromEventHub EH TimeStamp by Time
join UnitRecordBlob UR on EH.PartitionKey = UR.UUID
Group by TUMBLINGWINDOW(mi,1), UR.PartitionKey