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:	message – `motorway.messages.Message` instance or `list()` if using `motorway.decorators.batch_process()`