celery 相关问题

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

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

使用 systemd 的 celery 守护进程未运行

我正在使用 ubuntu 16 和 systemd 将 celery 作为守护进程运行。我也创建了单元文件,但我无法将 celery 作为服务运行。为什么会出现这个错误? /etc/systemd/system/celery.service...

回答 2 投票 0

Celery 和 Django - 主进程是否等待任务完成?

我刚刚开始开发一个使用 Django 和 Celery 的项目。我对两者都很陌生。其中一个端点的代码如下所示: task_do_something.delay() 返回响应( ...

回答 1 投票 0

Celery 中的永久任务?

我正在构建一个 django 应用程序,在其中使用相机捕获图像、分析图像、将元数据和分析结果存储在数据库中,最后将数据呈现给用户。 我正在考虑使用

回答 2 投票 0

Celery 未接收在后台运行的任务

我在设置 celery 与我的 Flask 应用程序一起使用时遇到问题。我使用了准系统应用程序来测试配置,发现我的 celery 工作程序已启动,但没有获取任何任务...

回答 2 投票 0

Celery Beat 无法连接到 Rabbitmq 容器

我的 celery Beat docker 容器(据我认为)连接消息代理时出现问题。 我有一个正在运行的 RabbitMQ 容器: .... 兔子MQ: 图片:rabbitmq:3.11.13-management-alpine

回答 1 投票 0

将文件存储到 S3 在 Celery 工作线程中不起作用

我面临着从 django 的 celery 任务将文件存储在 S3 中的问题。我正在做以下事情 从数据库获取数据 使用 BytesIO 创建 XLSX 文件 使用 Dja 的 file.save 方法存储该文件...

回答 1 投票 0

RedBeatScheduler 发送新任务,但 celery-worker 没有收到它们

如果 celery-worker 有大约 10-15 个任务,那么它会停止处理来自 RedBeatScheduler 的新任务,这些新任务是在工作期间动态创建的。但是,如果任务少于 10 个,那么他们...

回答 1 投票 0

django celery [celery.worker] 调试:定时器唤醒!运行 scrapy 进程时的下一个预计到达时间

我正在 Django 中使用 celery 在 task.py 文件中运行一个简单的蜘蛛。运行我的蜘蛛的代码如下: 文件任务.py: @shared_task(绑定=True) def scrape_amazon_products(self,products_urls,

回答 1 投票 0

在 Python 中将 WebSocket 与 Celery 和 FastAPI 集成

我正在将 WebSocket 与 Python 中的 Celery 和 FastAPI 集成,但面临 AttributeError 和 EncodeError 等问题。需要帮助解决这些错误以实现无缝集成。任何建议或指导...

回答 1 投票 0

如何更改 django celery 配置中的“传输”url

我有django 3.2.7,celery 5.2.1,redis 3.5.3 我有下一个芹菜设置。 (REDIS_PASSWORD) 是环境变量: CELERY_BROKER_URL = f'redis://:{REDIS_PASSWORD}@redis:6379/4' CELERY_BROKER_TRANSPORT_O...

回答 3 投票 0

Celery 单元测试重试

我目前正在为我的芹菜任务编写单元测试,并想测试我的任务是否正在重试。 注意:ALWAYS_EAGER 在测试设置中设置为 True @app.shared_task(bind=True, soft_time_...

回答 1 投票 0

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