如何按任务名称检查和取消Celery任务
我将Redis作为经纪人使用Celery（3.0.15）。
有没有一种简单的方法来查询Celery队列中存在的具有给定名称的任务数？
并且，作为后续措施，是否可以取消Celery队列中存在的所有具有给定名称的任务？
我已经看过《监控和管理指南》，在那儿看不到解决方案。
问题答案：
# Retrieve tasks
# Reference: http://docs.celeryproject.org/en/latest/reference/celery.events.state.html
query = celery.events.state.tasks_by_type(your_task_name)
# Kill tasks
# Reference: http://docs.celeryproject.org/en/latest/userguide/workers.html#revoking-tasks
for uuid, task in query:
celery.control.revoke(uuid, terminate=True)
-
问题内容： 如何检查一项任务是否在celery中运行（特别是我在使用celery-django）？ 我已经阅读了文档，并且已经在Google上进行了搜索，但是看不到类似以下的呼叫： 我的用例是我有一个外部（java）服务来进行代码转换。当我发送要进行代码转换的文档时，我想检查运行该服务的任务是否正在运行，如果没有运行，请（重新）启动它。 我相信我使用的是当前的稳定版本2.4。 问题答案： 每个对象
-
问题内容： 我一直在阅读文档并进行搜索，但似乎找不到直接的答案： 你可以取消已经执行的任务吗？（由于任务已开始，需要一段时间，因此需要取消一半） 我是从Celery FAQ的文档中找到的 但是我不清楚这是否会取消排队的任务，或者是否会杀死工作程序上正在运行的进程。感谢你能摆脱的光芒！ 问题答案： 撤销将取消任务执行。如果任务被吊销，工人将忽略该任务并且不执行它。如果你不使用持久撤销，则可以在wor
-
问题内容： 如何从任务中获取任务的task_id值？这是我的代码： 这个想法是，当我创建任务的新实例时，我从任务对象中检索。然后，我使用任务ID来确定任务是否已完成。我 不想 按值跟踪任务，因为在任务完成后文件将被“清理”，并且可能存在也可能不存在。 在上面的示例中，我将如何获取值？ 问题答案： 如果任务接受，Celery会设置一些默认关键字参数。（您可以使用** kwargs接受它们，也可以专门
-
问题内容： 我刚刚发现了有关配置选项（docs）的信息。默认值为4，但是（我相信）我希望预取尽可能少。我现在将其设置为1，这与我要查找的值足够接近，但是仍有一些我不理解的地方： 为什么这样预取一个好主意？我并没有真正找到原因，除非消息队列和工作线程之间存在大量延迟（就我而言，它们当前正在同一主机上运行，最糟糕的是最终可能在同一数据中的不同主机上运行）中央）。该文档仅提到了缺点，但没有解释优点是
-
问题内容： 我目前正在将celery与django结合使用，并且一切正常。 但是，如果服务器超载，我希望能够通过检查当前计划了多少个任务，使用户有机会取消任务。 我怎样才能做到这一点？ 我正在使用Redis作为代理。 这在某种程度上与我的问题有关，但是我不需要列出任务，只需数一下它们即可:) 问题答案： 如果您的代理配置为，并且您的任务已提交到常规队列，则可以通过以下方式获得长度： 或者，从she
-
以下是我的代码尝试执行的操作：编写一个名为 processName 的方法，该方法接受控制台的扫描仪作为参数，并提示用户输入全名，然后以相反的顺序打印名称（即姓氏、名字）。 以下是与用户的示例对话： 请输入您的全名：Sammy Jankis 你的名字倒过来是詹基斯，萨米 我在阅读时出错： 我的问题是，如何将名称字符串分成两部分，以便将其反转？请使用简单的术语，因为我是编码新手。