В концентраторе событий при получении более 1 обработанного сообщения сообщение не приходит как отдельные события. Сообщение содержит более 1 элемента.
если вы видите сообщение, в котором содержится более одного элемента информации об устройстве, я должен получать один элемент для каждого события.
//Processing the message
With ProcessedPayload As
(SELECT
udf.Device(
Event.meta.DeviceId,
Event.meta,
Event.Data_in,
Event.channels,
pcmsqlazure.ConfigIOPayload) As device
FROM
localINputsignal As Event
join
pcmsqlazure
ON
Event.meta.DeviceId=pcmsqlazure.SerialNumber)
//output data to event bus
select device.deviceId,device.productFilter,device.data into Custom from ProcessedPayload
Редактировать:
Данные поступают, как показано ниже, в виде одной строки
{"Ts":"2019-08-28T04:08:23.3884855Z","DeviceId":"DJT3COE4","count":1}
{"Ts":"2019-08-28T04:08:23.0584507Z","DeviceId":"DJT3COE4","count":1}
{"Ts":"2019-08-28T04:08:21.8236859Z","DeviceId":"DJT3COE4","count":1}
{"Ts":"2019-08-28T04:08:21.8236859Z","DeviceId":"DJT3COE4","count":1}
но для меня результат должен быть как одно событие, как показано ниже
{"Ts":"2019-08-28T04:08:21.8236859Z","DeviceId":"DJT3COE4","count":1}
В: обработанное нисходящее сообщение, которое публикуется в Eventhub, и это сообщение должно быть получено одно за другим, нужно ли мне что-то делать в запросе?