omrihar

import os
import logging
import boto3

class FirehoseStream(object):
    """Allows sending of events to Kinesis Firehose"""

    def __init__(self, stream=None, region=None,
                 project=None, logger=None):
        """Create the stream client and wait for events.