Kinesis Client put_record

import boto3
import json
from datetime import datetime
import calendar
import random
import time

my_stream_name = 'python-stream'

kinesis_client = boto3.client('kinesis', region_name='us-east-1')

def put_to_stream(thing_id, property_value, property_timestamp):
    payload = {
                'prop': str(property_value),
                'timestamp': str(property_timestamp),
                'thing_id': thing_id
              }

    print payload

    put_response = kinesis_client.put_record(
                        StreamName=my_stream_name,
                        Data=json.dumps(payload),
                        PartitionKey=thing_id)

while True:
    property_value = random.randint(40, 120)
    property_timestamp = calendar.timegm(datetime.utcnow().timetuple())
    thing_id = 'aa-bb'

    put_to_stream(thing_id, property_value, property_timestamp)

    # wait for 5 second
    time.sleep(5)

Source: arundhaj.com

Similar codes

0 vote235 views1 answer
How to draw a square pygame
Python
0 vote252 views1 answer
Convert method to str python
Python
0 vote254 views2 answers
Return returns string with brackets python
Python
0 vote240 views1 answer
Python look up how many rows in dataframe
Python
1 vote249 views1 answer
Fill na with mode and mean python
Python
2 votes249 views1 answer
Alex john
Python
0 vote255 views1 answer
How to round off values in columns in pandas in excel
Python
0 vote227 views1 answer
Import re #your code goes here number=input() pattern=r"(1|8|9)[0-9]+" match=re.match(pattern,number) of lane(number)==8: if(match): print("value") else: print("invalid") else print("invalid")
Python
1 vote247 views1 answer
How to install panda3d
Python
1 vote233 views2 answers
Winsound python
Python