Friendly Amazon Kinesis Stream Command Line Interface
Project description
Kines
Friendly Amazon Kinesis Stream Command Line Interface
Install
pip install kines
Setup
aws configure
Features
List all Kinesis Stream
kines ls
> kines ls
Using boto3 version 1.9.230
Found 20 streams.
Status - Stream = Stream with Status. # = OpenShardCount. ๐ฅ = EnhancedConsumerCount. ๐ = RetentionPeriod. ๐ = EncryptionType.
โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฌโโโโฌโโโโโฌโโโโโฌโโโโโโโ
โ Status - Stream โ # โ ๐ฅ โ ๐ โ ๐ โ
โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโผโโโโผโโโโโผโโโโโผโโโโโโโค
โ โน prod-clickstream โ 8 โ 0 โ 24 โ NONE โ
โ โน uat-clickstream โ 1 โ 0 โ 24 โ NONE โ
โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโดโโโโดโโโโโดโโโโโดโโโโโโโ
List Kinesis Stream Shards
kines lss -s <stream-name>
> kines lss -s prod-clickstream
Using boto3 version 1.9.230
โโโโโโโโโโโโโโโโโโโฌโโโโโโโโโโโโโโโโฌโโโโโโโโโโโโโโโโโโโโโโโโฌโโโโโโโโโโโโโโโโโ
โ ShardId โ ParentShardId โ AdjacentParentShardId โ % HashKeyRange โ
โโโโโโโโโโโโโโโโโโโผโโโโโโโโโโโโโโโโผโโโโโโโโโโโโโโโโโโโโโโโโผโโโโโโโโโโโโโโโโโค
โ ๐ 000000000007 โ 000000000003 โ โ 12.5% โ
โ ๐ 000000000008 โ 000000000003 โ โ 12.5% โ
โ ๐ 000000000009 โ 000000000004 โ โ 12.5% โ
โ ๐ 000000000010 โ 000000000004 โ โ 12.5% โ
โ ๐ 000000000011 โ 000000000005 โ โ 12.5% โ
โ ๐ 000000000012 โ 000000000005 โ โ 12.5% โ
โ ๐ 000000000013 โ 000000000006 โ โ 12.5% โ
โ ๐ 000000000014 โ 000000000006 โ โ 12.5% โ
โโโโโโโโโโโโโโโโโโโดโโโโโโโโโโโโโโโโดโโโโโโโโโโโโโโโโโโโโโโโโดโโโโโโโโโโโโโโโโโ
- For detailed output
kines lss -s <stream-name> -d
> kines lss -s prod-clickstream -d
Using boto3 version 1.9.230
โโโโโโโโโโโโโโโโโโโฌโโโโโโโโโโโโโโโโฌโโโโโโโโโโโโโโโโโโโโโโโโฌโโโโโโโโโโโโโโโโโฌโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฌโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ
โ ShardId โ ParentShardId โ AdjacentParentShardId โ % HashKeyRange โ StartingHashKey โ EndingHashKey โ
โโโโโโโโโโโโโโโโโโโผโโโโโโโโโโโโโโโโผโโโโโโโโโโโโโโโโโโโโโโโโผโโโโโโโโโโโโโโโโโผโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโผโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโค
โ ๐ 000000000007 โ 000000000003 โ โ 12.5% โ 0 โ 42535295865117307932921825928971026431 โ
โ ๐ 000000000008 โ 000000000003 โ โ 12.5% โ 42535295865117307932921825928971026432 โ 85070591730234615865843651857942052863 โ
โ ๐ 000000000009 โ 000000000004 โ โ 12.5% โ 85070591730234615865843651857942052864 โ 127605887595351923798765477786913079295 โ
โ ๐ 000000000010 โ 000000000004 โ โ 12.5% โ 127605887595351923798765477786913079296 โ 170141183460469231731687303715884105727 โ
โ ๐ 000000000011 โ 000000000005 โ โ 12.5% โ 170141183460469231731687303715884105728 โ 212676479325586539664609129644855132159 โ
โ ๐ 000000000012 โ 000000000005 โ โ 12.5% โ 212676479325586539664609129644855132160 โ 255211775190703847597530955573826158591 โ
โ ๐ 000000000013 โ 000000000006 โ โ 12.5% โ 255211775190703847597530955573826158592 โ 297747071055821155530452781502797185023 โ
โ ๐ 000000000014 โ 000000000006 โ โ 12.5% โ 297747071055821155530452781502797185024 โ 340282366920938463463374607431768211455 โ
โโโโโโโโโโโโโโโโโโโดโโโโโโโโโโโโโโโโดโโโโโโโโโโโโโโโโโโโโโโโโดโโโโโโโโโโโโโโโโโดโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโดโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ
Find shard for partition key
kines find -s prod-clickstream -p 123455 -p 8900
> kines find -s prod-clickstream -p 123455 -p 8900
Using boto3 version 1.9.230
โโโโโโโโโโโโโโโโฌโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฌโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฌโโโโโโโโโโโโโโโโโโ
โ PartitionKey โ MD5PartitionKey โ HashKey โ ShardId โ
โโโโโโโโโโโโโโโโผโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโผโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโผโโโโโโโโโโโโโโโโโโค
โ 123455 โ 00c66aaf5f2c3f49946f15c1ad2ea0d3 โ 1030238607790890479260410494606811347 โ ๐ 000000000007 โ
โ 8900 โ eedc6ed006e6f49a7010013cc1fd8a3f โ 317500815852337962583846441353507342911 โ ๐ 000000000014 โ
โโโโโโโโโโโโโโโโดโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโดโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโดโโโโโโโโโโโโโโโโโโ
Get report for your Kinesis Stream
kines report -s <stream-name> -h <number-of-hours> -p <metric-period-in-minutes>
kines report -s prod-clickstream -h 3
Using boto3 version 1.9.230
Time = Converted Local Time. IR = IncomingRecords. IS = IncomingSize. IR/Sec = IncomingRecords Per Sec. GR = GetRecords.Records. GR/Sec = GetRecords.Records/Sec. GR/IR = GetRecords/IncomingRecords. WPTE = WriteProvisionedThroughputExceeded. RPTE = ReadProvisionedThroughputExceeded. MAX(IAGM) = MAX(IteratorAgeMilliSeconds).
โโโโโโโโโโโโโโโโโโโโฌโโโโโโโโโโฌโโโโโโโโโโโโฌโโโโโโโโโฌโโโโโโโโโโโฌโโโโโโโโโฌโโโโโโโโฌโโโโโโโฌโโโโโโโโโโฌโโโโโโโโโโโโ
โ Time โ IR โ IS โ IR/Sec โ GR โ GR/Sec โ GR/IR โ WPTE โ RPTE โ MAX(IAGM) โ
โโโโโโโโโโโโโโโโโโโโผโโโโโโโโโโผโโโโโโโโโโโโผโโโโโโโโโผโโโโโโโโโโโผโโโโโโโโโผโโโโโโโโผโโโโโโโผโโโโโโโโโโผโโโโโโโโโโโโค
โ 2019-09-23 13:30 โ 63564.0 โ 192.4 MB โ 70.63 โ 444774.0 โ 494.19 โ 7.00 โ 0.0 โ 6.0 ๐ฅ โ 0.0 โ
โ 2019-09-23 13:45 โ 65641.0 โ 198.67 MB โ 72.93 โ 459252.0 โ 510.28 โ 7.00 โ 0.0 โ 7.0 ๐ฅ โ 0.0 โ
โ 2019-09-23 14:00 โ 65451.0 โ 198.45 MB โ 72.72 โ 458541.0 โ 509.49 โ 7.01 โ 0.0 โ 1.0 ๐ฅ โ 0.0 โ
โ 2019-09-23 14:15 โ 66479.0 โ 202.04 MB โ 73.87 โ 465438.0 โ 517.15 โ 7.00 โ 0.0 โ 5.0 ๐ฅ โ 0.0 โ
โ 2019-09-23 14:30 โ 71354.0 โ 216.3 MB โ 79.28 โ 499529.0 โ 555.03 โ 7.00 โ 0.0 โ 2.0 ๐ฅ โ 0.0 โ
โ 2019-09-23 14:45 โ 71284.0 โ 216.07 MB โ 79.20 โ 498896.0 โ 554.33 โ 7.00 โ 0.0 โ 4.0 ๐ฅ โ 0.0 โ
โ 2019-09-23 15:00 โ 98094.0 โ 293.68 MB โ 108.99 โ 686561.0 โ 762.85 โ 7.00 โ 0.0 โ 8.0 ๐ฅ โ 0.0 โ
โ 2019-09-23 15:15 โ 85521.0 โ 258.77 MB โ 95.02 โ 598670.0 โ 665.19 โ 7.00 โ 0.0 โ 2.0 ๐ฅ โ 0.0 โ
โ 2019-09-23 15:30 โ 78926.0 โ 236.83 MB โ 87.70 โ 552504.0 โ 613.89 โ 7.00 โ 0.0 โ 2.0 ๐ฅ โ 0.0 โ
โ 2019-09-23 15:45 โ 82719.0 โ 251.19 MB โ 91.91 โ 578759.0 โ 643.07 โ 7.00 โ 0.0 โ 14.0 ๐ฅ โ 0.0 โ
โ 2019-09-23 16:00 โ 75329.0 โ 228.95 MB โ 83.70 โ 527481.0 โ 586.09 โ 7.00 โ 0.0 โ 2.0 ๐ฅ โ 0.0 โ
โ 2019-09-23 16:15 โ 73013.0 โ 221.95 MB โ 81.13 โ 511282.0 โ 568.09 โ 7.00 โ 0.0 โ 5.0 ๐ฅ โ 0.0 โ
โ 2019-09-23 16:30 โ 73048.0 โ 222.1 MB โ 81.16 โ 511147.0 โ 567.94 โ 7.00 โ 0.0 โ 2.0 ๐ฅ โ 0.0 โ
โ 2019-09-23 16:45 โ 54229.0 โ 165.09 MB โ 60.25 โ 379756.0 โ 421.95 โ 7.00 โ 0.0 โ 2.0 ๐ฅ โ 0.0 โ
โโโโโโโโโโโโโโโโโโโโดโโโโโโโโโโดโโโโโโโโโโโโดโโโโโโโโโดโโโโโโโโโโโดโโโโโโโโโดโโโโโโโโดโโโโโโโดโโโโโโโโโโดโโโโโโโโโโโโ
How to build in Dev?
venv/bin/kines_cli
. venv/bin/activate
pip install --editable .
How to publish to pypi?
python3 setup.py sdist bdist_wheel
twine upload --skip-existing dist/*
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
kines-0.0.4.tar.gz
(9.9 kB
view hashes)
Built Distribution
kines-0.0.4-py3-none-any.whl
(16.3 kB
view hashes)