Опубликовать сообщение из SNS в Kinesis - PullRequest
Новая
       44

Опубликовать сообщение из SNS в Kinesis

0 голосов
/ 21 мая 2018

У меня есть требование публиковать сообщения из SNS в kinesis.Я обнаружил, что напрямую подписаться на SNS / SQS невозможно.Мне нужно будет написать лямбду, чтобы извлечь из SNS и опубликовать его в kinesis.Есть ли другой способ публиковать записи из SNS в kinesis напрямую?Спасибо

1 Ответ

0 голосов
/ 22 мая 2018

Amazon SNS - это модель публикации / подписки.

На сообщения, отправленные на SNS, можно подписаться с помощью:

  • http/s: доставка JSON-кодированного сообщения через HTTP POST
  • email: доставка сообщения по SMTP
  • email-json: доставка JSON-закодированного сообщения по SMTP
  • sms: доставка сообщения по SMS
  • sqs: доставка сообщения в кодировке JSON в очередь Amazon SQS
  • application: доставка сообщения в кодировке JSON в EndpointArn для мобильного приложения и устройства.
  • lambda: доставка JSON-кодированного сообщения в функцию AWS Lambda.

См .: Подписка - Amazon Simple Notification Service

Из них толькоте, которые можно использовать для отправки в Amazon Kinesis, будут использовать AWS Lambda .Вам нужно написать лямбда-функцию, которая будет отправлять сообщение в поток Kinesis.

Чтобы уточнить: ваша лямбда-функция не будет «извлекать данные из SNS».Скорее, лямбда-функция будет запускаться SNS, а сообщение передается в качестве ввода.Тогда вашей лямбда-функции потребуется отправить сообщение в Kinesis.

Единственной альтернативой для вас является изменение системы, которая в данный момент отправляет сообщение в SNS, и вместо этого отправка сообщения в Kinesis.

...