|
|
@@ -1,3 +1,31 @@
|
|
|
# celery
|
|
|
|
|
|
-异步任务的调度和处理，耗时的任务异步执行，与 RabbitMQ、Redis、Amazon SQS 中间件集成
|
|
|
+异步任务的调度和处理，耗时的任务异步执行，与 RabbitMQ、Redis、Amazon SQS 中间件集成
|
|
|
+
|
|
|
+## Usage
|
|
|
+
|
|
|
+```
|
|
|
+pip install celery
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+from celery import Celery
|
|
|
+
|
|
|
+# 创建 Celery 应用
|
|
|
+app = Celery('tasks', broker='redis://localhost:6379/0')
|
|
|
+
|
|
|
+# 定义一个 Celery 任务
|
|
|
+@app.task
|
|
|
+def add(x, y):
|
|
|
+ return x + y
|
|
|
+
|
|
|
+
|
|
|
+# 调用 Celery 任务，其中4,6为add函数的参数
|
|
|
+result = add.delay(4, 6)
|
|
|
+
|
|
|
+# 等待任务执行完成并获取结果
|
|
|
+print("Task ID:", result.id)
|
|
|
+print("Task Status:", result.status)
|
|
|
+print("Task Result:", result.get())
|
|
|
+
|
|
|
+```
|
