一,通过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