update celery

xianhu · xianhu · commit 57988b3de0a7 · 2022-04-13T23:06:08.000+08:00
diff --git a/python_celery.py b/python_celery.py
@@ -2,16 +2,18 @@
 
 """
 测试celery
-运行：celery -A celery1:app worker -l INFO
+终端运行：celery -A python_celery:app worker -l INFO
 """
 
 import time
+
 from celery import Celery
 
-broker = 'redis://152.136.149.221:9002/10'   # 用redis做broker，中间件
-backend = 'redis://152.136.149.221:9002/11'    # 用redis做broken，用来保存结果
+broker = "redis://localhost:6379/10"  # 用redis做broker，中间件
+backend = "redis://localhost:6379/11"  # 用redis做broken，用来保存结果
+
+app = Celery("tasks", broker=broker, backend=backend)
 
-app = Celery('tasks',broker=broker,backend=backend)
 
 @app.task
 def add(x, y):
diff --git a/python_celery_test.py b/python_celery_test.py
@@ -5,13 +5,14 @@
 """
 
 import time
+
 from python_celery import add
 
 if __name__ == "__main__":
     result = []
     for i in range(10):
-        result.append(add.delay(1, 2))
+        result.append(add.delay(i, i))
+    print("----", time.time())
+    for index, item in enumerate(result):
+        print(index, item.get())
     print("----", time.time())
-    for i in result:
-        print(i, i.get())
-    print("----", time.time())
