class FirehoseIntegration::KinesisJob

Public Instance Methods

perform(stream, data) click to toggle source
# File lib/firehose_integration/jobs/kinesis_job.rb, line 4
def perform(stream, data)
  client = Aws::Firehose::Client.new(region:'us-east-1')

  params = {
    delivery_stream_name: stream,
    record: {
      data: "#{data}\n"
    }
  }
  client.put_record params
end