Skip to content

Instantly share code, notes, and snippets.

Last active June 5, 2018 16:56
What would you like to do?
from json import dumps
from uuid import uuid4
import boto3
from time import time
from os import environ
client = boto3.client('kinesis')
def place_vote(event, context):
Reading vote information from user and publishing it to the kinesis stream
:param event: event object
:param context: event context
:return: response object
data = event['pathParameters']
record_data = {
'time_id': time(),
'vote_id': data['vote_id'],
'token': data['token'],
'vote_choice': data['vote_choice']
result = client.put_record(
response = {
"statusCode": 200,
"body": dumps(result)
return response
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment