Лямбда-функция Python |Сообщения AWS MQ для передачи между различными учетными записями AWS через Kinesis - PullRequest
0 голосов
/ 23 ноября 2018

У меня есть функция Python Lambda, которая отправляет сообщения из AWS MQ в AWS Kinesis того же аккаунта AWS.Как я могу добиться того же, если у меня есть кинезис в другой учетной записи AWS?

import time
import boto3
import stomp
import json
kinesis_client = boto3.client('kinesis')

class Listener(stomp.ConnectionListener):
    def on_error(self, headers, message):
        print('received an error "%s"' % message)
        kinesis_client.put_record(
            StreamName='',
            Data=u'{}\r\n'.format(message).encode('utf-8'),
            PartitionKey='0'
        )
    def on_message(self, headers, message):
        print('received a message "%s"' % message)
def lambda_handler(event, context):
    conn = stomp.Connection(host_and_ports=[('', 61614)])
    lst = Listener()
    conn.set_listener('Listener', lst)
    conn.set_ssl(for_hosts=[('', 61614)])
    conn.start()
    print('CONNECTION Started')
    conn.connect(login='', passcode='',wait=True)
    print('CONNECTION established')
    conn.subscribe(destination='/queue/', id=1, ack='auto')
    print('CONNECTION Subscribed')
    time.sleep(10)
    conn.disconnect()
    return

Спасибо

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...