Я использую IoT Core для получения петиций MQTT и HTTP
Теперь я хочу использовать что-то похожее на облачные сервисы Azure для постоянного прослушивания с устройств, которые отправляют мне данные через UDP / TCP.
Можно ли было бы использовать лямбда-функцию? Может быть, это будет слишком дорого, потому что его можно будет вызывать тысячи раз в день.
Если я использую EC2, как я могу получить, а затем отправить эти данные, например, в S3 / DynamoDB?





Лямбда-функции не могут прослушивать UDP или случайные TCP-порты. Вы сможете использовать Lambda (в сочетании со шлюзом API) только для обработки сообщений HTTPS.
Вам нужно будет использовать EC2 или, возможно, одну из контейнерных служб, чем запускать на EC2, например ECS или EKS.
Вам нужно будет написать программу, которая прослушивает правильные порты TCP / UDP, используя любой язык программирования и библиотеки, которые вам нравятся. Как только эта программа получит сообщение, она будет использовать AWS SDK для языка программирования, который вы используете, чтобы отправить это сообщение в сервис AWS, такой как SQS / SNS / IoT и т. д.
Для тех, кто видит это после июля 2019 года, Amazon выпустила поддержку UDP для своих «балансировщиков сетевой нагрузки».
https://aws.amazon.com/blogs/aws/new-udp-load-balancing-for-network-load-balancer/
Используя это решение, вы сможете заставить балансировщик сетевой нагрузки получать UDP-пакеты от ваших полевых устройств, а затем пересылать их одной или нескольким «целевым группам» (в данном случае, скорее всего, экземплярам EC2 или группам автомасштабирования).
Вам все равно нужно будет написать собственный сервис, который понимает формат сообщений UDP с ваших устройств и преобразует его в формат сообщения, понятный ядру AWS IoT. Эта настраиваемая служба будет работать на любых экземплярах в целевой группе, которая получает трафик от вашего балансировщика сетевой нагрузки.
Основное преимущество здесь перед открытием одного экземпляра EC2 заключается в том, что вы можете вносить изменения в свой код синтаксического анализа / получения UDP, загружать новый ящик с этими изменениями и переносить трафик на новый экземпляр без прерывания обслуживания. Вы также получаете некоторую избыточность (возможно, чтобы балансировщик сетевой нагрузки был разделен на несколько зон доступности, а также несколько целевых групп прослушивали входящие сообщения UDP).
Итак, в этом случае, если мне придется использовать EC2 (или, возможно, локальный компьютер), мне придется разработать программу с AWS SDK для получения данных UDP и передачи их в другой сервис AWS?