任务排队

[woshiyanghai]

一个归档任务长时间运行，导致这个时候执行的工单排队，django-q 是否可以设置多个队列？

[nick2wang]

可以调整workers数量

Archery/archery/settings.py

Lines 238 to 250 in 30585b0

	Q_CLUSTER = {
	"name": "archery",
	"workers": env("Q_CLUISTER_WORKERS", default=4),
	"recycle": 500,
	"timeout": env("Q_CLUISTER_TIMEOUT", default=60),
	"compress": True,
	"cpu_affinity": 1,
	"save_limit": 0,
	"queue_limit": 50,
	"label": "Django Q",
	"django_redis": "default",
	"sync": env("Q_CLUISTER_SYNC"), # 本地调试可以修改为True，使用同步模式
	}

[woshiyanghai]

能否单独指定一个队列，因为归档任务很多，如果加worker的话，还是有可能出现等待

[woshiyanghai]

在setting这里如何增加一个队列？
在sql/archery.py中调用async_task 如何制定队列名称？
def archive_once(request):
"""单次立即调用归档任务"""
archive_id = request.GET.get("archive_id")
async_task(
"sql.archiver.archive",
archive_id,
timeout=-1,
task_name=f"archive-{archive_id}",
)
辛苦大佬指导一下

[nick2wang]

理论上你可以自定义两个broker，运行两套qcluster配置不同的Q_CLUSTER参数，然后通过运行任务时指定broker来实现，我没有验证过，仅供参考