Qfyilyi

I have python lambda function, which will get messages from AWS MQ and with those messages I need to put them into Kinesis.
I followed this link but that did not help much. So Rob helped me to get through this.

My Final achievement is - I have my Kinesis in Different AWS account with Role name, ARN, StreamARN,Stream Name and Endpoint as well as the Partition Key. What changes do I need to do to my below code?

Code:

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)



    def on_message(self, headers, message):

        print('received a message %s (%s)'%(message, headers))

        kinesis_client.put_record(

            StreamName='',

            Data=b'bytes',

            PartitionKey='1'

        )

def lambda_handler(event, context):

    conn = stomp.Connection(host_and_ports=[('b-4714-4441-8166-47aae158281a-1.mq.eu-central-1.amazonaws.com', 61614)])

    lst = Listener()

    conn.set_listener('Listener', lst)

    conn.set_ssl(for_hosts=[('b-4714-4441-8166-47aae158281a-1.mq.eu-central-1.amazonaws.com', 61614)])

    conn.start()

    print('CONNECTION Started')

    conn.connect(login='test_mq', passcode='',wait=True)

    print('CONNECTION established')

    conn.subscribe(destination='/queue/', id=1, ack='auto', headers={'transformation' : 'jms-map-json'})

    print('CONNECTION Subscribed')

    time.sleep(10)

    conn.disconnect()

    return