geowatchutil.channel.geowatch_channel_kinesis module¶

class geowatchutil.channel.geowatch_channel_kinesis.GeoWatchChannelKinesis(client, topic, mode, num_procs=1, shard_id=u'shardId-000000000000', shard_it_type='LATEST')[source]¶

Bases: geowatchutil.channel.base.GeoWatchChannelTopic

classmethod decode(message)[source]¶

classmethod encode(message)[source]¶

get_messages_raw(count, block=True, timeout=5)[source]¶: get_messages_raw will return raw Kinesis objects

send_message(message)[source]¶

send_messages(messages)[source]¶

shard_id = None¶

shard_it_type = 'LATEST'¶