celery 相关问题

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

与 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如何使用Django ORM？

celery如何使用Django ORM？ Celery 和 django 是不同的进程。但是，Celery 工作人员可以使用 Django 应用程序代码。（ORM、模型..）我认为 celery 进程有 django 应用程序代码。难道是……

django celery django-celery

回答 1 投票 0

带有选择数据库数据的 Celery 周期性任务

我根据数据库中的数据设置发送生日祝福。使用Python和Celery（on_after_configure）。它看起来像这样：从烧瓶导入烧瓶从 celery.schedules 导入 crontab ...

python-3.x celery

回答 1 投票 0

flask celery 抛出错误“url 必须以前导斜杠开头”

我正在尝试使用 Flask 实现 celery，当我运行此命令 celery -A src.celery_worker.celery_appworker --loglevel=debug 来启动 celeryworker 时，它会抛出错误：我不能...

python flask celery flask-restx

回答 1 投票 0

Celery WorkerLostError Worker 过早退出：信号 6 (SIGABRT)

我想让异步工作同步完成。我使用couchbase中数据的id作为redis的key。我再次使用 redis 的值更新 couchbase。运行时效果很好

python asynchronous redis celery couchbase

回答 1 投票 0

celery 正在运行，但没有执行任何任务

带有 Redis 的 Celery 正在运行，但任务未在 FastAPI 中执行命令-redis-服务器- 命令 - celery -A core.celery_app_work worker --loglevel=info -P eventlet - 芹菜花输出...

redis celery fastapi celery-task

回答 2 投票 0

Celery 任务未在 Mac M2 上运行（进程“ForkPoolWorker”退出并显示“信号 11 (SIGSEGV)”）

我在尝试在 Mac M1 计算机上运行 Celery 任务时遇到问题。我收到的错误消息如下：进程已分叉，您无法使用此 CoreFoundation 功能...

django rabbitmq celery apple-m1 task-queue

回答 1 投票 0

celery 相关问题

最新问题