celery_redis_broker_quickstart_with_async_add_task.py

1from celery import Celery
2
3# Initialize Celery app with Redis as the broker and backend
4# Format: redis://:password@hostname:port/db_number
5app = Celery('tasks', 
6             broker='redis://localhost:6379/0',
7             backend='redis://localhost:6379/0')
8
9@app.task
10def add(x, y):
11    return x + y
12
13if __name__ == '__main__':
14    # Example of how to call the task asynchronously
15    result = add.delay(4, 4)
16    print(f'Task ID: {result.id}')