def process_or_store()

in python-app/comment-stream.py [0:0]

• 11 lines of code
• 2 McCabe index (conditional complexity)

def process_or_store(comment):
    try:
        response = firehose_client.put_record(
            DeliveryStreamName='<insert-delivery-stream-name>',
            Record={
                'Data': (json.dumps(comment, ensure_ascii=False) + '\n').encode('utf8')
                    }
            )
        logging.info(response)
    except Exception:
        logging.exception("Problem pushing to firehose")