c7n.sqsexec module¶
-
class
c7n.sqsexec.
MessageIterator
(client, queue_url, limit=0, timeout=10)[source]¶ Bases:
object
-
msg_attributes
= ['sequence_id', 'op', 'ser']¶
-
next
()¶
-
-
class
c7n.sqsexec.
SQSExecutor
(session_factory, map_queue, reduce_queue)[source]¶ Bases:
concurrent.futures._base.Executor
-
class
c7n.sqsexec.
SQSFuture
(sequence_id)[source]¶ Bases:
concurrent.futures._base.Future
-
marker
= <object object>¶
-