/Python/Kinesis Client get_records example

Kinesis Client get_records example

import boto3
import json
from datetime import datetime
import time

my_stream_name = 'python-stream'

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

response = kinesis_client.describe_stream(StreamName=my_stream_name)

my_shard_id = response['StreamDescription']['Shards'][0]['ShardId']

shard_iterator = kinesis_client.get_shard_iterator(StreamName=my_stream_name,
                                                      ShardId=my_shard_id,
                                                      ShardIteratorType='LATEST')

my_shard_iterator = shard_iterator['ShardIterator']

record_response = kinesis_client.get_records(ShardIterator=my_shard_iterator,
                                              Limit=2)

while 'NextShardIterator' in record_response:
    record_response = kinesis_client.get_records(ShardIterator=record_response['NextShardIterator'],
                                                  Limit=2)

    print record_response

    # wait for 5 seconds
    time.sleep(5)

Source: arundhaj.com

Similar codes

0 vote125 views1 answer
Draw pixel by pixel python
Python
18 votes137 views5 answers
Get list with random numbers python
Python
2 votes133 views4 answers
Decision tree classifier sklearn
Python
22 votes127 views5 answers
Define a string in python
Python
1 vote132 views1 answer
Knowing the sum null values in a specific row in pandas dataframe
Python
0 vote124 views1 answer
Cos2x
Python
56 votes128 views5 answers
Check python version ubuntu
Python
0 vote128 views1 answer
Python package structure
Python
4 votes160 views2 answers
Urllib.error.URLError: <urlopen error [SSL: CERTIFICATE_VERIFY_FAILED] certificate verify failed: unable to get local issuer certificate (_ssl.c:1123)>
Python
108 votes136 views6 answers
While loop py
Python