Можно ли добавить многоканальные входы в конвейер в AWS IoT Analytics? - PullRequest
0 голосов
/ 12 апреля 2019

У меня есть несколько устройств IoT, которые отправляют данные одного типа в свои тени. Я хотел бы проанализировать эти данные с помощью IoT Analytics. Я создал канал для каждого из этих устройств и хотел бы обрабатывать данные со всех них, используя действия. Пользовательский интерфейс предполагает, что к конвейеру может быть подключено несколько каналов, но я не могу понять, как это сделать. Я также не нашел никакой информации об этом в документации API.

Возможно или мне нужно добавить новый конвейер для каждого из этих каналов? Разве нет более простого способа организовать эти вещи, чтобы все они отправляли данные на один канал (поскольку в любом случае это один и тот же тип данных)?

1 Ответ

1 голос
/ 15 апреля 2019

Пользовательский интерфейс предполагает, что к конвейеру может быть подключено несколько каналов, но я не могу понять, как.Я также не нашел никакой информации об этом в документации API.

Для каждого конвейера требуется ровно 1 связанный канал.На уровне API это задокументировано в форме требования к свойству pipeline activities самого конвейера, например:

Список может содержать 2-25 объектов PipelineActivity и должен содержать какактивность канала и хранилища данных

из: IoT-Analytics CreatePipeline API

Возможно ли добавить новый конвейер для каждогоиз этих каналов?

Если у вас есть несколько каналов (по одному на устройство), и вы хотите обрабатывать данные с каждого из них, вам необходимо определить отдельный конвейер для каждого.

Нет ли более простого способа организовать эти вещи, чтобы все они отправляли данные в один канал (поскольку в любом случае это один и тот же тип данных)?

Если вы пытаетесь объединить данныес нескольких устройств в определенный момент обработки вы можете:

a) иметь несколько устройств, отправляющих данные на один и тот же канал, а затем иметь один конвейер для обработки данных с этого канала по мере необходимости

b) устройства отправляют данные на отдельные каналы, затем имеют отдельные конвейеры (по одному на канал), настроенные на обработку данных по мере необходимости, и отправляют обработанные данные в одно хранилище данных

Последний вариантимеет больше ресурсов для определения и обслуживания, но позволяет хранить данные от каждого устройства отдельно, если вам необходимо по какой-либо причине.

Надеюсь, это поможет, но дайте мне знать, если я неправильно понял ваш сценарий или вопрос.

...