celery 相关问题

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

节拍调度程序不会自动工作,但在手动触发时会工作

我正在学习使用芹菜。我想使用beat 自动化API 触发器。如果我从 shell 手动调用increment_value.delay(),则以下代码有效。但是,它不会自动化。另外,我...

回答 1 投票 0

Celery计划任务中的打印语句没有出现在终端中

当我运行 celery -Atask2.celeryworker -B 时,我希望看到每秒打印“celerytask”。目前没有打印任何内容。为什么这不起作用? 从应用程序导入应用程序 从芹菜进口芹菜...

回答 6 投票 0

使 Django 测试用例数据库对 Celery 可见

当 Django 测试用例运行时,它会创建一个隔离的测试数据库,以便在每个测试完成时回滚数据库写入。我正在尝试使用 Celery 创建集成测试,但我不能

回答 4 投票 0

任务接收但不执行

我正在学习Django。最近我尝试使用芹菜。我面临的问题是任务正在接收但它们没有执行。 设置.py: # Celery 应用程序定义 CELERY_BROKER_UR...

回答 4 投票 0

Django + Celery 中没有名为“project_name”的模块?

调试这个的第二天我必须转向 stackoverflow 我处于边缘。 几个月前我使用 cookiecutter-django 生成我的项目。 项目名 配置/设置/... 源代码/ 应用程序_na...

回答 2 投票 0

当在类中定义方法时,Python Django 无法运行 celery

我是 celery 新手,现在我正在使用它在后台计算 Django 任务。我遇到的问题可以使用下面的类方法来演示,我在其中定义了 3 个函数...

回答 1 投票 0

通知celery任务worker关闭

我使用 celery 2.4.1 和 python 2.6、rabbitmq 后端和 django。我希望如果工作人员关闭,我的任务能够正确清理。据我所知,您无法提供...

回答 2 投票 0

如何防止在数据库中存储芹菜和弦计数器对象

我遇到了一个问题,django_celery_results_chordcounter 表很快就填满了,导致我耗尽了服务器空间。它从几 MB 增长到超过 99 GB。 我已经尝试解决...

回答 1 投票 0

计划的 Celery 任务从 Redis 中丢失

我在 Django 中使用 Celery,并以 Redis 作为代理。 使用 apply_async 中的 eta 参数为将来安排任务。 安排任务后,我可以运行 celery -A MyAppspect

回答 1 投票 0

Python:在 docker 容器上调试和自动重新加载

我的情况是:我正在开发一些docker容器。其中一个容器是 celery 应用程序,它从另一个应用程序获取一些任务并处理这些任务。 当我在容器中工作时...

回答 2 投票 0

在celery任务中访问request或request.user

我正在尝试在 django celery 任务函数中访问 request.user 但由于该函数不接受任何请求实例而无法访问,那么我该如何访问它? @共享任务 def run_ever...

回答 1 投票 0

celery 在 get_scheduler 上击败了 TypeError

尝试使用 Supervisor 设置运行 Python3.5、Django==1.10.2 和 celery==4.0.2 的 Celery,但在 site-packages/celery/beat 上收到此错误 回溯(最近一次调用最后一次): 文件“/home/

回答 2 投票 0

尝试使用 Celery+RabbitMQ 设置优先级队列时出现“PreconditionFailed - 队列的不等价参数‘x-max-priority’”错误

我有 RabbitMQ 设置,有两个队列:低和高。我希望我的芹菜工作人员在消耗低优先级队列的任务之前先消耗高优先级队列的任务。我得到以下信息...

回答 1 投票 0

使用 Celery 和 RabbitMQ 对 Django 项目进行 docker 化时出现问题

我正在尝试使用 Celery 和 RabbitMQ 来 dockerize 我的 Django 项目。我有一个 Docker Compose 文件,但无法使其正常工作。 这是我的 Docker Compose 文件: 服务: 兔子MQ: ...

回答 1 投票 0

Django Pytest 使用rabbitmq 和 celery 给出 Kombu 连接被拒绝[111]

目前我正在使用 pytest、django 和rabbitmq-server 以及 celery 来执行后台任务 然而,我确实注意到,当我运行 pytest 而不在本地计算机上运行服务器时,它会导致很长的

回答 1 投票 0

用 Celery 取消已经执行的任务?

我一直在阅读文档并进行搜索,但似乎找不到直接的答案: 您可以取消已经执行的任务吗? (就像任务已经开始,需要一段时间,完成一半......

回答 9 投票 0

芹菜陷入循环 - 为什么?

我是 celery 和 redis 的新手,我试图理解为什么 celery 有时会陷入循环并不断为一项小工作创建任务。请查看日志。我不确定这是否正常? 我正在使用...

回答 1 投票 0

Scrapy Spider 错误:无法腌制本地对象 'Crawler.__init__.<locals>.<lambda>'

我想在 Celery(版本 5.3.4)任务中运行 Scrapy 蜘蛛(版本 2.10)。此外,我希望我的蜘蛛能够使用多重处理来工作。 我已经定义了一个 CrawlerProcess 类...

回答 1 投票 0

如何从`django_celery_results`中的`TaskResult`模型加载`task_kwargs`?

我正在使用 django_celery_results 来保存一些 celery 任务的结果。每个任务都获取 kwargs 作为输入,最后保存在 TaskResult 的 task_kwargs 字段中。 我无法加载这些...

回答 2 投票 0

如何从另一个模块接收celery任务

我可以成功从我的主应用程序接收芹菜任务 - 但是,我的系统无法从另一个模块接收任务。我在远程 Ubuntu 服务器上使用 celery 的主管。 草稿1是我的...

回答 2 投票 0

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