Можете ли вы слушать сервис Azure с помощью AWS Lambda?

Question

За ссылка ! здесь триггер служебной шины функций Azure позволяет прослушивать служебную шину Azure. В настоящее время мы используем в основном облачные сервисы AWS. И мы работаем с поставщиком, который получает уведомления в режиме реального времени с помощью служебной шины Azure. Я хотел бы знать, есть ли в любом случае для подключения к служебной шине с помощью лямбды. Каждый раз, когда в шине появляется новое сообщение, мы бы хотели, чтобы наша AWS лямбда вызывала и принимала его оттуда.

Answer 1

Это невозможно.Однако вы можете использовать функции Azure (предложение Azure без сервера), запускаемые шиной службы Azure, для приема сообщений.

Если вы действительно хотите использовать триггерный поставщик, вам нужно использовать сообщение Azure Service Bus, преобразовать это сообщение в полезную нагрузку http и запустить лямбда AWS с полезной нагрузкой Http, в которой есть содержимое сообщения.

Answer 2

Правило события Cloudwatch: https://docs.aws.amazon.com/AmazonCloudWatch/latest/events/Create-CloudWatch-Events-Rule.html

Вы указываете источник своего события - поддерживаемую Службу и вызов действия / API, а также цели и устанавливаете необходимые настройки IAM (разрешение Lambda и т. Д., Если вы создаете из таких инструментов IaC, как terraform ...). идти!

Тогда, пока действует правило событий Cloudwatch, все события, попадающие в указанное вами правило, будут запускать вашу лямбду.

Правило событий также может быть использовано «cron schedule» для лямбды, который я использовал. Я очень редко встречался с задержкой, хотя ...

Обновление: чтобы сделать его как можно более реальным, вам нужно будет внести изменения в учетную запись Azure вашего поставщика, чтобы разрешить передачу некоторых сообщений в конечную точку AWS (шлюз API), что, как я полагаю, НЕТ. Кроме этого, автономное решение AWS заключается в настройке правила события cloudwatch, которое будет отправлять конечную точку Azure HTTP вашего поставщика каждые 1 минуту и ​​сохранять содержимое в собственных очередях SQS.