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