celery 相关问题

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

我运行了python celery项目，遵循以下文档：http：//celery.readthedocs.org/ LAYOUT：celery_folder / celeryServer.py #server处理http请求celery_folder / ...

python celery

回答 1 投票 0

Celery python同步任务

在我的应用程序中，我有连接到其他API的python芹菜任务..简单。我遇到的问题是API不允许多个resuests使用相同的凭据。有没有办法......

python celery celery-task

回答 1 投票 0

如何从Flask向Celery工作人员发送中断？

问题我已经阅读了一些关于从Flask应用程序访问Celery工作人员状态的信息，就像在本教程中一样，但你可以采取其他方式吗？发送中断或对芹菜进行反省......

python flask signals celery interrupt

回答 1 投票 0

什么时候应该重新开始芹菜？

我使用芹菜来处理异步任务。我明白当我更新这些任务中的代码时，或者当我想注册一个新任务时，我必须重新启动芹菜以查看...的反映

django celery

回答 1 投票 0

在Celery终端完成工作，但`task.ready（）`返回false（Django）

我在芹菜中有以下任务：@shared_task def convert_to（audio_file_pk）：file_obj = AudioFile.objects.get（pk = audio_file_pk）print（“Tsk Run：Returning {}”。format（file_obj.audio_file ....

django asynchronous celery task-queue background-task

回答 1 投票 0

Django Celery收到类型为“appname.tasks.add”的未注册任务

python django celery

回答 1 投票 3

芹菜工人并发

我已经制作了一个刮刀来扫描150个链接。每个链接都有大约5k个子链接来获取信息。我正在使用Celery在后台运行刮刀并将数据存储在Django ORM上。我用 ...

python django celery

回答 1 投票 1

为什么芹菜会给rabbitmq添加数千个队列，这些队列在任务完成后似乎会持续很长时间？

我正在使用带有rabbitmq后端的芹菜。在Rabbitmq中生成数千个队列，其中包含0或1个项目，如下所示：$ sudo rabbitmqctl list_queues列出队列......

rabbitmq celery

回答 2 投票 17

Python + Celery：防止重复的任务执行

如何防止同时执行两个或多个相同的任务？例如：如果我有一个名为do_stuff的任务和一个调用它的程序，它应该只在没有...时执行。

python celery

回答 1 投票 1

适用于Django中的Message Queue / Scheduled任务的方法

我想知道当我们需要在django项目中使用某种任务队列时需要考虑什么标准，我正在考虑性能，开发速度，灵活性等等。我一直......

python django celery mq

回答 1 投票 7

如何在出现OperationalErrors时重试所有芹菜任务？

偶尔重新启动postgres时，由于OperationalErrors，我从Celery那里得到了大量错误。例如：文件“/var/www/.virtualenvs/xxx/local/lib/python2.7/site-packages/django/db / ...

python django postgresql celery

回答 1 投票 0

有人可以解释花的平均负荷吗？

我使用花来监控我的rabbitmq队列，我无法理解如何计算负载平均值，如果有人可以解释那将会有很大的帮助。我有一个四核处理器。谢谢。

rabbitmq celery flower

回答 1 投票 4

使用sqlalchemy会话的Celery子任务会引发UnboundExecutionError

我有一个芹菜任务，触发了它下面的一些子任务。它运行那些非同步的子任务。 @shared_task def task_update_all_customers（customer_ids =（））：job = group（...

python sqlalchemy celery

回答 1 投票 0

Celery：如何将worker和client分成不同的服务器

我使用Django作为网络服务器，当Django收到请求时，redis作为代理，它启动了一个异步任务，这个任务可能花费10个小时，所以我使用了Celery。我的目标是：一台服务器，称之为服务器1，......

python celery django-celery

回答 1 投票 0

芹菜| Flask错误：预期AsyncResult找到一个类似字节的对象

我目前正在研究一个烧瓶应用程序（Python 3.6），并希望集成芹菜，因为我有多个长时间运行的后台任务。编辑：芹菜4.1整合没问题，......

python flask celery typeerror celery-task

回答 1 投票 0

如果params和任务名称已在服务器中排队，是否可以跳过委托芹菜任务？

假设我有这个任务：def do_stuff_for_some_time（some_id）：e = Model.objects.get（id = some_id）e.domanystuff（）我正在使用它：do_stuff_for_some_time.apply_async（args = [some_id] ,. ..

python django rabbitmq celery

回答 3 投票 10

Django模型上的芹菜任务

我正在尝试学习如何使用芹菜来检查我的一个模特每天的日期。我的一个模型包含一个到期日期和一个布尔字段，表明他们的保险是否已过期。 ...

django celery celery-task celerybeat

回答 1 投票 3

无法使用芹菜启用SSL

我有芹菜的Django应用程序，工作正常。 app = Celery（'backend'，broker ='amqp：// guest：guest @ localhost：5672 //'，）然后我尝试使用SSL加密连接：app = Celery（'backend'，...

python python-3.x celery

回答 2 投票 1

如何在virtualenv中为Celery（django-celery）编写Ubuntu Upstart工作

我真的很喜欢使用暴发户。我目前有很多新手工作，可以在许多版本中运行不同的gunicorn实例。但是，我在Celery新贵脚本上发现的2-3个例子......