celery 相关问题

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

Django 应用程序向 SQS 发送消息,但工作线程未执行

我设置了一个名为 celery-celery 的 AWS SQS,当我调用 API 时,我通过 Celery 将任务发送到 SQS 队列。 我可以看到消息正在进入 SQS 队列 (https://sqs.us-east-1.

回答 1 投票 0

使用 celery 运行“独特”任务

我使用 celery 来更新我的新闻聚合网站中的 RSS 提要。我为每个提要使用一个@task,并且一切似乎运行良好。 有一个细节我不确定处理得好:所有提要都是

回答 7 投票 0

如何不启动相同的任务并等到它用 celerybeat 完成

我已安排 celerybeat 任务每 3 小时运行一次: 'sync_stuff':{ '任务':'celery_tasks.sync_stuff', ‘计划’: crontab(小时=‘*/3’) } 有时需要超过3小时才能

回答 2 投票 0

Heroku Postgres 无法在 Heroku 服务器 [Django] 上运行

我有一个 Django 项目,我在其中使用 Redis/Celery 来调用一些 API。我已经设置了 settings.py 文件来连接到 Postgres 数据库以及在本地运行 Django 项目时(使用 Redis/

回答 1 投票 0

celery 在执行特定任务后关闭工作进程

我正在使用celery(并发=1的单池),我希望能够在特定任务运行后关闭工作线程。需要注意的是,我想避免工人挑选的任何可能性......

回答 4 投票 0

billiard.exceptions.WorkerLostError:Worker 过早退出:没有 Docker 的信号 9 (SIGKILL)

[2021-10-27 02:05:09,365:错误/MainProcess]进程“ForkPoolWorker-5”pid:12871退出并显示“信号9(SIGKILL)” [2021-10-27 02:05:09,412:错误/MainProcess] 任务处理程序引发错误:WorkerLost...

回答 1 投票 0

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

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

回答 1 投票 0

如果用户卸载,如何停止 celery 任务?

我的网站允许用户翻译文件。我想添加一个故障保护,以防用户决定卸载网页(无论是重新加载、导航离开还是关闭选项卡)。我的后端是 django plus

回答 1 投票 0

我正在尝试启动一个 celery 工作程序(连接到 RabbitMQ)。失败了

celery -商店工人 -l 信息 [2024-08-17 13:31:27,736:警告/MainProcess] 未提供主机名。恢复默认“本地主机” -------------- celery@known-koala v5.4.0(乳白色) ---...

回答 1 投票 0

如果我们有 AsyncIO、多线程和多处理,为什么还要使用 celery?什么时候用什么?

最近我正在学习 celery,这个问题出现在我的脑海中,因为还有其他解决方案可以从请求-响应周期中卸载任务。

回答 1 投票 0

从 Django 中的数据库更新对象属性

假设我有一个代表任务的模型: 类任务(模型.模型): on_status = models.BooleanField() def 运行(自我): 如果 self.on_status: # 做事 我运行这个任务...

回答 1 投票 0

OSError:错误的文件描述符

我正在尝试将 celery Beat Worker 和普通的 celery Worker 作为 docker 容器运行。我的任务是烧瓶应用程序。 普通的芹菜工人工作正常,但在 b 中出现以下错误...

回答 1 投票 0

PostgreSQL 连接问题:异步 Celery 任务中的“保留剩余连接槽”和“队列绑定到不同的事件循环”

身体: 我正在开发一个使用 PostgreSQL 作为数据库和 SQLAlchemy 作为 ORM 的项目。最近,我遇到了两个与数据库连接相关的问题,特别是在运行...

回答 1 投票 0

查看celery任务是否存在

是否可以查出某个任务id的任务是否存在?当我尝试获取状态时,我总是会处于待处理状态。 >>> AsyncResult('...').status '待办的' 我想知道...

回答 10 投票 0

Celery启动命令行中gevent greenlet的合适数量是多少

对于gevent池,我们可以使用参数“-c”来指定greenlet编号。如下所示。 芹菜工人-A celerytasks.celery_worker_init -P gevent -c 1000 --loglevel =信息 问题:...

回答 1 投票 0

寻求 Flask 替代 Django Celery Beat,支持时区和多用户 crontab 存储

我正在开发 Flask 应用程序,我面临着在不同时区安排任务的挑战。 我之前尝试将 Celery Beat 与 MongoDB 支持的 Celery Beat Scheduler 结合使用(

回答 1 投票 0

在 Airflow 中动态选择队列

是否可以根据运行时条件动态地将队列分配给Airflow中的任务?例如,我想根据前一个任务提供的 XCom 值来确定任务的队列...

回答 1 投票 0

为什么 django-channel 中需要 celery、rabbitmq 来完成它们的工作?

我今天第一次阅读 django-channels 的文档,发现下面这行 Channels will take care ofcheduling those and run them allparallel.这是不是意味着……

回答 1 投票 0

Django + Celery + SQS - celery 工作人员收到但未执行的消息?

我正在尝试使用 Celery 和 AWS SQS 作为消息代理在 Django Web 应用程序上实现后台任务。我有一个调用任务的视图,该任务已成功发送到 SQS。在控制台赢...

回答 1 投票 0

WorkerLost 的 Celery 重启逻辑

Python 3.8、Celery 4.4.4、Redis、Django 寻找一些指导来帮助完善我的 Celery 重启逻辑和设置。我有一系列复杂的过程,广泛使用和弦来

回答 1 投票 0

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