celery 并发数是否等于一次可以执行的任务数？
我了解您应该将工作人员计算为您的节点的核心数，如果您超越了此核心，则可能会压倒节点。 我有数百个Web请求（每个Web请求）需要每分钟，目前通过 ap…
芹菜任务未执行 - 芹菜不工作的最简单示例
我在运行非常基本的、实际上是最简单的 celery 示例时遇到了麻烦。 你能指导我是否我在这里做错了什么？ 工作部分： from celery import Celery celer…
在 Heroku 中使用 Selenium 以及 Python、FastAPI 和 Celery 时，错误 R14（超出内存配额）导致 TimeoutException
我构建了一个抓取器，可以从页面收集数据，对其进行格式化并将其添加到数据库中。然后，它使用抓取的数据来构建模型，但抓取的一个值除外。一切都包含…
芹菜不仅在AWS中注册我的任务
dev环境中Terraform的结构我们有一个与AWS中的Terraform一起部署的应用程序。 Terraform负责创建所需的所有资源，包括AWS，包括芹菜，节拍和花朵以及…
可以动态禁用 celery 调度程序任务吗？
声明中是否有一个“启用”字段可以动态启用/禁用计划任务？ CELERYBEAT_SCHEDULE = { 'add-every-30-seconds': { 'task': 'tasks.add', 'schedule': t…
雷迪斯不工作。 __init__() 得到了意外的关键字参数“用户名”；
我正在尝试运行 celery -A 项目工作人员 -l 信息。但每次它都会返回一个错误，例如 init 遇到意外错误。请帮助。 提前致谢。 我的设置文件： CELERY_B…
Django Celery Beat - Ubuntu 上的失控进程
我在 ubuntu 上将 celerybeat 作为服务运行。 一般来说，一切都很好。我在许多服务器上都有相同的设置。 昨晚，我注意到某个任务的触发频率增加了一倍…
为什么 docker-compose 可以工作而 docker run 不能
我有以下 local.yml 文件 version: '3' services: celery-worker-default: image: weapp_app:latest container_name: weapp_celery-worker-default co…
将 POST 请求从 Flask 传递到 Celery 任务
我在 Flask 中有一个很长的 csv 文件上传任务，由于它很长，我想让 Celery 在后台处理它，但是如何将此请求从 Flask 路由传递到 Celery 任务？ 为了构…
有没有办法验证 celery 是否在 Google 云中启动，因为所有作业都将进入队列状态
有没有办法在 Gcp 中验证 celery 是启动还是关闭，因为我们所有的气流作业都进入队列状态并且没有被执行。 （气流在谷歌云中运行） …
如何杀死所有 Celery 后台进程
终止所有 celery 进程涉及到“ps”命令上的“grep”并对所有 PID 运行kill 命令。格雷平 ps 命令会显示 grep 命令的自身进程信息。为了跳过该 PID，'g…
如何获取 My Celery 应用程序处理的任务数
我有一个使用 redis 作为代理的 Celery 应用程序，我可以使用以下命令获取应用程序的统计信息 celery -A test.celeryappspect stats 这给了我一些如下…
