celery 相关问题

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

调用长时间运行的端点时,远程从 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

Acks_late:celery + redis 代理/后端

我正在查看芹菜代码。一旦任务函数通过(task_trace)运行,acks_late就会被调用。 然而,在 Redis 中,一旦接收到任务(即从 Redis 队列中弹出),RedisWorkerController 就会...

回答 1 投票 0

在 celery 中使用 apply_async() 时,Worker 不消耗任务

我正在尝试在 django 项目之外使用 celery。 我定义一个这样的任务: 从芹菜进口芹菜 应用程序 = Celery('任务') 应用程序.conf.更新( result_backend =“rpc”, 经纪人网址=...

回答 1 投票 0

使用 docker 为 django 项目配置 celery 时出现错误

当我由于某种原因使用 docker compose up 命令启动 docker 容器时,出现此错误: 芹菜工人|用法:芹菜 [选项] 命令 [参数]... 芹菜工人| ...

回答 2 投票 0

Celery 中 app.tasks 如何不同时启动?

经过多次测试和搜索,我没有得到结果,希望您能指导我。 我的代码可以在这个 GitHub 地址上找到。 由于主要代码比较复杂,所以我写了一个简单的...

回答 2 投票 0

“连接池已满,正在丢弃连接”警告 Selenium 在 Django 中的 Celery 任务上

所以我在 Django 上使用 Celery 来安排任务。我的任务之一是使用 Selenium 生成一个驱动程序,用于驱动 Selenium Grid 上的 chrome 节点。 该任务还会生成一个将驱动程序作为参数的线程

回答 2 投票 0

Dash/Plotly - long_callback 在 celery/redis 后端失败

总结 我一直在开发一个使用 long_callback 的 dash 应用程序,并且为了开发,我一直在为我的 long_callback_manager 使用磁盘缓存后端,正如我在这里找到的指南所推荐的:ht...

回答 2 投票 0

Django celery 和主应用程序位于一个核心 cpu vps 服务器上?

我是芹菜新手。我可以在一台核心 cpu vps 服务器上运行 Django celery 和主应用程序吗?我需要每小时从队列中更新网站上的信息,并将其保存在 Radis 缓存中。而且我也...

回答 1 投票 0

celery 功能“reply_to”无法按预期工作

我需要配置芹菜应将任务执行结果放入哪个队列,我使用文档中描述的方式(项目“reply_to”): @app.task(reply_to='export_task') # <= configured

回答 1 投票 0

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