class AktivlearnStream::Stream
Public Class Methods
send_raw_data(config,firehose,raw_data)
click to toggle source
# File lib/stream.rb, line 4 def self.send_raw_data(config,firehose,raw_data) begin firehose.put_record({ delivery_stream_name: config["delivery_stream_name"], record: { data: raw_data}}) rescue Exception => e return "Error with the connection. Check the config. Error message === #{e.message}" end end