/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

1 vote286 views1 answer
How to run commands in repl.ot
Python
21 votes230 views1 answer
Raise en python
Python
8 votes277 views5 answers
Python string lowercase
Python
20 votes266 views5 answers
Plotting confusion matrix
Python
0 vote356 views1 answer
How to calculate log 10 in python
Python
1 vote294 views1 answer
Check odd numbers numpy
Python
0 vote276 views2 answers
Python program to read a random line from a file
Python
0 vote229 views1 answer
Returns all the records as a list of Row
Python
0 vote281 views1 answer
Re_path(r'^logout/$',views.logout, {"next_page":'/'},name="logout"), AttributeError: module 'django.contrib.auth.views' has no attribute 'logout'
Python
2 votes370 views2 answers
Django template array index
Python Django