我的服务如下：

在创建 REDIS 主从复制并将 Celery 和 Flower 指向 Master 之后，我创建了一个用于测试目的的简单任务......

Supervisord 的celery.ini

celery_app.py

再次，工人工作正常，花显示任务结果。但是一旦我使用重新启动服务

sudo 服务花重启

Flower 在没有任何数据的情况下作为全新安装加载...

我对代理/后端网址做错了吗？

我有 celery 4.1.0、django 1.11.11、rabbitMQ 和 Redis 作为结果。

所以，当我的代码遇到除了块 self.update_state 不起作用但记录器工作时......实际上，我不确定是否

这是正确的...

我想做的是捕获我的python代码的异常（通过try和except块），更改状态并手动终止任务。那么，有什么建议/帮助吗？

假设我在 celery 队列上的所有任务都在访问第 3 方 API。但是，API 有一个速率限制，我正在跟踪它（我需要遵守一天限制和每小时限制）。一旦我达到速率限制，我想暂停新任务的消费，然后当我知道我很好时恢复。

我通过使用以下两个任务实现了这一点：

然后我可以继续提交我的 3rd 方 API 任务，一旦我的消费者被添加回来，我的所有任务都会被消耗掉。伟大的。

然而，由于我在这个队列中没有消费者，这似乎意味着我再也看不到在Flower中提交的作业（直到我的消费者被添加）。

有什么我做错了吗？我可以通过另一种方式实现这种“暂停”，让我继续看到提交的工作吗？

ps也许这与这个问题有关，但不是100％肯定：https ://github.com/celery/celery/issues/1452

如果这有所作为，我正在使用 amqp 代理。

谢谢女孩和男孩。

我们将 Django 用于我们的 Python 网站。我们celery==4.1.1用来运行后台任务。一切正常。但是，我无法像以前在旧 celery 中使用djcelery. 我听说过flower。

我用了

这是主管中的命令：

这是我的 Nginx 配置：

我无法打开仪表板。它显示 504 错误。

这是来自 celery-flower-stderr 的日志。

是否--broker-api必须只显示花卉仪表板？我的设置有问题吗？我应该怎么办？我怀疑这与我的 nginx 配置有关。请指出其中的任何错误。

已编辑

我添加了broker-api=http://guest:**@ec2-xx-2xx-1xx-xx.eu-west-1.compute.amazonaws.com:15672/api/和 rabbitmq 管理命令。

现在 celery-flower-stderr 中的消息：

在哪里有一些与 sqs+celery 一起使用的花卉模拟？我发现在当前的 celery 版本中，sqs 不支持 celery 事件。也许还有其他方法可以获取有关多少任务成功、多少崩溃等信息。我的项目使用 Django+Celery+SQS

有没有一种方法可以将 Celery Flower 仪表板嵌入到 Flask 应用程序中，以便查看工作状态等？

我正在使用Celery和Flower和Redis的最新版本，但我不明白发生了什么。我得到了所有结果，并且数据正确返回，但是当我使用 Flower 查看 Celery 任务时，我看到了所有任务和结果。

我的任务有以下装饰器：

我试过调用get(),forget()等，但是当我查看 Flower 时，结果总是在那里。

我也试过：

我启动任务：

我试过了：

我无法让任务不在Flower中显示，所以我认为任务必须仍然存在（占用内存）。

这是真的？有没有想过让他们消失？

谢谢！

我有一个正在工作的芹菜花项目。现在我想要一些使用花 http api 的芹菜任务详细信息，但是当我在http://localhost:5555/api/task/info/上的花 http api 发出请求时，task_id它返回 500 错误？

花页里一切都好。

在使用requests获取http api时，发生了一些错误！

所有步骤都遵循Flower 的文档。花日志如下：

我已经部署了花来监控 celery 任务，但是花的仪表板没有显示足够的信息。

我怎样才能获得完整的信息仪表板作为文档。 https://flower.readthedocs.io/en/stable/screenshots.html

我正在尝试掌握 Celery 的窍门。到目前为止，一切看起来都很好。我只是无法弄清楚一件事：

我希望存储在数据库中的任务结果不仅可以从工作人员更新状态，还可以在将消息发送到代理时从客户端应用程序更新状态。

所以目前我的配置中有以下两行：

这会更新数据库中由工作人员管理的任务的所有状态，包括STARTED状态。

但我想要的是也有由于客户端的状态，比如PENDING. 因此，PENDING只要工作人员没有获得该任务，DB 中的结果就会开始，然后当工作人员开始/获得该任务时，诸如 等状态STARTED将SUCCESS更新到数据库。

背后的基本原理是我们希望我们的数据库包含所有任务的记录，即使它们仍处于待处理状态（即尚未被任何工作人员选中）。

我的问题是：

1. 可能吗？因为这种方式数据库中的任务行必须由客户端代码创建，然后工作人员在更新任务状态时必须识别正确的任务。如果不是通过任何 Celery 配置，那么可能是通过编写自定义代码？

2. 我遇到了CELERY_SEND_TASK_SENT_EVENT = True它使 Celery 客户端能够发送事件，从而允许Flower显示PENDING任务。我的猜测是，如果Flower可以从客户端代码中获取这些事件，然后从工作人员的事件中更新正确的状态，那么数据库应该能够做到。尝试上述设置只是试一试。但它不仅对数据库不起作用，而且对数据库也没有影响Flower。我仍然看不到我的待处理任务Flower。我只能在工人开始并改变他们的状态时看到他们。