celery_redis_async_task_queue_quickstart.py

1from celery import Celery
2
3# Initialize Celery app
4# 'tasks' is the name of the current module.
5# broker: The URL where the Redis message broker is running.
6# backend: The URL where task results will be stored.
7app = Celery('tasks', 
8             broker='redis://localhost:6379/0', 
9             backend='redis://localhost:6379/0')
10
11@app.task
12def add(x, y):
13    return x + y
14
15if __name__ == '__main__':
16    # To run this, start the worker in your terminal:
17    # celery -A tasks worker --loglevel=info
18    
19    # Example of calling the task asynchronously:
20    result = add.delay(4, 4)
21    print(f"Task ID: {result.id}")
22    print(f"Task Result: {result.get(timeout=10)}")