FilesExpand file tree

 main

/

lambda_function.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

19 lines (16 loc) · 787 Bytes

 main

/

lambda_function.py

Copy path

Top

File metadata and controls

• Code
• Blame

19 lines (16 loc) · 787 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

import json

import pulsar

import os

print('Pulsar Producer Started')

def lambda_handler(event, context):

_pulsar_cluster = os.environ['CLUSTER_IP_PORT'] ## lambda environment variable sample format : pulsar://172.31.76.93:6650

client = pulsar.Client(_pulsar_cluster)

_pulsar_topic = os.environ['PULSAR_TOPIC'] ## lambda environment variable for pulsar topic

producer = client.create_producer(_pulsar_topic)

for record in event['Records']:

print(record['eventID'])

print(record['eventName'])

print("DynamoDB Record: " + json.dumps(record['dynamodb'], indent=2))

producer.send((json.dumps(record['dynamodb'], indent=2)).encode('utf-8'))

client.close()

return 'Successfully processed {} records.'.format(len(event['Records']))