Я получил скрипт Python от put_records () принимает только ключевые аргументы в Python API Kinesis boto3 , которые будут загружать файлы json в поток kinesis.
Моя архитектура примерно такая
В консоли AWS я создал лямбда-функцию с добавленным выше кодом. Лямбда-функция
Как я буду интегрировать или сообщать своей лямбда-функции, что она просыпается каждую минуту? Нужно ли мне добавлять сообщения захвата с помощью событий Cloud-watch. Если так, как ..?
Я получил эту форму решения по ссылке ниже.
Python Script: -
import time
import boto3
import stomp
kinesis_client = boto3.client('kinesis')
class Listener(stomp.ConnectionListener):
def on_error(self, headers, message):
print('received an error "%s"' % message)
def on_message(self, headers, message):
print('received a message "%s"' % message)
kinesis_client.put_record(
StreamName='inter-lambda',
Data=u'{}\r\n'.format(message).encode('utf-8'),
PartitionKey='0'
)
def handler(event, context):
conn = stomp.Connection(host_and_ports=[('localhost', 61616)])
conn.set_listener('', Listener(conn))
conn.start()
conn.connect(login='user', passcode='pass')
conn.subscribe(destination='A.B.C.D', ack='auto')
print('Waiting for messages...')
time.sleep(10)
conn.close()
return ''
https://github.com/aws-samples/amazonmq-invoke-aws-lambda