Можно ли добавить многоканальные входы в конвейер в AWS IoT Analytics?
У меня есть несколько устройств IoT, которые отправляют данные одного типа в свои тени. Я хотел бы проанализировать эти данные с помощью IoT Analytics. Я создал канал для каждого из этих устройств и хотел бы обрабатывать данные со всех них, используя действия. Пользовательский интерфейс предполагает, что к конвейеру может быть подключено несколько каналов, но я не могу понять, как это сделать. Я также не нашел никакой информации об этом в документации API.
Возможно ли это, или мне нужно добавить новый конвейер для каждого из этих каналов? Разве нет более простого способа организовать эти вещи, чтобы все они отправляли данные в один канал (поскольку в любом случае это один и тот же тип данных)?
1 ответ
Пользовательский интерфейс предполагает, что к конвейеру может быть подключено несколько каналов, но я не могу понять, как это сделать. Я также не нашел никакой информации об этом в документации API.
Каждому конвейеру требуется ровно 1 связанный канал. На уровне API это задокументировано в форме требования к pipeline activities свойство самого трубопровода, например:
Список может состоять из 2-25 объектов PipelineActivity и должен содержать как канал, так и действие хранилища данных.
от: IoT-Analytics CreatePipeline API
Возможно ли это, или мне нужно добавить новый конвейер для каждого из этих каналов?
Если у вас есть несколько каналов (по одному на устройство), и вы хотите обрабатывать данные с каждого из них, вам необходимо определить отдельный конвейер для каждого.
Разве нет более простого способа организовать эти вещи, чтобы все они отправляли данные в один канал (поскольку в любом случае это один и тот же тип данных)?
Если вы пытаетесь объединить данные с нескольких устройств в какой-то момент обработки, вы можете:
а) несколько устройств отправляют данные на один и тот же канал, а затем имеют один конвейер для обработки данных с этого канала по мере необходимости
b) чтобы устройства отправляли данные на отдельные каналы, затем настраивали отдельные конвейеры (по одному на канал) для обработки данных по мере необходимости и отправки обработанных данных в одно хранилище данных
Последний вариант имеет больше ресурсов для определения и обслуживания, но позволяет хранить данные от каждого устройства отдельно, если вам необходимо по какой-либо причине.
Надеюсь, это поможет, но дайте мне знать, если я неправильно понял ваш сценарий или вопрос.