celery 相关问题

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

无法从 Django Gunicorn 应用程序中的代码读取队列长度,但在控制台中工作正常

以下 get_queue_length 代码将队列长度始终设置为零,但是当我在 Django shell 中运行同一组命令时,它工作正常并给出队列中的对象总数 小鬼...

回答 1 投票 0

处理K8s在完成运行任务之前强行杀死celery pods

我正在 AWS EKS 上使用 Celery Workers 部署 Django 应用程序。我的一切都按预期运行,除了 K8s 在完成正在进行的任务之前继续停止 Celery 工作副本,我也...

回答 1 投票 0

Celery/SQS 错误“没有名为 sqs 的模块”

我无法配置 Celery 以使用 SQS。我按照此链接上的说明进行操作:http://docs.celeryproject.org/en/latest/getting-started/brokers/sqs.html 这是堆栈跟踪。 [2018年02月-...

回答 3 投票 0

psycopg2.OperationalError:SSL SYSCALL 错误:在 Flask/SQLAclemy/Celery + PostgreSQL 应用程序上检测到 EOF

我有一个用 Flask+SQLALchemy+Celery 编写的应用程序,RabbitMQ 作为代理,数据库是 PostgreSQL (PostgreSQL 10.11 (Ubuntu 10.11-1.pgdg16.04+1) on x86_64-pc-linux-gnu,编译通过海湾合作委员会(乌布...

回答 3 投票 0

“CELERY_BEAT_SCHEDULER”配置在 django 设置中不起作用

我在 django 项目设置文件中设置了 CELERY_BEAT_SCHEDULER = "django_celery_beat.schedulers:DatabaseScheduler" 。但它似乎不起作用。 我检查了 celerybeat 日志,发现 ce...

回答 2 投票 0

如何对 Celery 任务进行单元测试?

Celery 文档提到了在 Django 中测试 Celery,但没有解释如果您不使用 Django,如何测试 Celery 任务。你怎么做到这一点?

回答 11 投票 0

Celery 未发现项目内的任务

我有一个项目 myproject 和一个应用程序应用程序。 在我的项目里面我有tasks.py 从芹菜导入共享任务 @共享任务 def 添加(x,y): 返回 x + y 在我的应用程序中,我有以下tasks.py...

回答 1 投票 0

Celery 未发现项目内的任务

我有一个项目 myproject 和一个应用程序应用程序。 在我的项目中我有tasks.py 从芹菜导入共享任务 @共享任务 def 添加(x,y): 返回 x + y 在我的应用程序中,我有以下tasks.py 来自

回答 1 投票 0

为什么单个 celery 任务甚至比 I/O 绑定任务的同步对应任务快得多

我正在学习Python中的并发 我设置了 Celery 运行一个脚本来获取请求 50 次,只需要 0.13 秒就完成了,真的让我惊讶! 当我与普通

回答 1 投票 0

运行时错误:模型类 django_celery_beat.models.SolarSchedule 未声明显式 app_label 并且不在 INSTALLED_APPS 中的应用程序中

我正在使用我的 virtualenv 并在执行 celery -A appbeat -l info -S django 时,始终显示此错误。 RuntimeError:模型类 django_celery_beat.models.SolarSchedule 未声明 exp...

回答 2 投票 0

SSL SYSCALL 错误:使用 postgres 和 Celery 的 Heroku 上的文件描述符错误

我已经在 Heroku 上的 Django 站点上成功使用了 Celery,但它刚刚开始生成下面的错误,这导致它停止运行。看起来 postgres 有问题,但我...

回答 4 投票 0

如何将 Docker Compose Manifest 迁移到 Kubernetes?

上下文 我与 celery 工人和 docker 进行了广泛的合作,但我对 Kubernetes 的了解非常基础。这是我如何在

回答 1 投票 0

芹菜优先不适用

我有这个示例代码: @router.post('/测试') 定义测试(): 对于范围 (0,10) 内的 i: Testy.apply_async([i],优先级=7) 返回“完成” @app.task(绑定=True) def Testy(自我,i): ...

回答 1 投票 0

运行 celery 时出现 Celery 和 Redis 错误

我正在使用 celery 和 redis 制作一个 django 应用程序,它可以异步更新股票价格。我现在正在处理后台任务,芹菜无法正常运行。然后我打开 Redis 服务器...

回答 1 投票 0

与 Nginx、Flask 和 Redis 一起部署时,Celery docker 容器上的空闲高 CPU 使用率

空闲时,Celery docker 容器的 CPU 使用率极高,docker stats 显示高达 600% 使用率。在执行任何任务之前启动容器后立即观察到此行为...

回答 1 投票 0

当我尝试使用 redbeat 在终端中启动 celerybeat 时,为什么会收到“'NoneType'对象没有属性'startswith'”错误?

我一直在努力进行 redbeat 设置并使用我的 Flask 应用程序,但我似乎无法让它正确启动。当我运行命令时 celery -A celery_config.celerybeat --scheduler redbeat.

回答 1 投票 0

如何在异步RestAPI中等待Celery任务结果?

我有一个使用 FastAPI 构建的 API,该端点将任务提交给 celery 工作人员,等待工作人员完成其工作并将结果返回给用户。 问题是等待

回答 1 投票 0

Celery:使用 kombu 在任务(和客户端)之间进行通信

这让我有些沮丧,并且由于缺乏内部的 Celery 文档而花费了我大量的时间进行研究和逆向工程。这里有一个漂亮的教程: https://ask.github.io/

回答 1 投票 0

用 Celery 构造日志

我有一个可用的芹菜应用程序。我想向其中添加结构化日志记录。 很难提供完整的工作示例,所以让我演示一下: 导入结构日志 导入日志记录 日志记录.config.dictC...

回答 1 投票 0

Celery 工作容器在出现 MemoryError 后永远不会重新启动

我在生产机器上遇到了这个恼人的问题,我的芹菜容器有一个 docker 容器,配置如下: 工人: 建造: 。 环境文件: -.env 命令:

回答 1 投票 0

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