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