celery-task 相关问题

celery-task是Celery分布式任务队列系统的构建块

Celery - “WorkerLostError:工作人员过早退出:信号 11 (SIGSEGV)”

我正在本地开发一个 Django 应用程序,需要将 CSV 文件作为输入并对文件运行一些分析。 我在本地运行 Celery、RabbitMQ 和 Web 服务器。 当我导入文件时,我看到...

回答 4 投票 0

Celery 设置问题 - 显示而不是执行任务代码

尝试在 Flask 应用程序中运行 Celery 任务时遇到此错误: celery.exceptions.TimeoutError:操作超时。 这是我的配置文件: 从芹菜进口芹菜 导入操作系统 从烧瓶

回答 1 投票 0

Celery 任务完成检查未检查正确的任务

我正在尝试执行一项并行处理多个订单的任务。我用了一个和弦,给前端发了一个和弦id,定期检查任务进度,但是我发的id是ac...

回答 1 投票 0

Celery/Redis 每个任务触发两次 send_email 任务

我有一个 Celery 任务来发送一封电子邮件,但从前一段时间开始,这封电子邮件以相同的主题和正文到达了 2 次。我认为值得一提的是,为了发送电子邮件,我使用 SendGrid。附件...

回答 1 投票 0

如何使用 Celery 让我的 web 应用程序在特定日期的特定时间执行 python 函数?

我正在制作一个存储在谷歌云上的网络应用程序。对于我的后端,我使用 Flask、Python、Celery 和 RabbitMQ。对于我的前端,我使用 React、JavaScript 和 HTML/CSS。我在 VS Code 上编写代码。 我试着制定一个时间表。

回答 1 投票 0

Celery 任务未执行,但工作程序和节拍运行完美

我有一个运行没有问题的应用程序,我最近从 APScheduler 切换到了 Celery。 我已经为其设置了 redis 服务器,并且 celery 任务似乎从外部运行顺利。 我已经开始了...

回答 1 投票 0

为什么 Celery 在调用任务中的子任务链时会死锁?

我正在尝试在 celery 中创建嵌套任务工作流程。基本上我有一个主要任务,首先应该调用一组子任务,等待结果,然后处理它们。接下来它调用一个 ch...

回答 2 投票 0

运行 celery 周期性任务 1 小时,是否需要超过 1 小时,该任务过期吗?

我有一个定期的数据清除任务,每天运行一次。 我希望该任务只运行 1 小时。如果处理该任务的持续时间超过 1 小时,则使该任务过期。它会运行

回答 2 投票 0

flask celery 工人未收到任务

我正在执行一项任务,需要使用 Celery Beat 计划安排我的应用程序定期执行。 我面临的主要问题是 Celery 没有触发我的应用程序...

回答 1 投票 0

子进程任务未在`@celery_app.task`中终止

我想使用 celery ID 停止 celery 任务。我正在执行子进程任务来运行蜘蛛进行报废。因此,当我们停止 celery 任务时,子进程任务也会终止。 ...

回答 1 投票 0

celery 节拍动态调度器

我有一个包含动态计划任务的时间和元数据的数据库。 从 __future__ 导入绝对导入,unicode_literals 导入操作系统 从芹菜进口芹菜 从 concentrApp 导入集...

回答 1 投票 0

如果其中一项任务失败,Celery 链就会断裂

如果其中一个任务失败,整个链就会断裂,那么 Celery 链还有什么意义?!! 我有这个芹菜链: res = 链(workme.s ( y=1111 ), workme2.s( 2222 ), workme3.s( 3333 ),)() 而我...

回答 2 投票 0

删除celery中所有待处理的任务?

如何在不知道每个任务的task_id的情况下删除所有待处理的任务?

回答 12 投票 0

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

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

回答 1 投票 0

通过 Django 中的 celery Worker 停止当前正在运行的任务

我有一个 Django 应用程序和 React 作为我的前端框架,我使用 celery 来运行冗长的任务,这确实需要很多时间,但一切都工作正常。 我还提供真实的...

回答 2 投票 0

优雅地停止芹菜任务

我想优雅地退出 celery 任务(即不是通过调用 revoke(celery_task_id, Terminate=True))。我想我应该向设置标志的任务发送一条消息,以便任务函数可以返回...

回答 2 投票 0

celery 正在运行,但没有执行任何任务

带有 Redis 的 Celery 正在运行,但任务未在 FastAPI 中执行 命令-redis-服务器- 命令 - celery -A core.celery_app_work worker --loglevel=info -P eventlet - 芹菜花输出...

回答 2 投票 0

如何从 celery 任务获取实时标准输出?

我有一个 Django 项目,其中我正在使用 celery 运行一些后台任务,我的目标之一是显示正在运行的任务的实时标准输出,以便用户可以看到进度。问题是...

回答 1 投票 0

Celery 任务在 Django 测试中不会抛出异常

我的 Django 测试中包含几个 celery 任务。不幸的是,当通过 .delay() 调用任务时,不会抛出异常。我将 CELERY_ALWAYS_EAGER 设置为 True。 任务.py

回答 3 投票 0

@shared_task 装饰器不起作用

问题:当我从自定义文件导入数据时,@shared_task 装饰器不起作用。我的意思是,当我启动 celery 时,@shared_task 下的所有任务都不会出现在任务列表中。 例如,在...

回答 2 投票 0

最新问题
© www.soinside.com 2019 - 2025. All rights reserved.