python celery

from celery import Celery

# 创建 Celery 实例，传递 broker URL 和 backend URL
app = Celery('my_app', broker='redis://localhost:6379/0', backend='redis://localhost:6379/0')

# 定义一个简单的任务
@app.task
def add(x, y):
    return x + y

# 启动 Celery worker
# 在终端中运行：celery -A my_app worker --loglevel=info

# 调用任务
result = add.delay(4, 5)
print(result.get())  # 输出 9

解释说明：

1. 创建 Celery 实例：通过 Celery 类创建一个 Celery 实例，并指定消息队列（broker）和结果存储（backend）。这里使用 Redis 作为 broker 和 backend。
2. 定义任务：使用 @app.task 装饰器定义一个名为 add 的任务，该任务接收两个参数并返回它们的和。
3. 启动 Celery worker：在终端中运行命令 celery -A my_app worker --loglevel=info 来启动 Celery worker。这会监听任务并执行它们。
4. 调用任务：使用 add.delay(4, 5) 异步调用任务，并通过 result.get() 获取任务的结果。

如果你需要更多关于 Celery 的配置或高级用法，请参考官方文档。