celery 相关问题

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

是否可以使用外部 API 创建和编辑 Celery 计划的任务?

我想开发一个系统,允许最终用户通过一个应该集成到现有软件中的界面来创建、编辑和删除数据管道。这些数据管道

回答 0 投票 0

调用 update_state 后无法从 celery 任务的状态/信息中获取元数据(当前总计)

我正在用 Django 构建一个 Web 应用程序。我需要显示一个进度条。 为了跟踪 celery 任务中的进度,我将 ajax 调用传递给后端,其中包含...

回答 1 投票 0

Python异步并发对象问题使用Celery模块,报错

我正在使用 Celery 模块运行异步并发对象,但是当我使用 LetView.delay() 调用该函数时,会报错 Celery 函数代码 ChatGPT 帮助代码是你...

回答 0 投票 0

Telnet 连接被 docker 拒绝

我正在尝试在我的 docker flask 项目中使用 telnet 来使用 rdb 调试 celery 任务。 为此,我在我的 dockerfile 中安装了 telnet,然后为了测试它我使用:docker-compose exec web bash, web being

回答 0 投票 0

Celery KeyError: 'tasks.add' when trying to run a simple task

我正在尝试使用 EC2 实例上的 Redis 作为代理运行一个简单的 Celery 任务,并从我的本地机器连接到它,但是当 Celery 工作人员尝试执行时我遇到了一个错误...

回答 0 投票 0

具有干净架构的python celery

我正在学习并尝试使用干净的架构开发一个 python 项目。以下是项目结构如下: - 项目/ - entities/ # 包含实体,例如 User, user.py - 用例/...

回答 0 投票 0

尽管已注册,但芹菜任务未在 docker 容器中执行?

我在同一个容器中运行 flask + celery + redis。 # Dockerfile 来自蟒蛇:3.10.5 工作目录/应用程序 # 复制所有内容到/app 复制 。 . 运行 pip install -r requirements.txt # 运行两个 cele...

回答 0 投票 0

Celery 的任务 ETA 不准确

我正在使用 Celery 和 eta 功能。根据文档,不能保证任务会在 ETA 的确切时间执行,但会在这之后的某个时间执行。 我发现与...有明显的滞后

回答 1 投票 0

Python导入和celery worker

我有以下目录结构: . └── 包 ├── 富 │ ├── __init__.py │ └── foo.py ├── 运行.py └── 任务.py foo/foo.py 类富: @静态方法 定义双(x): ...

回答 1 投票 0

face_recognition 抛出 CUDA 异常,但仅在 Celery 任务中

我有一个 face_recognition 任务,它是一个更大的 Django 4.1 站点的一部分,人脸识别任务在 celery 和 redis 中运行。在过去的几年里,它在旧版本上运行没有任何问题......

回答 0 投票 0

Celery Task (Docker) - 我们无法从表中获取新插入的数据?

Celery Task (Docker) - 我们无法从表中获取新插入的数据。

回答 0 投票 0

celery postgres 后端不存储重试次数

上下文 失败的任务按预期重试 postgresql 后端不存储失败任务的重试次数 测试 这些返回无, AsyncResult(task_id='some_taskid', app=app).retries 选择...

回答 0 投票 0

如何在 Django 中更新 Celery 任务的状态?

朋友们有一个问题:我想在Django中更新celery的任务状态。我想要的一个例子: 1-在任务中创建一个任务,比如从多个文本文件中提取数字: @shared_tas ...

回答 0 投票 0

关于构建 docker image level=error msg="Can't close tar writer: io: read/write on closed pipe"

time="2017-10-27T07:39:20Z" level=error msg="无法将文件 /var/app/current/app/content_classifier/forest.pickle 添加到 tar:io:读/写封闭管道” time="2017-10-27T07:39:20Z" level=错误信息...

回答 10 投票 0

Celery 找不到我的 django 模块

当我尝试使用命令 celery -A blogger.celery worker 启动 celery 时,我遇到了以下错误。我从我的包目录运行命令,我有我的 celery.py

回答 0 投票 0

尝试将 CloudAMQP 与 Flask 和 Celery 一起使用时出现连接被拒绝错误:如何解决?

我在使用 Flask 和 Celery 连接到我的 CloudAMQP 实例时遇到问题。我在 https://api.cloudamqp.com/console/ 创建了一个免费帐户并设置了以下 Flask 配置: 来自芹菜

回答 0 投票 0

向 RabbitMQ 消息队列添加任务时出现 Django 芹菜错误:AttributeError: 'ChannelPromise' object has no attribute '__value__'

我在 digitalocean 上设置了 celery、rabbitmq 和 django 网络服务器。 RabbitMQ 在我的 Django 应用程序未运行的另一台服务器上运行。 当我尝试使用延迟将任务添加到队列时,我...

回答 2 投票 0

如何在FastAPI中将花端口5556映射到enpoint?

我有一个简单的 FastAPI 应用程序。我使用 celery 进行异步任务处理,使用 flower dashboard 监控任务 我的主要应用程序在端口 80 上运行 我的任务监控花仪表盘是

回答 0 投票 0

如何获取芹菜中任务的持续时间?

我想测量芹菜中的任务运行时间。 我知道我们可以使用时间作为开始时间和结束时间。 然后得到持续时间。 但我想使用内置芹菜。 例如在这个 URL 中我们有任务事件:

回答 0 投票 0

如何安排任务在特定时间每n分钟运行一次(celery-django)

在django中使用celerybeat时,我想安排一个任务在特定时间启动,然后每5分钟运行一次。我能够让任务每 5 分钟运行一次,使用 crontab(min...

回答 2 投票 0

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