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 all Kinesis Stream
kines ls <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 ls <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 grep -s prod-clickstream -p 123455 -p 8900
> kines grep -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 .
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.3.tar.gz
(14.7 kB
view hashes)
Built Distribution
kines-0.0.3-py3-none-any.whl
(16.2 kB
view hashes)