celery 相关问题

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

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

Celery 状态未更新(停留在 PENDING 状态)

我对芹菜相当陌生,但我能够使用芹菜在另一个容器上实现分布式工作。 当尝试检查芹菜工作状态时,即使在任务完成后我也完成了

回答 1 投票 0

如何动态添加计划任务到Celerybeat

使用 Celery ver.3.1.23,我尝试动态地将计划任务添加到 celerybeat 中。我有一名芹菜工人和一名芹菜节拍实例正在运行。 触发标准 celery 任务 y 运行...

回答 4 投票 0

AWS 基础设施对 Celery 和 Redis 的替代是什么?

我的应用程序是用 django f/w 编写的,它使用 celery 和 redis 来执行异步任务。我想根据队列中的消息负载/数量自动缩放工作人员。为此,我想做...

回答 2 投票 0

Celery 任务在 Django 测试中不会抛出异常

我的 Django 测试中包含几个 celery 任务。不幸的是,当通过 .delay() 调用任务时,不会抛出异常。我将 CELERY_ALWAYS_EAGER 设置为 True。 任务.py

回答 3 投票 0

Celery 实时监控和 Django 应用程序

Celery 文档解释了如何设置事件的自定义处理。然而,这种方法似乎不太适用于我的 Django 项目和 celery。 我的 celery.py 文件看起来像 从 __future__ 导入

回答 2 投票 0

Docker 无法运行 Celery 后台任务,Celery 似乎无法正常启动

我创建了一个项目 github 存储库,其中包含 Docker、Django、React、Redis、Celery: https://github.com/axilaris/docker-django-react-celery-redis。我的目标是让芹菜发挥作用,但事实并非如此......

回答 1 投票 0

Celery 问题 - Docker 无法运行 Celery 后台任务,Celery 似乎无法正常启动 - Docker、Django、React、Redis、Celery

我创建了一个项目 github 存储库,其中包含 Docker、Django、React、Redis、Celery: https://github.com/axilaris/docker-django-react-celery-redis。我的目标是让芹菜发挥作用,但事实并非如此......

回答 1 投票 0

@shared_task 装饰器不起作用

问题:当我从自定义文件导入数据时,@shared_task 装饰器不起作用。我的意思是,当我启动 celery 时,@shared_task 下的所有任务都不会出现在任务列表中。 例如,在...

回答 2 投票 0

芹菜和定制消费者

据我所知,Celery 既充当消息的生产者又充当消息的消费者。这不是我想要达到的目标。我希望 Celery 仅充当消费者,根据消息触发某些任务...

回答 4 投票 0

Celery 任务链似乎只运行第一个任务。 Celery 链是如何运作的?

我有一个问题,我认为与此方法的工作原理有关。我正在创建一个由 300 个相当大的任务组成的链,每个任务需要处理很多项目。我创建并异步运行一个 C...

回答 1 投票 0

Celery:如何忽略弦或链中的任务结果?

我正在使用celery,我有几个任务需要按顺序执行。 例如我有这个任务: @celery.task def tprint(字): 打印字 我想做这样的事情: &g...

回答 4 投票 0

为什么celeryworker无法使用docker compose连接到rabbitmq

我正在尝试使用 docker compose 组合我的服务,但我的 celery 和 celerybeat 服务无法与我的rabbitmq 服务连接。 这是 docker-compose.yml 文件中我的rabbitmq服务 拉布...

回答 2 投票 0

将 celery 设置为守护进程服务时出现问题

我已经尝试将芹菜设置为守护进程三天了,但我仍然在努力解决这个问题。每次我启动服务并检查状态时,都会显示以下内容, 文档的 Type=fo...

回答 2 投票 0

从 Celery 中的脚本运行 Scrapy 时出现问题:安装的反应器与请求的不匹配

有很多方法可以从脚本(文档)启动 scrapy 蜘蛛。但是当你在 Celery 中处理它时,它就变得有些复杂了。 我想要的是一个能够启动 scrapy 的函数...

回答 1 投票 0

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