Searched refs:put_records (Results 1 – 3 of 3) sorted by relevance
66 self.service_connection.put_records(stream_name='stream-name',
83 response = kinesis.put_records([record, record.copy()], 'test')
662 def put_records(self, records, stream_name, b64_encode=True): member in KinesisConnection