#NEWLINE# def put_records( self , records ) : #NEWLINE# #INDENT# 'Put the given records in the Kinesis stream.' #NEWLINE# for record in records : #NEWLINE# #INDENT# response = kinesis . put_record ( stream_name = self . stream_name , data = record , partition_key = self . partition_key ) #NEWLINE# if ( self . quiet is False ) : #NEWLINE# #INDENT# print ( '-= put seqNum:' , record [ 'SequenceNumber' ] )