Rexw099

When the script runs the following function I get the following error. def find_missing_data(zipped_data): missing_count = 0 for question, answer in zipped_data: if not answer: missing_count += 1 return missing_count...

Stream Name, Shard ID, and Application Name

1

Is there a way you can get the Stream Name, Shad ID and Application Name as a variable in the code?

What is the best way to stop the KCLPY consumer from processing and exit gracefully? I need to stop all shards from processing for about 90 to 120 minutes a...

Is there a way to change kclpy to use gzip instead of code64 from the kinesis stream?