| Name | celery-debug JSON |
| Version |
0.1.5
JSON |
| download |
| home_page | None |
| Summary | celery debug tasks. |
| upload_time | 2025-10-26 02:21:21 |
| maintainer | rRR0VrFP |
| docs_url | None |
| author | rRR0VrFP |
| requires_python | None |
| license | MIT |
| keywords |
celery
debug
tasks
|
| VCS |
|
| bugtrack_url |
|
| requirements |
No requirements were recorded.
|
| Travis-CI |
No Travis.
|
| coveralls test coverage |
No coveralls.
|
# celery-debug
celery debug tasks.
## 安装
```shell
pip install celery-debug
```
## 输出的celery调试服务
- debug.ping
- debug.echo
- debug.sleep
- debug.raise_error
- debug.retry_n
## 启动
1. 在工作目录下创建`celeryconfig.py`，添加以下内容
```python
# 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
```
2. 使用以下命令启动celery worker
```shell
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`任务。
### v0.1.5
- Doc update.
Raw data
{
"_id": null,
"home_page": null,
"name": "celery-debug",
"maintainer": "rRR0VrFP",
"docs_url": null,
"requires_python": null,
"maintainer_email": null,
"keywords": "celery debug tasks",
"author": "rRR0VrFP",
"author_email": null,
"download_url": "https://files.pythonhosted.org/packages/bb/55/0ec21a3336c6be43c24ada01b7fc712202362a3aa1306bfd7c4326fc05f7/celery_debug-0.1.5.tar.gz",
"platform": null,
"description": "# celery-debug\n\ncelery debug tasks.\n\n## \u5b89\u88c5\n\n```shell\npip install celery-debug\n```\n\n## \u8f93\u51fa\u7684celery\u8c03\u8bd5\u670d\u52a1\n\n- debug.ping\n- debug.echo\n- debug.sleep\n- debug.raise_error\n- debug.retry_n\n\n## \u542f\u52a8\n\n1. \u5728\u5de5\u4f5c\u76ee\u5f55\u4e0b\u521b\u5efa`celeryconfig.py`\uff0c\u6dfb\u52a0\u4ee5\u4e0b\u5185\u5bb9\n\n ```python\n # concurrency\n worker_concurrency = 10\n worker_pool = \"threads\"\n # broker_url and result_backend\n broker_url = \"redis://redis/0\"\n result_backend = \"redis://redis/1\"\n # internal configs\n accept_content = [\"application/json\"]\n task_serializer = \"json\"\n result_accept_content = [\"application/json\"]\n result_serializer = \"json\"\n timezone = \"Asia/Shanghai\"\n broker_connection_retry_on_startup = True\n task_track_started = True\n task_acks_late = True\n task_acks_on_failure_or_timeout = True\n task_reject_on_worker_lost = True\n # \u989d\u5916\u65b0\u589e\u7684\u914d\u7f6e\u9879\n # \u914d\u7f6e\u540e\u6240\u6709\u4efb\u52a1\u90fd\u4f7f\u7528\u4e0d\u540c\u7684\u961f\u5217\n use_different_queue = True\n ```\n\n2. \u4f7f\u7528\u4ee5\u4e0b\u547d\u4ee4\u542f\u52a8celery worker\n\n ```shell\n celery -A celery_debug.app:app worker -l DEBUG \n ```\n\n## \u7248\u672c\u8bb0\u5f55\n\n### v0.1.0\n\n- \u7248\u672c\u9996\u53d1\u3002\n\n### v0.1.1\n\n- \u63d0\u4f9b\u914d\u7f6e\u9879\uff0c\u5feb\u901f\u8ba9\u6240\u6709\u4efb\u52a1\u90fd\u4f7f\u7528\u4e0d\u540c\u7684\u961f\u5217\u3002\n\n### v0.1.2\n\n- use_different_queue\u65b9\u6cd5\u505a\u6210\u5de5\u5177\u51fd\u6570\u3002\u8ba9\u7528\u6237\u81ea\u4e3b\u63a7\u5236\uff0c\u907f\u514d\u4e00\u5f15\u5165\u5c31\u5f3a\u5236\u8bbe\u7f6e\u3002\n\n### v0.1.4\n\n- `use_different_queue`\u81ea\u52a8\u7ed1\u5b9a`celery`\u6d88\u606f\u961f\u5217\u3002\n- \u6dfb\u52a0`deubg.sleep`\u4efb\u52a1\u3002\n- \u6dfb\u52a0`debug.raise_error`\u4efb\u52a1\u3002\n- \u6dfb\u52a0`debug.retry_n`\u4efb\u52a1\u3002\n\n### v0.1.5\n\n- Doc update.\n",
"bugtrack_url": null,
"license": "MIT",
"summary": "celery debug tasks.",
"version": "0.1.5",
"project_urls": null,
"split_keywords": [
"celery",
"debug",
"tasks"
],
"urls": [
{
"comment_text": null,
"digests": {
"blake2b_256": "23519b510e257a0457f91af49c3b5a0e52a71481a4aec9c9df49a9867b97ae9e",
"md5": "55c47a1b2dbdca175847c9a83f21b4c1",
"sha256": "2ac6ea4f158cb44c471a1714d98044963cc816c2a1bf2697a5def7b85859860f"
},
"downloads": -1,
"filename": "celery_debug-0.1.5-py3-none-any.whl",
"has_sig": false,
"md5_digest": "55c47a1b2dbdca175847c9a83f21b4c1",
"packagetype": "bdist_wheel",
"python_version": "py3",
"requires_python": null,
"size": 4585,
"upload_time": "2025-10-26T02:21:20",
"upload_time_iso_8601": "2025-10-26T02:21:20.519271Z",
"url": "https://files.pythonhosted.org/packages/23/51/9b510e257a0457f91af49c3b5a0e52a71481a4aec9c9df49a9867b97ae9e/celery_debug-0.1.5-py3-none-any.whl",
"yanked": false,
"yanked_reason": null
},
{
"comment_text": null,
"digests": {
"blake2b_256": "bb550ec21a3336c6be43c24ada01b7fc712202362a3aa1306bfd7c4326fc05f7",
"md5": "f1c67b83b5d62514e12f2d9e8cbd99fd",
"sha256": "64925468e8ed7c405e26fb15a47c499da0f2c7d11704cae2a075343bfae9ae53"
},
"downloads": -1,
"filename": "celery_debug-0.1.5.tar.gz",
"has_sig": false,
"md5_digest": "f1c67b83b5d62514e12f2d9e8cbd99fd",
"packagetype": "sdist",
"python_version": "source",
"requires_python": null,
"size": 4282,
"upload_time": "2025-10-26T02:21:21",
"upload_time_iso_8601": "2025-10-26T02:21:21.841418Z",
"url": "https://files.pythonhosted.org/packages/bb/55/0ec21a3336c6be43c24ada01b7fc712202362a3aa1306bfd7c4326fc05f7/celery_debug-0.1.5.tar.gz",
"yanked": false,
"yanked_reason": null
}
],
"upload_time": "2025-10-26 02:21:21",
"github": false,
"gitlab": false,
"bitbucket": false,
"codeberg": false,
"lcname": "celery-debug"
}
