Acknowledge

from platonic.sqs.queue import SQSReceiver
from platonic.timeout import ConstantTimeout
from datetime import timedelta

incoming_numbers = SQSReceiver[int](
    url='https://sqs.us-west-2.amazonaws.com/123456789012/queue-name',
    # Thus we prevent the receiver from blocking forever if queue is empty
    timeout=ConstantTimeout(period=timedelta(minutes=3)),
)

# If the queue is empty, this call with block until there is a message.
cmd = incoming_numbers.receive()

assert cmd.value == 15
# Do complicated stuff with the value
print(cmd.value * 1234 + 5767)

incoming_numbers.acknowledge(cmd)

class platonic.sqs.queue.SQSReceiver(*args, **kwds)

acknowledge(self, message)

Acknowledge that the given message was successfully processed.

Delete a single message from the queue.

acknowledge_many(self, messages)

Remove multiple correctly processed messages from the queue.