class Monsoon::Streams::Kinesis
Public Class Methods
new()
click to toggle source
# File lib/monsoon/streams/kinesis.rb, line 6 def initialize @client = Aws::Kinesis::Client.new end
Public Instance Methods
put_records(stream, records, options = {})
click to toggle source
# File lib/monsoon/streams/kinesis.rb, line 10 def put_records(stream, records, options = {}) data = records.map do |r| { data: JSON.generate(r), partition_key: options[:partition_key] || r['event'] || r[:event] || r['droplet_version'] || 'monsoon' } end @client.put_records(records: data, stream_name: stream) end