celery 相关问题

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

芹菜未能在码头工人开始

我正在使用以下Dockerfile启动芹菜:FROM python:3.7-alpine RUN apk add --no-cache postgresql-libs && \ apk add --no-cache gcc musl-dev postgresql-dev zlib-dev jpeg-dev& ...

回答 1 投票 2

在单元测试中修补时,Celery任务调用的函数没有调用?

考虑以下tasks.py模块(改编自http://docs.celeryproject.org/en/latest/getting-started/first-steps-with-celery.html#first-steps):从celery import导入日志导入系统...

回答 1 投票 1

一些Celery任务有效,另一些则是NotRegistered

我按照Celery Django教程和我在示例中看到的任务(add,mul)完美地为我工作。当我执行res = add.delay(1,2)时,我得到正确的响应; res.get()。但我得到*** ......

回答 3 投票 9

使用Django / virtualenv运行芹菜时找不到'__main__'模块

Debian 9.8 virtualenv 16.4.3 Python 3.5.3 Django 2.1.7芹菜4.3.0 django-celery-beat 1.4.0当我从我的app目录运行celery命令时,我的venv活动就像芹菜工人-A人员或......

回答 1 投票 0

申请,运行和调用芹菜任务有什么区别?

mytask.apply(),mytask.run()和mytask()有什么区别?哪种方式更可取?

回答 2 投票 2

芹菜中未处理的异常冻结了工人

我通过redis后端在docker中运行芹菜。我有celery-beat容器芹菜工人容器redis容器芹菜工人容器产生6个工人进程。如果是芹菜任务......

回答 1 投票 0

Celery:为什么它的分布式任务比多处理运行得慢?

我的电脑有16个CPU内核,并试图比较时间来完成芹菜和多处理之间的任务这里是实验(update_daily_price是抓取一些股票每日价格数据的方法......

回答 2 投票 0

Django,Celery:检索异步生成的文件

我有一个页面(foo.com/process),您可以在其中生成数据报告。有时需要生成的数据量很大,因此需要一段时间。因此,我做了一个Celery任务来处理......

回答 1 投票 0

Django + Celery有长期计划任务

我正在开发一个Django应用程序,它严重依赖于Celery任务调度,使用Redis作为后端。可以将任务设置为在很长一段时间内运行,也可以在几秒/分钟内运行。我读了 ...

回答 1 投票 1

从Redis后端删除所有Celery结果

在Celery中是否有任何方法可以通过命令行删除所有以前的任务结果?我能找到的所有内容都引用了清除,但这似乎并不适用于任务结果。我找到的其他解决方案......

回答 1 投票 1

开始芹菜工作者作为守护进程

我正在尝试建立芹菜来生产。我一直按照这里的说明进行操作:https://www.linode.com/docs/development/python/task-queue-celery-rabbitmq/#start-the-workers-as-daemons ...

回答 1 投票 0

使用PHP的Celery?

我正在构建一个基于队列的系统来扩展用户上传的图像。用户将上传将传输到存储服务器的图像。然后,Web服务器将向队列添加消息,该队列将...

回答 2 投票 2

如何在Django模型中从PDF中提取和保存文件

我正在开发一个项目,需要提取附加到模型的PDF。然后PDF与项目相关,如下面的models.py:class Project(models.Model):name = models ....

回答 1 投票 0

如何将在tasks.py之外定义的函数转换为Celery任务,并使Celery工作程序在Django中处理它

我试图在我的Django项目中使用Celery说“MySite”。我的目录结构如下mysite - applications - api -tasks.py -urls.py -apps.py -__init__.py ...

回答 1 投票 2

如何动态添加/删除周期性任务到芹菜(celerybeat)

如果我有一个定义如下的函数:def add(x,y):return x + y有没有办法动态添加这个函数作为芹菜PeriodicTask并在运行时启动它?我希望能做到......

回答 5 投票 41

在RESTful Route中触发Celery任务

我想为我的Celery任务设置一条路线并监控它们。这是我在我的烧瓶应用程序中运行的代码:localhost:5000 background.py任务:@ celery.task(queue ='cache')def ...

回答 2 投票 1

django芹菜 - 任务通过django管理员

我正在尝试用django建立芹菜。所有设置都已设置,如果我开始任务manuelly它正在工作。 (所有发生在我的本地开发服务器上)mytask.apply_async()然后我尝试设置...

回答 1 投票 1

RuntimeError:使用celery进行并发poll()调用

在从其他容器接收rest API的Docker容器上运行Celery时,我得到一个RuntimeError:concurrent poll()调用。有没有人面临类似的错误?我附上了追溯。 ...

回答 2 投票 3

是否有可能等到芹菜组完成?

我正在尝试执行组任务并等待所有组子任务完成然后运行最后一个任务。但是当我调用任务时,它会调用组和上一个任务,但最后一个任务在组完成之前完成。 ...

回答 1 投票 1

检索Celery中队列中的任务列表

如何检索队列中尚未处理的任务列表?

回答 12 投票 115

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