问题标签 [djcelery]

我正在尝试task2从task_success信号连接

当我运行此代码时，它会抛出

如果删除app.tasktask2 的装饰器，它会完美运行。但是为什么无法连接到 celery 任务呢？

我正在 Django 中实现一个任务调度系统。用户将选择一个任务，例如发送电子邮件，并将为任务执行设置一个非常具体的时间和日期。

我发现用 Celery 你可以设置一个任务，比如

但是如何在特定时间触发它？对于 celery 中的 PeriodicTasks，必须预先指定执行时间和频率。如何即时添加执行日期和时间？

他们是 Celery 中的任何方法，例如 add.schedule(date="SOME_DATA") 还是我可以解决这个用例的任何其他方法。

当我跑步时

我收到以下错误

当工作人员接受使用 pickle 序列化的消息时以超级用户权限运行工作人员是一个非常糟糕的主意！如果你真的想继续，那么你必须设置 C_FORCE_ROOT 环境变量（但在你做之前请考虑一下）。

用户信息：uid=0 euid=0 gid=0 egid=0

被这个问题困住了，有没有人可以解决这个问题？

Celery 用户指南建议在调用任务进程之前手动提交 Django 事务。

http://celery.readthedocs.org/en/latest/userguide/tasks.html#database-transactions

我希望系统尽可能可靠。从事务提交和调用任务之间的崩溃中恢复的最佳实践是什么（即确保在事务提交时始终调用任务）。

顺便说一句，现在我正在使用我实现的基于数据库的作业队列，所以没有这样的问题——我可以在事务中发送作业。我不太确定是否应该改用 Celery。

我正在使用 djcelery 和 django 的管理站点。如果我想停止一个已经启动的 djcelery 任务，我是使用 revoke、terminate 还是 kill，有什么区别？

使用 current_app.send_task 时，我遇到了 Celery 队列路由问题

我有两个工人（每个队列一个）

我在 celeryconfig.py 文件中定义了两个队列：

在任务的定义中，我们使用装饰器来显式队列：

当使用以下命令运行此任务时，此任务确实在低队列中运行：

但是当它使用以下方式运行时并非如此：（它在默认队列中运行：“优先级”）

我想知道为什么这种后一种方式不会将任务路由到“低”队列！

ps：我用redis。

我有一个相当复杂的工作流程（动态构建），看起来像这样：

)

然后芹菜变成这样：

请注意和弦末尾的任务是如何被推入“任务”标题的。根据我的阅读，这些任务存储在主任务标题中，并且在和弦标题完成执行之前不会放入队列中。

当我尝试显示整个工作流的 task_id 时（我希望它是工作流中的 task_id 之一）。

我得到的这个任务 ID 没有存储在 celery_taskmeta 或 celery_tasksetmeta 中。这不是在工作流中执行的任何任务（请参阅下面的工作日志）。任何想法，这个 task_id 代表什么，如果有的话我可以将它链接到任何正在执行的任务？

我希望能够遍历结果并显示工作流中每个任务的状态。但是，我得到的这个任务 ID 似乎与任何任务无关。下面是工作日志，您会看到上面打印的任务 ID 找不到！有任何想法吗？谢谢。

我有一个在 django 上运行的 Web 应用程序，最终用户可以在其中输入一个 URL 进行处理。所有的处理任务都被卸载到一个 celery 队列中，当任务完成时，它会向用户发送通知。

我需要用目标对这个应用程序进行压力测试。

• 确定断点或安全使用限制
• 确认符合预期规格
• 确定故障模式（系统究竟如何故障）
• 测试零件或系统在标准使用范围之外的稳定运行

考虑到我还需要考虑卸载的 celery 任务，我该如何用 Python 编写脚本。

我已经为我的 django 应用安装了花pip install flower。我使用命令启动它./manage.py celery flower --port=5555。之后我得到以下输出。

但是，我无法在 UI 中看到任何任务和工作人员。请任何指点。

大家好，我收到以下错误。我已经检查了 rabbitmqctl 的状态及其工作良好。但是在定期运行任务时发现以下问题。CPU消耗也增加到100％。请帮我解决这个问题。

也请你让我知道“这两个问题是否相互关联？？”

谢谢你的帮助。