GitLocker: The Coding Marketplace

Description:

celerydebug 0.1.4

celery-debug
celery debug tasks.
安装
pip install celery-debug

输出的celery调试服务

debug.ping
debug.echo
debug.sleep
debug.raise_error
debug.retry_n

启动

在工作目录下创建celeryconfig.py，添加以下内容
# concurrency
worker_concurrency = 10
worker_pool = "threads"
# broker_url and result_backend
broker_url = "redis://redis/0"
result_backend = "redis://redis/1"
# internal configs
accept_content = ["application/json"]
task_serializer = "json"
result_accept_content = ["application/json"]
result_serializer = "json"
timezone = "Asia/Shanghai"
broker_connection_retry_on_startup = True
task_track_started = True
task_acks_late = True
task_acks_on_failure_or_timeout = True
task_reject_on_worker_lost = True
# 额外新增的配置项
# 配置后所有任务都使用不同的队列
use_different_queue = True

使用以下命令启动celery worker
celery -A celery_debug.app:app worker -l DEBUG

版本记录
v0.1.0

版本首发。

v0.1.1

提供配置项，快速让所有任务都使用不同的队列。

v0.1.2

use_different_queue方法做成工具函数。让用户自主控制，避免一引入就强制设置。

v0.1.4

use_different_queue自动绑定celery消息队列。
添加deubg.sleep任务。
添加debug.raise_error任务。
添加debug.retry_n任务。