"""Lambda function for submitting the events to Kinesis stream."""

import json
import logging

import boto3

import config

logger = logging.getLogger()
logger.setLevel(logging.INFO)
logger.addHandler(logging.StreamHandler())

client = boto3.client('kinesis')


def handler(event, context):
    """Lambda entry point."""
    response = client.put_record(
        StreamName=config.KINESIS_STREAM_NAME,
        Data=json.dumps(event),
        PartitionKey=str(event['data']['id'])
    )
    status = response['ResponseMetadata']['HTTPStatusCode']
    logger.info('Message sent to stream, status: %s', status)
    return status