Amazon SQS¶
-
class
motorway.contrib.amazon_sqs.ramps.
SQSRamp
(*args, **kwargs)[source]¶ -
next
()[source]¶ This function is called continuously by the ramp.
Warning
Do not block this for a long time or make a while True loop inside it. Betwen every
motorway.ramp.Ramp.next()
run, some essential operations are run, including receiving acks from themotorway.controller.Controller
Yield: motorway.messages.Message
instance
-
-
class
motorway.contrib.amazon_sqs.intersections.
SQSInsertIntersection
(**kwargs)[source]¶ -
process
(message)[source]¶ This function is called continuously by the intersection.
Yield: motorway.messages.Message
instanceParameters: message – motorway.messages.Message
instance orlist()
if usingmotorway.decorators.batch_process()
-