芹菜没有发现项目内部的任务
我有一个项目 myproject 和一个应用程序 app 。 在myproject内部，我有 tasks.py from celery import shared_task @shared_task def add(x, y): retur…
未在服务Docker-Compose.yml中指定卷
Docker版本20.10.17，Build 100C701 我有一个VITE，VUE 3前端和Django后端，带有Postgres数据库，芹菜和Redis。 当我不包含API和芹菜服务Docker组成的…
指定将数据存储在Rabbitmq消息队列中的格式
我将RabbitMQ用作消息经纪和芹菜作为任务队列来处理我的队列内容。让我们以一个基本示例，要添加两个数字x和y。 我已经创建了共享任务为： tasks.py f…
工人跑步时，如何将带有时间表的任务发送给芹菜？
我有问题创建和添加节拍计划任务到芹菜工人并运行该芹菜工人当前运行 良好时，这是我的代码， from celery import Celery from celery.schedules impo…
芹菜任务未在Docker-Compose中运行
我有一个码头组合，那里有三个组成部分：应用程序，芹菜和雷迪斯。这些是在djangorest中实现的。 我已经在Stackoverflow上几次看到了这个问题，并尝试…
RABBITMQ：在使用芹菜处理任务时，如何检查队列内容？
我已经在我的Django应用中使用RabbitMQ和芹菜设置了一个基本消息和任务队列。根据我的理解，当我使用延迟Menthod时，将我的任务推到Rabbitmq队列，而…
DJANGO芹菜错误在将任务添加到RabbitMQ消息队列：attributeError：＆＃x27; channelpromise＆＃x27;对象没有属性＆＃x27; __值__＆＃x27;
我在Digitalocean上设置了芹菜，RabbitMQ和Django Web服务器。 RabbitMQ在我的Django应用程序未运行的另一台服务器上运行。 当我尝试使用延迟将任务添…
如何确定芹菜任务的名称？
我有一个fastapi应用，我想调用芹菜任务 我无法在两个不同的代码库中导入任务。因此，我必须使用其名称称呼它。 任务 imagery = Celery( "imagery", b…
如何将日志从远程调用，停泊的芹菜工人返回到气流容器
我正在开发一个dockerized Python/Django项目，其中包括一个用于芹菜工人的容器，我一直在其中集成了现成的气流码头容器。 我的气流通过使用REDIS代理…
如何为芹菜和普罗米修斯生成自定义应用指标/监控
我正在尝试在芹菜中生成自定义应用程序指标，并将其拉入普罗米修斯。我正在使用 danihodovic/celery-exporter 导出芹菜任务指标，这些是开箱即用。但…
芹菜＆＃x2B; REDIS如何基于最低时间戳以相同的优先级运行任务
我已经在芹菜中定义了一个任务，并使用烧瓶框架被称为。我看到芹菜能够在工作节点上执行任务。现在可以说，一些API以这种方式称为任务。 timestamp, t…
