celery 相关问题

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

Python celery - 如何等待和弦中的所有子任务

我正在对 celery 任务进行单元测试。 我的连锁任务也有组,所以产生了一个和弦。 测试应该如下所示: 运行 celery 任务(延迟) 等待任务和所有子任务 断言 我尝试...

回答 3 投票 0

在 Celery 任务中运行 Scrapy 蜘蛛

这不再起作用了,scrapy 的 API 已经改变了。 现在文档提供了一种“从脚本运行 Scrapy”的方法,但我收到了 ReactorNotRestartable 错误。 我的任务: 从芹菜进口Ta...

回答 5 投票 0

Celery 登录文件

有人可以帮忙告诉我如何将 celery 任务调试详细信息保存到日志文件中吗?我需要将 celery 任务的详细信息记录到 .log 文件中。 你能做一些吗

回答 2 投票 0

如何在 celery 中测试 on_failure

我的 celery 任务有一个基类,其中实现了 on_failure 方法。 在我的测试中,我修补了任务调用的方法之一,以引发异常,但 on_faliure 从未被调用。

回答 2 投票 0

如何使用配置文件运行celeryflower?

对于我的项目。我想使用花配置文件而不是使用命令行选项。 但我写了一个名为flowerconfig.py的文件,如下所示: # RabbitMQ 管理 Broker_api = 'http://用户:passwd@

回答 1 投票 0

Celery 任务始终待处理

我尝试在 Windows 上使用 Redis 后端运行 Celery 示例。代码如下: 从芹菜进口芹菜 应用程序 = Celery('risktools.distributed.celery_tasks', backend='redis://localhos...

回答 6 投票 0

无法在 celery/arq 任务中使用 ODM beanie API

当任务代码中有对beanie文档的操作时,会抛出beanie.exceptions.CollectionWasNotInitialized错误。 如果相同的函数被称为 ordi,那么一切都会正常工作......

回答 2 投票 0

芹菜花送给不知名的工人

我正在使用 celery 和 redis 后端。 我将 CELERY_RESULT_BACKEND 与正确的 redis url 以及代理 url 传递到 Celery 应用程序配置。 我通过给我的芹菜路径来开始开花......

回答 2 投票 0

调用长时间运行的端点时,远程从 docker 上的 celery 任务断开连接

我有一个在 docker-compose 上运行的 Django 应用程序。在我的一项后台 celery 任务中,我正在调用 Cloud Run 端点。此端点需要很长时间才能完成:60-80 秒。 芹菜...

回答 1 投票 0

Celery:忽略配置文件中的 BROKER_URL

我的问题与此问题重复,但更详细。 问题是我在 Celery 配置文件中设置了 BROKER_URL,但这没有反映在我正在加载配置中:我检查过,...

回答 4 投票 0

Celery 的过期选项不起作用

我正在玩 Celery,我正在尝试使用 CELERYBEAT_SCHEDULER 执行定期任务。这是我的配置: CELERY_TIMEZONE = '欧洲/基辅' CELERYBEAT_SCHEDULE = { '永远运行任务...

回答 3 投票 0

Celery + SQS - 使用“queue_name_prefix”写入错误的队列

我正在尝试使用 SQS 作为代理来设置 Celery 任务。我能够使用以下命令使其工作(最小可重现): 从芹菜进口芹菜 应用程序 = Celery('任务', 经纪人=f'sqs://{

回答 2 投票 0

django errno 104 连接被对等方重置

我正在尝试在 AWS EC2 上的 Ubuntu 实例上运行我的 django 服务器。我正在使用 Gunicorn 来运行服务器,如下所示: Gunicorn --workers 4 --bind 127.0.0.1:8000 woc.wsgi:application --name woc-s...

回答 2 投票 0

python3.11 + Celery + Gevent ->“返回NULL而不设置异常”

当使用 python3.11 并以 Redis 作为代理在容器上运行 celery Worker 时 - 我收到以下异常。 降级到python 3.10解决了问题,但是还有其他解决方案吗?

回答 1 投票 0

如何在 CELERYBEAT_SCHEDULE 配置中设置优先级?

在我的 Django 应用程序中,我尝试将 Celerybeat 任务的优先级值设置为 6,但下面的方法不起作用。设置这个值的正确方法是什么?我在此配置中还有其他任务,并且想要...

回答 1 投票 0

Flask 和 Celery FileUpload 返回 BufferedRandom 错误

我正在尝试进行简单的文件上传并收到错误: kombu.exceptions.EncodeError:FileStorage 类型的对象不可 JSON 序列化 我的代码: @flask_app.post('/上传') def upload_post(): ...

回答 1 投票 0

JavaScript 异步/等待轮询以获取状态 - 函数未返回正确的数据

Context:Django 中使用 Celery 和 Redis 的异步任务管理。 我有一个在 Ajax 中发送 POST 请求的函数。服务器返回一个任务id。 使用任务 ID,我启动另一个功能...

回答 2 投票 0

Dash 应用程序后台回调在添加到 Celery 时未运行

我正在尝试从 Dash 后台回调中获取示例 4 以使其工作 https://dash.plotly.com/background-callbacks。 我有一个在 Docker 容器中运行的 Redis 代理,我正在使用它进行连接

回答 2 投票 0

Celery send_task() 方法

我有我的API,一些端点需要将请求转发到Celery。想法是拥有特定的 API 服务,基本上只实例化 Celery 客户端并使用 send_task() 方法,并单独的...

回答 2 投票 0

Celery:未配置结果后端

我正在尝试使用 Celery 从学校大学网站异步抓取课程注册信息。最终,我想构建一些东西,如果

回答 1 投票 0

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