Dockerized celery project with SQS broker and Redis for results backend

Start

$ docker-compose up

$ docker-compose ps

API endpoints (exposed to host)

Add job to SQS queue

$ curl http://localhost:5000/task?time=30&block=true

time - how much time will the task run

block - should API endpoint wait for task result to be returned

Add job that will end up in dead letter Q

$ curl http://localhost:5000/dlq_task

Add job that return the same message to the Q

$ curl http://localhost:5000/retry

Visibility Timeout

The default Q is configured with 10 seconds
Please note that if you pass time>10 duplications will occur

Dead letter queue

As for now, the implementation of roribio16/alpine-sqs will not support queueing to a dead letter. This is currently working out of the box with real SQS running

if you like to work with DQL, please see my fork for its repo, where I configure DLQ in elasticmq.conf file

https://github.com/galCohen88/alpine-sqs

and build the image $ docker-compose -f docker-compose.build build

SQS control panel

to see SQS queues using web browser go to

http://localhost:9325