吉林省网站建设_网站建设公司_内容更新_seo优化
2025/12/21 15:13:37 网站建设 项目流程

一,通过pip安装

$ pip install celery

事先启动redis,

安装访问redis的库

$ pip install redis

二,创建task1

代码:

import time
from celery import Celerycelery = Celery('tasks', broker='redis://localhost:6379/0')@celery.task
def celery_test(data):time.sleep(2.0)print(data)if __name__=="__main__":celery.start()

运行:

$ celery -A task1 worker --loglevel=INFO

三,调用task1

代码:

from task1 import celery_testfor i in range(10):celery_test.delay("my running at %s"%str(i))

运行:

$ python3 testcelery.py 

四,运行结果:

[2025-12-21 15:02:02,183: INFO/MainProcess] Task task1.celery_test[5c87924f-bfc6-46bf-835b-1b6e53f74fee] received
[2025-12-21 15:02:02,185: INFO/MainProcess] Task task1.celery_test[fc5b05a0-8563-43f6-bcc7-828f1fccfe6b] received
[2025-12-21 15:02:02,187: INFO/MainProcess] Task task1.celery_test[f4f7f6c1-90b0-4184-b4c7-12375266c6c0] received
[2025-12-21 15:02:02,188: INFO/MainProcess] Task task1.celery_test[23f0267a-d898-44fd-bed4-f7de67713fa4] received
[2025-12-21 15:02:02,189: INFO/MainProcess] Task task1.celery_test[a53e9a6b-4ddc-49e1-9228-9dc9b706f809] received
[2025-12-21 15:02:02,190: INFO/MainProcess] Task task1.celery_test[090209d1-4922-43ff-a711-5e72c884aa79] received
[2025-12-21 15:02:02,190: INFO/MainProcess] Task task1.celery_test[d69a6b94-49e3-4144-84a1-aef49fd04527] received
[2025-12-21 15:02:02,191: INFO/MainProcess] Task task1.celery_test[a26ba6de-d32c-4cc6-a153-dda888f8c2eb] received
[2025-12-21 15:02:02,192: INFO/MainProcess] Task task1.celery_test[f966fedb-b809-4a1e-bc1a-a4d8c80c0799] received
[2025-12-21 15:02:02,193: INFO/MainProcess] Task task1.celery_test[20cb6b7d-6bfc-4188-be8d-0da68efc73b0] received
[2025-12-21 15:02:04,185: WARNING/ForkPoolWorker-1] my running at 0
[2025-12-21 15:02:04,186: INFO/ForkPoolWorker-1] Task task1.celery_test[5c87924f-bfc6-46bf-835b-1b6e53f74fee] succeeded in 2.0012752229995385s: None
[2025-12-21 15:02:04,188: WARNING/ForkPoolWorker-2] my running at 1
[2025-12-21 15:02:04,189: INFO/ForkPoolWorker-2] Task task1.celery_test[fc5b05a0-8563-43f6-bcc7-828f1fccfe6b] succeeded in 2.0031797969986656s: None
[2025-12-21 15:02:06,190: WARNING/ForkPoolWorker-1] my running at 2
[2025-12-21 15:02:06,190: INFO/ForkPoolWorker-1] Task task1.celery_test[f4f7f6c1-90b0-4184-b4c7-12375266c6c0] succeeded in 2.0007636589998583s: None
[2025-12-21 15:02:06,191: WARNING/ForkPoolWorker-2] my running at 3
[2025-12-21 15:02:06,191: INFO/ForkPoolWorker-2] Task task1.celery_test[23f0267a-d898-44fd-bed4-f7de67713fa4] succeeded in 2.0006290000001172s: None
[2025-12-21 15:02:08,193: WARNING/ForkPoolWorker-2] my running at 5
[2025-12-21 15:02:08,193: WARNING/ForkPoolWorker-1] my running at 4
[2025-12-21 15:02:08,193: INFO/ForkPoolWorker-2] Task task1.celery_test[090209d1-4922-43ff-a711-5e72c884aa79] succeeded in 2.0010091669992107s: None
[2025-12-21 15:02:08,194: INFO/ForkPoolWorker-1] Task task1.celery_test[a53e9a6b-4ddc-49e1-9228-9dc9b706f809] succeeded in 2.0014524329999404s: None
[2025-12-21 15:02:10,196: WARNING/ForkPoolWorker-2] my running at 7
[2025-12-21 15:02:10,196: WARNING/ForkPoolWorker-1] my running at 6
[2025-12-21 15:02:10,196: INFO/ForkPoolWorker-2] Task task1.celery_test[a26ba6de-d32c-4cc6-a153-dda888f8c2eb] succeeded in 2.001402545000019s: None
[2025-12-21 15:02:10,197: INFO/ForkPoolWorker-1] Task task1.celery_test[d69a6b94-49e3-4144-84a1-aef49fd04527] succeeded in 2.0015222629990603s: None
[2025-12-21 15:02:12,199: WARNING/ForkPoolWorker-1] my running at 8
[2025-12-21 15:02:12,199: WARNING/ForkPoolWorker-2] my running at 9
[2025-12-21 15:02:12,199: INFO/ForkPoolWorker-1] Task task1.celery_test[f966fedb-b809-4a1e-bc1a-a4d8c80c0799] succeeded in 2.0012847779998992s: None
[2025-12-21 15:02:12,199: INFO/ForkPoolWorker-2] Task task1.celery_test[20cb6b7d-6bfc-4188-be8d-0da68efc73b0] succeeded in 2.0014259250001487s: None

 

需要专业的网站建设服务?

联系我们获取免费的网站建设咨询和方案报价,让我们帮助您实现业务目标

立即咨询