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 the motorway.controller.Controller

Yield:motorway.messages.Message instance
success(_id)[source]

Called when a message was successfully ack’ed through the entire pipeline.

Parameters:_id – The id of the message that was successful
class motorway.contrib.amazon_sqs.intersections.SQSInsertIntersection(**kwargs)[source]
process(message)[source]

This function is called continuously by the intersection.

Yield:motorway.messages.Message instance
Parameters:messagemotorway.messages.Message instance or list() if using motorway.decorators.batch_process()