Create a virtual environment and install the dependencies:
$ python3 -m venv venv
$ source env/bin/activate
$ pip install -r requirements.txtOn settings there's a variable REDIS_URL in the format of os.getenv("REDIS_URL"). This variable is used to connect to Redis. You can either set it as an environment variable or just replace it with your Redis URL.
If you want to use Upstash Redis, you can create a free account and get the Redis URL from there.
$ export REDIS_URL=<YOUR_REDIS_URL>
# or use any other way to set the environment variableSpin up a new terminal and start the celery worker:
$ celery -A celery_redis worker --loglevel=infoNow start also a Django server:
$ python manage.py runserverSend a task to celery worker by calling the endpoint /trigger-task/ with a GET request from browser or with curl:
$ curl http://localhost:8000/trigger-task/This will trigger a new task which will be stored in Upstash Redis. After that Celery will receive the task from Redis queue and it will execute it.
Verify by looking the looks on the terminal where you started the celery worker:
[2023-10-12 20:04:30,499: INFO/MainProcess] mingle: searching for neighbors
[2023-10-12 20:04:31,970: INFO/MainProcess] mingle: all alone
[2023-10-12 20:04:32,677: INFO/MainProcess] celery@my-pc ready.
[2023-10-12 20:04:39,088: INFO/MainProcess] Task celery_redis.celery.reverse_and_sleep[7ec800a8-476b-4357-afbe-7d08824f63fc] received
[2023-10-12 20:04:49,324: INFO/ForkPoolWorker-16] Task celery_redis.celery.reverse_and_sleep[7ec800a8-476b-4357-afbe-7d08824f63fc] succeeded in 10.2348608289999s: '!yreleC ,olleH'Just expand the usage of the celery, define your tasks and keep doing amazing stuff :)
If you have any questions regarding the topic or anything else, feel free to reach to me on:
This project is licensed under the terms of the MIT license.