c7n.sqsexec module

class c7n.sqsexec.MessageIterator(client, queue_url, limit=0, timeout=10)

Bases: object

ack(m)

msg_attributes = ['sequence_id', 'op', 'ser']

next()

class c7n.sqsexec.SQSExecutor(session_factory, map_queue, reduce_queue)

Bases: concurrent.futures._base.Executor

gather()

Fetch results from separate queue

submit(func, *args, **kwargs)

Submit a function for serialized execution on sqs

class c7n.sqsexec.SQSFuture(sequence_id)

Bases: concurrent.futures._base.Future

marker = <object object>

class c7n.sqsexec.SQSWorker(session_factory, map_queue, reduce_queue, limit=0)

Bases: object

process_message(m)

run()

stop()

stopped = False

c7n.sqsexec.named(o)

c7n.sqsexec.resolve(o)