.

Author: xdai555

demo/celery_demo/demo1/README.md

@@ -14,4 +14,4 @@
 
    运行之后，可以在 celery 进程中看到 worker 已经接受了一系列 task 并开始了处理，一般在运行任务时打印出任务 ID。
 
-3. 运行结果可以通过 fetch_result.py 根据任务 ID 来获取。
+3. 运行结果可以通过 fetch_result.py 根据任务 ID 来获取。  

demo/celery_demo/demo1/exec_task.py

@@ -1,14 +1,14 @@
 from task import send_msg, send_msg1
 import time
 
-# for i in range(5):
-#     send_msg1.delay(str(i))
-#     send_msg.delay(str(i+5))
+for i in range(30):
+    send_msg1.delay(str(i))
+    send_msg.delay(str(i+5))
 
-result = send_msg.delay("Hello")
-print(result.id)
-while not result.ready():
-    print("正在执行中...")
-    time.sleep(0.5)
+# result = send_msg.delay("Hello")
+# print(result.id)
+# while not result.ready():
+#     print("正在执行中...")
+#     time.sleep(0.5)
 
-print("执行完成\n" + result.get())
+# print("执行完成\n" + result.get())

demo/celery_demo/demo2/celery_tasks/celery.py

@@ -32,4 +32,4 @@
 }
 
 # 启动定时任务，将任务周期性地添加到 worker 队列中执行
-
+# celery -A celery_tasks  beat -l info