Add files via upload

Author: ssnskar

integration-kinesis-to-lambda/example.rb

@@ -0,0 +1,23 @@
+require 'aws-sdk'
+
+def lambda_handler(event:, context:)
+  event['Records'].each do |record|
+    begin
+      puts "Processed Kinesis Event - EventID: #{record['eventID']}"
+      record_data = get_record_data_async(record['kinesis'])
+      puts "Record Data: #{record_data}"
+      # TODO: Do interesting work based on the new data
+    rescue => err
+      $stderr.puts "An error occurred #{err}"
+      raise err
+    end
+  end
+  puts "Successfully processed #{event['Records'].length} records."
+end
+
+def get_record_data_async(payload)
+  data = Base64.decode64(payload['data']).force_encoding('UTF-8')
+  # Placeholder for actual async work
+  # You can use Ruby's asynchronous programming tools like async/await or fibers here.
+  return data
+end