celery 相关问题

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

Docker - Celery无法连接到redis

项目结构：客户端nginx web / celery_worker.py项目config.py api /我在docker-compose中有以下服务：版本：'3.6'服务：web：build：...

docker redis docker-compose celery

回答 1 投票 0

重新加载芹菜击败配置

我正在使用没有Django的芹菜和芹菜，我有一个任务需要在运行时修改芹菜节拍时间表。现在我有以下代码（模块名为celery_tasks）：＃__ init__.py from ...

python celery celerybeat

回答 2 投票 -1

安装redis时缺少redis库

我安装了redis和celery python库。我安装并运行了redis服务器。使用bash我可以运行python并导入redis而不会出错。我安装了python-celery-common。我是 ...

python redis pycharm celery windows-subsystem-for-linux

回答 1 投票 0

将参数传递给自定义芹菜任务

我只是想知道将参数传递给自定义任务装饰器的正确方法是什么。例如，我发现我可以将celery任务子类化如下：class MyTask（celery.Task）：def ...

python arguments task celery subclass

回答 1 投票 1

用户在上次刷新Django / Celery后9天安排任务

这是在为用户刷新访问令牌的上下文中。假设我们有函数refresh_user_token，它以用户身份接收CustomUser对象。 def refresh_user_token（user）：...... ......

python django celery django-celery django-cron

回答 1 投票 -1

app-celery：ERROR（没有这样的文件）

我已经按照教程了解如何使用supervisor在我的django生产服务器上实现芹菜。我成功完成了这项工作，但是当我尝试使用sudo supervisorctl启动主管时......

python django celery supervisord

回答 1 投票 0

Docker - 没有名为'celery_worker'的模块

我试图在docker中构建芹菜容器，如下所示：celery：image：dev3_web restart：always volumes： - ./services/web:/usr/src/app - ./services/web/logs:/usr/src / app ...

docker celery

回答 1 投票 0

如何修复接收未注册的任务错误 - 芹菜

我正在尝试使用Ubuntu 16.04在Azure VM上使用Celain（4.2.0）和运行Python 3.7.2的RabbitMQ（3.7.14）建立周期性任务。我能够开始节拍和工作，看到......

python linux rabbitmq celery

回答 1 投票 0

如何在Django中运行@classmethod作为Celery任务？

如何在Django中运行@classmethod作为Celery任务？下面是示例代码：class Notification（TimeStampedModel）：.... @ classmethod def send_sms（cls，message，phone，user_obj = None，test = ...

python django celery

回答 1 投票 1

需要升级helm chart而不删除已经运行的pod

我有几个芹菜工人在minikube上运行，他们正在处理使用rabbitMQ传递的任务。最近我更新了一些芹菜工人的代码并改变了图像。当我做 ...

kubernetes celery kubernetes-helm

回答 1 投票 0

芹菜任务工作者不在生产中更新

我在EC2实例上建立了一个django项目，SQS作为芹菜的经纪人，通过Supervisord运行。当我更新任务的参数参数时，问题就开始了。在调用任务时，......

django celery amazon-sqs production-environment

回答 1 投票 0

芹菜捶打开始时运行芹菜任务

当我在1小时左右再次开始芹菜打败时，如何安排任务运行。目前我在settings.py中有计划：CELERYBEAT_SCHEDULE = {'update_database'：{'task'：'...

django celery

回答 2 投票 0

芹菜与RabbitMQ：AttributeError：'DisabledBackend'对象没有属性'_get_task_meta_for'

我正在使用Celery Tutorial运行第一步。我们定义了以下任务：来自celery import Celery app = Celery（'tasks'，broker ='amqp：// guest @ localhost //'）@ app.task def add（x，y）：...

python celery

回答 5 投票 52

如何在工作人员关闭时向正在运行的任务发送消息？

我的任务可能需要数小时才能完成。但是，可以通过在memcached中设置标志来尽快清除退出。该任务定期轮询该标志，当它被发现任务时......

celery

回答 1 投票 0

芹菜警告“收到并删除了未知消息”

我正在Celery中设置一个任务，让它从某个主题交换中“消费”。当我将消息发送到有问题的交换机时，我收到错误：“收到并删除了一条未知消息。...

python rabbitmq celery message-queue messagebroker

回答 1 投票 2

CELERY_ROUTES - 如何根据任务名称进行路由

我正在尝试让芹菜根据任务的名称来路由任务...基本上，我有名为'worker.some_name'和'web.some_name'的任务，我使用了两个不同的队列，名为worker和...

celery

回答 3 投票 5

Mock Celery任务方法apply_async

我创建了一个依赖于其他模块的芹菜任务。我在模型保存方法中延迟了芹菜任务，我想要通过所有没有芹菜的测试用例。以下是我的代码。 def save（self，...

python django unit-testing mocking celery

回答 2 投票 1

启动后立即访问django-celery-results TaskResult

我在Django视图中执行了几个Celery任务（更具体地说，在Django Rest Framework的perform_create方法中）。我想要实现的是立即（即...

python django celery django-celery

回答 1 投票 3

芹菜多工人但只有一名工人

我试图让用户安排一个周期性的任务。我还在一个容器中运行多个芹菜工人。我对该容器的命令看起来像这样：celery worker -c 4 -B -l INFO -A ...

celery celerybeat periodic-task

回答 1 投票 0

Celery任务在从大型数据库中提取数据时中途失败

我在django-rest应用程序中使用celery运行一个定期任务，该应用程序从具有多个表的大型Postgres数据库中提取数据，任务开始很好并且提取一些数据大约50分钟......

django postgresql django-rest-framework celery

回答 1 投票 1

celery 相关问题

最新问题