当前位置: 首页 > news >正文

python: 安装使用celery

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

 

http://www.jsqmd.com/news/119435/

相关文章:

  • 【Open-AutoGLM任务分配核心机密】:揭秘企业级自动化调度背后的算法逻辑
  • django基于数据挖掘的微博事件分析与可视化系统的设计与实现演示录像2023_u9nmf-vue
  • Open-AutoGLM即将开幕:你不可错过的5大前沿议题与参会价值
  • 读懂HikariCP一百行代码,多线程就是个孙子
  • 为什么顶尖团队都在用Open-AutoGLM做月报?背后的数据逻辑首次公开
  • 别让“小眼镜”挡住清晰世界!儿童近视防控,家长必知的科学指南
  • JavaSE——面向对象思想的应用
  • 好写作AI:你的学位论文理论框架,是“导航图”还是“理论陈列馆”?
  • 单北斗GNSS在大坝形变监测中的应用与性能分析
  • Open-AutoGLM会议调度秘籍(企业级应用案例曝光)
  • 证件照合格率低?Open-AutoGLM智能预检系统上线,审核通过率翻倍
  • 注意:雪花算法并不是ID的唯一选择!
  • 2025年印刷机市场新品排行榜,印刷开槽模切机/全伺服前缘送纸印刷开槽模切联动线/高速全自动水墨印刷开槽模切机印刷机订制厂家口碑推荐榜 - 品牌推荐师
  • 揭秘Open-AutoGLM自动汇总技术:如何3分钟生成高质量团队周报
  • 大厂面试真题解析:java 集合 +spring+ 并发编程 +MyBatis
  • 错过Open-AutoGLM等于落后3年?AI驱动会议管理的终极解决方案
  • 为什么你的Open-AutoGLM项目总延期?深度剖析进度监控缺失的4大痛点
  • BAT 大厂 java 程序员面试必问:JVM+Spring+ 分布式 +tomcat+MyBatis
  • 抓 https 加密数据,偷偷摸摸爽得很!
  • 绝杀峡谷源码 副图 通达信 贴图
  • Open-AutoGLM周报自动化落地全路径(从部署到高阶调优)
  • 使用systemd,把服务装进 Linux 心脏里~
  • Open-AutoGLM周报引擎实战指南(AI驱动办公新革命)
  • SMP语言基础知识-应用系统,开发的痛点,开发者的痛点
  • 高手,云集在于REST、gRPC 和 GraphQL之间!
  • Open-AutoGLM工作流监控实战指南(实时可视化监控体系搭建全解析)
  • 各大互联网公司面经分享:Java 全栈知识 +1500 道大厂面试真题
  • Open-AutoGLM数据统计实战:5步教你精准提取月报核心指标
  • 还在手动管理日程?用Open-AutoGLM实现全自动提醒,效率翻倍!
  • 赞!idea 如何单窗口打开多个项目?