- Start server using
python manage.py runserver
- Open second terminal
python manage.py process_queue --queues search.fifo
curl --location --request POST 'http://127.0.0.1:8000/search/'
--header 'Content-Type: application/json'
--data-raw '{
"words":["sample","12"]
}'
- Edit eb_sqs/aws/sqs_queue_client.py replace
import json
id = json.loads(msg)["id"]
queue.send_message(
MessageBody=msg,
DelaySeconds=delay,
MessageGroupId="sample",1
MessageDeduplicationId=id
)