celery 相关问题

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

Celery 在调度的事件中发送父工作进程的进程 ID,而不是工作进程

我正在开发一个celery监控工具。为此,我正在记录来自 celery.events.receiver.EventReceiver 的事件。 正在发送的数据如下所示(删除了不必要的信息以简化...

回答 1 投票 0

Django / Celery:一个任务如何能够不断地做某事?是否可以为任务设置无限循环?

我目前正在学习 Django 和 Celery。因此,我必须对 Django 项目执行一项功能,为此我使用 Celery:我需要不断检查 Redis 服务器中的列表。 为此,我使用芹菜......

回答 1 投票 0

Celery Worker 在 Docker 中运行时不执行任何写入操作

我不知道如何描述问题,但基本上,我有一个 celery 任务,它执行一些工作并将对象写入数据库。 从 app.celery 导入 celery_app 从 some.models 导入 Thing 小鬼...

回答 1 投票 0

如何在celery任务中同步运行多个celery任务?

我必须设计两个任务,即任务A和任务B,用于通过API调用获取数据,这两个任务应该能够按计划每天在后台运行,但也可以从

回答 1 投票 0

Celery Worker 找不到任务

我将worker与beats结合使用,beats发现一切都很完美,但是一旦beat将任务传递给worker,就会弹出错误:KeyError: 'tasks.cache_popular_posts' 所有信息...

回答 1 投票 0

使用Python、Flask、Celery和Redis,包含多个组的任务无法调用其上有链的子任务

@celery.task(bind=True,ignore_result=False) def process_ml_model_dataset(自身,dataset_serialized,media_serialized,ml_model_serialized,collection_name,n_factor): 如果 n_factor == 1:

回答 1 投票 0

停止 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

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