celery 相关问题

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

如何将 Celery 配置为可靠的发送队列

我正在尝试使用 Celery 来排队 HTTP 请求以发送到另一个服务。最重要的是没有数据丢失,所以每个请求至少发送一次。另外我...

回答 0 投票 0

Selenium 代码可在本地机器上运行,但在 heroku 上的 celery 中使用时会中断

我正在 django 中开发一个站点,我有一个使用 selenium 的任务,该任务使用 celery 进行,这个任务在我的机器上运行得很好,但是一旦托管到 heroku,它仍然运行但运行

回答 0 投票 0

Django celery - Django Admin 中的任务结果为空

我已经按照教程设置了celery/redis相关设置。 celery 任务可以成功运行,但 django admin 中的“任务结果”为空,记录为 0。 这是我的

回答 0 投票 0

pipenv 中安装的celery 如何进行Idaemon 化?

我正在尝试在 Ubuntu 20.04、pipenv pipenv、版本 2023.2.18、FastAPI 0.95.1 和 Celery 5.2.7 中将 Celery 作为服务运行。 如果我在测试目录中执行 pipenv shell 然后执行 celery -A app.worker

回答 0 投票 0

无法从我的 python flask 应用程序连接到我的哨兵 redis

嗨,我使用官方的 docker-compose 文件来设置我的 redis 和 sentinel,如下所示: 版本:'2' 网络: 应用层: 司机:桥 服务: 重新分配: 图片:'bitnami/redis:最新'

回答 1 投票 0

在 Celery 芹菜工人中使用 Theano 共享变量时出现运行时错误

我有一个名为 simple_theano_tasks 的 Celery 任务: @app.task(bind=True, queue='test') def simple_theano_tasks(自我): 将 theano、numpy 导入为 np my_array = np.zeros((0,), dtype=theano.config.float...

回答 1 投票 0

适用于基于代理或参与者模型算法服务的 python 框架或库

python 中的哪个框架或库适合基于代理或参与者模型算法服务? 我一直致力于开发新的算法交易平台,该平台倾向于 24/7 全天候为多个加密货币

回答 1 投票 0

RabbitMQ 和 Celery:订阅工作完成事件

我有一个使用 RabbitMQ 消息代理和 Redis 数据存储运行的简单 Celery task.py 从芹菜进口芹菜 app = Celery('tasks', broker='pyamqp://guest@localhost//', backend="redis://

回答 2 投票 0

在 django 中连接新的 celery 周期性任务

这不是问题,而是帮助那些会发现 celery 4.0.1 文档中描述的周期性任务的声明很难集成到 django 中的人: http://docs.celeryproject.org/en/l...

回答 6 投票 0

如何阻止芹菜推入已满的 rabbitmq 队列

我有一个用 Kombu 定义的队列,如下所示 从 kombu 导入队列 Queue("myname", "exchange", max_length=10, x_overflow='reject-publish') 我的期望是拒绝所有...

回答 0 投票 0

通过 RabbitMQ 队列上的侦听器执行芹菜任务

我正在尝试为消息传递消费者运行脚本,该脚本会监听 rabbitMQ 实例并根据该消息值执行 celery 作业。我收到了循环依赖的问题......

回答 1 投票 0

django celery 错误:不可恢复的错误:AttributeError("'EntryPoint' object has no attribute 'module_name'")

我很困惑,因为我是 celery 的新手,所以我不知道这个奇怪的错误,这个错误只发生在设置阶段,每件事都简单地按照 celery 文档 https://docs.c 中的描述进行配置...

回答 4 投票 0

celery和rabbitmq按什么原则来分配队列才是正确的?

我有一个小宠物项目,它是一个用 fastpic 编写并使用 postgresql 和 sqlalchemyORM 的 api。最近我遇到了 Celery 这样的东西,并决定将它添加到我的项目中,但是我运行了...

回答 0 投票 0

使用 Django 和 Celery 在 Azure 上上传文件

我正在开发一个 API,它将在 Azure 容器上上传大型视频。我正在使用 Celery 异步实现此功能。 这是 views.py 的代码- 类 FileUploadView(APIView): ...

回答 0 投票 0

我收到错误 ModuleNotFoundError: No module named 'celery' ubuntu 20.04 server

我已经连续两天尝试解决这个问题,但是,我没有任何运气 我正在与主管一起运行芹菜,它显示正在运行我可以通过 900 在 systemctl 和主管 Web 界面中看到它...

回答 1 投票 0

在 cpanel 主机上永久激活 celery worker 和 celery beat

好吧,我已经在我的项目中写了一些任务,我已经配置了一个 celery worker 并为他们打败,一切都很好。我打开终端运行 worker 并击败它,它就可以工作了。但这是我的

回答 1 投票 0

芹菜 dockerfile

我在一个应用程序(或容器)中同时使用 Django 和芹菜,但我想在另一个应用程序(或容器)中将芹菜分开。我不确定我应该怎么做,因为我的任务在 Django 应用程序中。 小...

回答 1 投票 0

Celery 同步子进程之间的数据

我有一个 python 应用程序,其中包括 flask、apscheduler 和 Celery。调度程序创建任务供 celery worker 计算。问题是芹菜工人正在轮询

回答 0 投票 0

在窗户上运行芹菜节拍 - 不可能完成的任务?

我坚持使用 redis 作为后端在 Windows 7(以及更高版本的 2013 服务器)上运行 celery 3.1.17。 在我的 celery.py 文件中,我定义了一个带有一个计划任务的应用程序 应用程序=芹菜('我的应用程序',

回答 3 投票 0

即使我在 task_prerun 上抛出异常,Celery 任务仍在执行

我需要在 celery 任务执行之前对其进行一些基本验证。当任务分配给工人时,我需要执行此验证,因为我需要检查工人是否...

回答 0 投票 0

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