Блог

У меня есть устройства интернета вещей mutliple, которые отправляют последовательные обновления каждого значения, а не полное обновление всех значений в одном и том же json. Я получаю

 {
        "4099": 0,
        "device": "Unit1",
        "TS": 1633539386
      }
 

затем новая полезная нагрузка с:

 {
        "4097": 232000,
        "device": "Unit1",
        "TS": 1633539386
      }
 

еще один, как

 {
        "146": 9.249749,
        "device": "Unit1",
        "TS": 1633539382
      }
 

Атрибуты устройство и TS всегда доступны, но атрибуты являются динамическими 4099 со значением 0, 4097 со значением 232000 и 146 со значением 9249749

Я изучал архитектуру 2-го типа с https://aws.amazon.com/blogs/iot/designing-dataflows-for-multi-schema-messages-in-aws-iot-analytics/ и это абсолютно логично. Однако неясно, как написать правило ВЫБОРА, которое выдает мне только сообщения, в которых отображается атрибут, чтобы я мог перенаправить его в правильный конвейер.

Или это означает, что выполните a SELECT * FROM topic в одном конвейере, а затем каким-то образом добавьте атрибуты. Похоже, это очень простая проблема, с которой, я уверен, сталкивались другие, но не на 100% ясно, на каком этапе переключение между атрибутами осуществляется в общее хранилище данных.