celery 相关问题

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

停止 Celery 缓存 Django 模板

我通过 RabbitMQ 代理设置了 Django 3.24、celery 4.4.7 和 celerybeat 2.2.0。 我有一个 celery 任务,它渲染 Django 模板,然后将其发送给许多电子邮件收件人。 ...

回答 1 投票 0

所有其他 celery 任务都失败;好像是“未注册”

我正在使用 celery 运行一个名为“filter”的任务。 我遇到一个奇怪的错误,每个其他任务调用似乎都会导致 celery.exceptions.NotRegistered 异常。 对于每一个其他电话,我的意思是: ...

回答 1 投票 0

在 celery 任务中使用 Django ORM 使用单元测试数据库

在 Django 应用程序中,我有一个运行 Celery 任务的视图。 在 celery 任务中,我使用 Django ORM 对数据库执行一些操作。 我这样称呼我的测试用例: 类 MyViewTestCase(

回答 1 投票 0

Theano 和 Celery:工作人员过早退出:信号 11 (SIGSEGV)

我正在构建一个 Web 应用程序,通过从客户端发送 ajax 请求,开始训练在服务器端使用 theano 实现的神经网络。显然我不想等待...

回答 4 投票 0

WorkerLost 错误:工作人员过早退出:信号 11 (SIGSEGV)

我试图在这里找到答案,但没有得到我想要的答案。 所以我发布了这个问题。 导入nltk 从 nltk.corpus 导入停用词 从 sklearn.decomposition 导入 TruncatedSVD 夫...

回答 2 投票 0

Celery Worker 在使用文件系统作为代理时创建“控制”文件夹

我有一个使用 Celery 和 Redis 后端来管理任务的项目。对于本地开发,我尝试使用文件系统设置 Celery 作为代理而不是 Redis。然而,当我运行 Celery Worker 时,它

回答 1 投票 0

如何从 celery 任务获取实时标准输出?

我有一个 Django 项目,其中我正在使用 celery 运行一些后台任务,我的目标之一是显示正在运行的任务的实时标准输出,以便用户可以看到进度。问题是...

回答 1 投票 0

Celery 如何配置子模块的记录器?

我的理解是 @after_setup_logger.connect 应该允许您附加自定义处理程序。但是,这对我不起作用。 @after_setup_logger.connect def setup_loggers(记录器:lo...

回答 1 投票 0

Celery 队列同时获取多条消息

我正在开发一个基于 docker、Celery 支持的 Python 应用程序,其中功能之一是触发并发送给定数字的文本消息。工作流程如下: 用户上传 CSV

回答 3 投票 0

芹菜任务有没有办法确定工作线程是否正在等待它完成以便可以关闭?

我们有一些运行时间非常长的 celery 任务(不,不幸的是,我们无法将其分割成子任务),但可以完全安全地杀死中间任务。 当我们需要部署新的时,这很糟糕......

回答 1 投票 0

有没有办法在多个进程之间共享 PyTorch 模型而不使用多个副本?

我有一个自定义的 PyTorch 模型,由于当前的使用方式,该模型成为我的应用程序的瓶颈。 该应用程序是一个在 Flask 中构建的 Web 服务器,用于接收 PyTorch 模型的作业提交到

回答 1 投票 0

Docker Celery 配置 - 适用于 Django/React/Redis/Celery 项目。没有出现 Celery 徽标和后台任务日志

我创建了一个项目 github 存储库,其中包含 Docker、Django、React、Redis、Celery: https://github.com/axilaris/dockerize-django-react-celery-redis。我的目标是让芹菜正常工作......

回答 1 投票 0

如何在远程任务中使用 Celery 原语?

我想使用 celery 的工作流程,例如位于另一个系统上的任务的组和和弦。目前使用 send_task() 来执行这些任务,但现在需要对多个任务进行分组

回答 1 投票 0

Django项目的settings.py文件中CELERY_TIMEZONE变量的含义是什么?

我知道USE_TZ=True将UTC中的所有日期时间对象保存在数据库中。在这种情况下,当任务计划定期运行时(例如每 2 天或每周一)使用

回答 1 投票 0

Celery 未提供主机名。恢复为默认“本地主机”

我的 /var/log/celery/w1.log 中有这个 我在这里按照 Celery 的步骤进行操作。 我的 celery.py 中有这个 从 __future__ 导入绝对导入,unicode_literals 导入操作系统 从芹菜进口

回答 2 投票 0

如何优雅地重启celery工人?

在发布新版本以更新工作人员中的代码时,如何优雅地重新启动 celery 工作人员? 编辑: 我想做的就是这样的事情。 Worker 正在运行,可能正在上传 100 M...

回答 10 投票 0

如何在 5.x 中使用自定义名称注册基于 celery 类的任务?

架构:Flask 应用程序在自己的容器中运行,Celery 在自己的容器中运行。消息代理是Redis。顺便说一句,这都是Python。 问题:我不知道如何注册基于类...

回答 1 投票 0

为什么我的Celery配置没有生效?

我正在使用 Celery 5.3.4 运行 Django 应用程序。我使用 Redis 作为代理。 我想配置task_time_limit和task_time_soft_limit选项,但运行时无法让它们生效

回答 1 投票 0

什么是“查找超时”。 Celery + RabbitMQ + Docker 中出现错误,如何解决该问题?

我有一个快速的API应用程序,其中有celery和rabbitmq在docker(compose)中运行。这是撰写配置: 服务: 刮刀: 建造: 上下文:fastapi-scrapers dockerfile:

回答 1 投票 0

django-celery-beat 加载任务,但 celery 工作人员没有收到它

我的芹菜节拍和工作人员一直遇到这些问题,我的芹菜节拍创建任务,但芹菜工作人员没有收到它。我使用elasticmq作为代理 我的芹菜打败了原木 它没有

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.