Example usage
python
@mock_kinesis def test_kinesis_behaviour: boto3.client("kinesis") ...
Implemented features for this service
- [X] add_tags_to_stream
- [X] create_stream
- [X] decrease_stream_retention_period
- [X] delete_stream
- [X] deregister_stream_consumer
- [ ] describe_limits
- [X] describe_stream
- [X] describe_stream_consumer
- [X] describe_stream_summary
- [X] disable_enhanced_monitoring
- [X] enable_enhanced_monitoring
- [X] get_records
- [X] get_shard_iterator
- [X] increase_stream_retention_period
- [X] list_shards
[X] list_stream_consumers
Pagination is not yet implemented
- [X] list_streams
- [X] list_tags_for_stream
- [X] merge_shards
- [X] put_record
- [X] put_records
- [X] register_stream_consumer
- [X] remove_tags_from_stream
- [X] split_shard
- [X] start_stream_encryption
- [X] stop_stream_encryption
- [ ] subscribe_to_shard
- [X] update_shard_count
- [ ] update_stream_mode