celery 相关问题

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

为什么 Celery 没有完全关闭?

使用 Ctlr-C 键盘中断向 Celery Worker 发出两次 TERM 信号(热关机和冷关机)后,Celery Worker 就挂断了。它不消耗消息或执行...

回答 2 投票 0

celery如何立即执行周期性任务?

我想用celery来执行周期性任务。 根据文档:http://docs.celeryproject.org/en/latest/userguide/periodic-tasks.html#entries,我写下了以下代码: 应用程序...

回答 2 投票 0

添加 Celery 设置 - 它有什么作用?

我们升级了 Celery 并开始收到警告: CPendingDeprecationWarning:broker_connection_retry 配置 设置将不再确定代理连接重试是否 做杜...

回答 3 投票 0

如何在模型字段中的特定日期触发 Django 任务

我有一个包含以下字段的模型 类 EventConfig(models.Model): end_date = models.DateTimeField(空白=True, null=True) 我安装了 celery,它会定期发送电子邮件,并且

回答 1 投票 0

当双方玩家都断开连接时处理未完成的国际象棋游戏的方法

我需要弄清楚如果两个玩家都没有完成游戏就离开游戏该怎么办。在这种情况下,我需要一个解决方案来保留当前的游戏状态并确定何时应该考虑游戏......

回答 1 投票 0

如何在 Flask 应用程序中使用 Celery 检查任务是否已添加到 RabbitMQ 队列?

我正在开发一个使用 Celery 和 RabbitMQ 作为消息代理的 Flask 应用程序。 我想在开始处理之前检查任务是否已成功添加到 RabbitMQ 队列中。

回答 1 投票 0

通过队列设置Celery时间限制

我有一个使用 Celery 的项目,最初实现了一个独特的队列,这可能会引起一些麻烦。 所以我想实现几个队列(已完成并且有效),但我想设置

回答 2 投票 0

DJANGO_CELERY_BEAT从shared_task访问PeriodicTask

在我的项目中,我使用django celerybeat包来执行计划任务。它运作良好,但我有一个无法处理的情况。 所有任务都有一个PeriodicTack 来安排它们。 所以接下来...

回答 1 投票 0

使用 CeleryExecutor 访问登录气流时访问禁止

我正在尝试使用 celery Executor 在 kubernetes(在 Azure Kubernetes 服务上)上部署 Airflow。但是,任务完成后,我在尝试访问其日志时收到以下错误: *** 记录...

回答 2 投票 0

芹菜是长时间运行任务的好选择吗?

我们使用 django、rabbitmq、celery 和 ffmpeg 的组合来读取相机流并将其分解为图像以存储到文件系统中。此设置可 24x7 运行。现在,对于每个摄像机流...

回答 2 投票 0

带有 celery 的 Python Flask 脱离应用程序上下文

我正在使用 python Flask 构建一个网站。 一切都很顺利,现在我正在尝试实施芹菜。 一切进展顺利,直到我尝试使用来自 ce 的 Flask-mail 发送电子邮件......

回答 7 投票 0

链接一个 Celery 任务,将列表返回到链中间的组中

这个问题和这个是一样的: 如何将返回列表的 Celery 任务链接到一个组中? 除了我需要这发生在链的中间,并且接受的解决方案只能工作......

回答 3 投票 0

Celery 按顺序执行任务,一个接一个

我有一个 Django 应用程序,其中包含大量 I/O 密集型任务。 我使用 Celery 在线程中运行这些任务,并使用进度条管理 UI 中的进度。 这是我的配置: Django 版本...

回答 1 投票 0

Celery 工作线程过早退出信号 11:尝试在 Django 视图中单击按钮时运行 python 脚本

我正在开发一个 Django 应用程序,其部分过程是用时间戳转录音频。当用户单击 Web 界面上的按钮时,Django 服务器会启动一个 Python 脚本来帮助...

回答 1 投票 0

Celery 并发与工作人员数量

有什么区别 celery -A 任务工作者 -l 信息 --concurrency=4 和 celery -A 任务worker -l 信息 -nworker1@%h celery -A 任务worker -l 信息 -nworker2@%h 芹菜 - 任务工作者...

回答 1 投票 0

多处理、Python3、Windows:TypeError:无法 pickle _thread.lock 对象

在运行Python 3.6的Windows 10系统上,当尝试使用multiprocessing.Process创建新的rq工作者时, multiprocessing.Process(target=Worker(qs).work, kwargs={'burst': True}).start() ...

回答 3 投票 0

姜戈芹菜。在publish_date发布帖子

我有一个邮政模型。有一个字段publish_date。如果帖子具有计划状态,那么我需要在publish_date上执行发布功能。我该怎么做? 模型.py: 班级帖子(mo...

回答 1 投票 0

Django 通道中的 WebSocket 连接失败和意外的套接字关闭

我在使用 Django Channels 的 Django 项目中建立和维护 WebSocket 连接时遇到问题。我已经建立了一个使用 WebSockets 来广播混乱的通知系统......

回答 1 投票 0

在后台运行 Django 进程

我一直在阅读一些有关设置后台进程的指南,其中大多数建议将 Celery 与 Redis 结合使用。我正在 Windows 上使用 Nginx 和 Gunicorn 运行 Django 应用程序,但我遇到了

回答 1 投票 0

找不到单元rabbitmq-server.service

我在Ubuntu 20.04上运行以下命令 sudo apt-get 安装rabbitmq-server sudo systemctl 启用rabbitmq-server sudo systemctl 启动rabbitmq-server systemctl 状态 RabitMQ 服务器 我明白了

回答 2 投票 0

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