Skip to content

Instantly share code, notes, and snippets.

View omrihar's full-sized avatar

Omri Har-Shemesh omrihar

View GitHub Profile
omrihar /
Last active September 20, 2018 14:22
An object that can send events to AWS Kinesis Firehose
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.