celery 相关问题

Celery是Python的分布式任务队列框架，用于异步和并行执行。

我正在学习Python中的并发我设置了 Celery 运行一个脚本来获取请求 50 次，只需要 0.13 秒就完成了，真的让我惊讶！当我与普通

python concurrency celery

回答 1 投票 0

运行时错误：模型类 django_celery_beat.models.SolarSchedule 未声明显式 app_label 并且不在 INSTALLED_APPS 中的应用程序中

我正在使用我的 virtualenv 并在执行 celery -A appbeat -l info -S django 时，始终显示此错误。 RuntimeError：模型类 django_celery_beat.models.SolarSchedule 未声明 exp...

django celery django-celery celerybeat django-celery-beat

回答 2 投票 0

SSL SYSCALL 错误：使用 postgres 和 Celery 的 Heroku 上的文件描述符错误

我已经在 Heroku 上的 Django 站点上成功使用了 Celery，但它刚刚开始生成下面的错误，这导致它停止运行。看起来 postgres 有问题，但我...

django postgresql heroku celery

回答 4 投票 0

如何将 Docker Compose Manifest 迁移到 Kubernetes？

上下文我与 celery 工人和 docker 进行了广泛的合作，但我对 Kubernetes 的了解非常基础。这是我如何在

docker kubernetes docker-compose redis celery

回答 1 投票 0

芹菜优先不适用

我有这个示例代码： @router.post('/测试') 定义测试（）：对于范围 (0,10) 内的 i： Testy.apply_async([i],优先级=7) 返回“完成” @app.task(绑定=True) def Testy(自我,i): ...

python celery priority-queue

回答 1 投票 0

运行 celery 时出现 Celery 和 Redis 错误

我正在使用 celery 和 redis 制作一个 django 应用程序，它可以异步更新股票价格。我现在正在处理后台任务，芹菜无法正常运行。然后我打开 Redis 服务器...

django redis celery

回答 1 投票 0

与 Nginx、Flask 和 Redis 一起部署时，Celery docker 容器上的空闲高 CPU 使用率

空闲时，Celery docker 容器的 CPU 使用率极高，docker stats 显示高达 600% 使用率。在执行任何任务之前启动容器后立即观察到此行为...

flask celery

回答 1 投票 0

当我尝试使用 redbeat 在终端中启动 celerybeat 时，为什么会收到“'NoneType'对象没有属性'startswith'”错误？

我一直在努力进行 redbeat 设置并使用我的 Flask 应用程序，但我似乎无法让它正确启动。当我运行命令时 celery -A celery_config.celerybeat --scheduler redbeat.

python flask celery celerybeat

回答 1 投票 0

如何在异步RestAPI中等待Celery任务结果？

我有一个使用 FastAPI 构建的 API，该端点将任务提交给 celery 工作人员，等待工作人员完成其工作并将结果返回给用户。问题是等待

python redis celery python-asyncio fastapi

回答 1 投票 0

Celery：使用 kombu 在任务（和客户端）之间进行通信

这让我有些沮丧，并且由于缺乏内部的 Celery 文档而花费了我大量的时间进行研究和逆向工程。这里有一个漂亮的教程： https://ask.github.io/

python django celery messaging kombu

回答 1 投票 0

用 Celery 构造日志

我有一个可用的芹菜应用程序。我想向其中添加结构化日志记录。很难提供完整的工作示例，所以让我演示一下：导入结构日志导入日志记录日志记录.config.dictC...

python celery structlog

回答 1 投票 0

Celery 工作容器在出现 MemoryError 后永远不会重新启动

我在生产机器上遇到了这个恼人的问题，我的芹菜容器有一个 docker 容器，配置如下：工人：建造：。环境文件： -.env 命令：

python docker docker-compose celery out-of-memory

回答 1 投票 0

celery 任务的正确类型注释

我正在寻找正确的类型注释来归因于已由 celery @task 装饰器设置的 celery 任务。假设我有一个函数 run_task 接受一些 celery 任务。 @任务（...

python celery python-typing

回答 1 投票 0

通过 Django 中的 celery Worker 停止当前正在运行的任务

我有一个 Django 应用程序和 React 作为我的前端框架，我使用 celery 来运行冗长的任务，这确实需要很多时间，但一切都工作正常。我还提供真实的...

django celery django-celery celery-task

回答 2 投票 0

从 celery 工作线程到 prometheus 的自定义指标

我有一些 celery 工作人员在 kubernetes 下的容器中运行。它们不会由 celery 自动缩放，并且每个都在单个进程中运行（即没有多处理）。我想要一堆不同的...

django kubernetes celery prometheus

回答 2 投票 0

当消息到达共享 RabbitMQ 队列时，KEDA ScaledObject 无法扩展多个 pod

我有以下情况：我有一个 Kubernetes 集群，其中有一个使用 RabbitMQ 进行通信的 Celery 应用程序。我有一个包含 Celery 任务的 pod，但有 3 个不同的

kubernetes triggers rabbitmq celery keda

回答 1 投票 0

Celery 命名任务执行并通过名称获取任务执行

我有一个名为 my_task 的 Celery 任务。我通过多次调用 my_task.delay() 创建任务的多次执行。我想为每次执行赋予一个唯一的标签/名称，并且能够获得...

python celery django-celery

回答 1 投票 0

如何在 celery 任务之外（在 django 视图内）登录 celery 日志？

假设 django 项目中有一个端点 def my_view(请求, my_id): 如果 is_request_valid(请求): logger =logging.getLogger('celery.task') logger.info('正在启动一个任务...

python django logging celery python-logging

回答 1 投票 0

优雅退出ForkPoolWorker中的celery任务

我的任务的简化版本：对于 _ 在范围内（100000）： # 检查worker是否没有关闭 # 如果是，则优雅退出 # 否则，做点什么。我尝试使用它来处理

celery

回答 1 投票 0

优雅地停止芹菜任务

我想优雅地退出 celery 任务（即不是通过调用 revoke(celery_task_id, Terminate=True)）。我想我应该向设置标志的任务发送一条消息，以便任务函数可以返回...

python celery django-celery celery-task

回答 2 投票 0

celery 相关问题

最新问题