celery 相关问题

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

Celery 在 docker 中运行时无法将任务发送到队列

我在windows上测试了它并且它有效，但现在我想使用docker来做到这一点。问题是当我尝试执行任务向用户发送电子邮件时出现错误：[Errno 111] 连接被拒绝，但是 celery s...

python django docker rabbitmq celery

回答 2 投票 0

Python Celery 收到未注册类型的任务 - 导入应用程序错误

我无法导入我的 celery 应用程序来从我的主 Python 应用程序运行任务。我希望能够从 myprogram.py 文件运行 celery 任务。我的celery_app.py文件如下：进口芹菜 ap...

python import celery

回答 2 投票 0

仅为 Celery 和弦任务配置结果后端？

是否可以仅为和弦任务配置结果后端？或者我是否需要为 Celery 应用程序中的所有任务配置通用结果后端才能使用和弦？我已经有了资源...

python celery django-celery

回答 0 投票 0

AttributeError: 'EntryPoints' 对象没有属性 'get'

在测试一个简单的芹菜示例时，我不断收到以下错误。 AttributeError: 'EntryPoints' 对象没有属性 'get' 使用以下 CLI 命令：芹菜 -A ctest worker --

python celery python-importlib kombu

回答 0 投票 0

如何在 Celery shared_task 中运行异步 GraphQL schema.execute()？

我将 Strawberry 与 Django 一起用于 GraphQL，我创建了一个 shared_task() 应该在 Schema 上执行此查询，但我收到此错误： GraphQLError("‘协程’对象没有属性‘

python django graphql celery strawberry-graphql

回答 0 投票 0

如何获取属于 Celery Canvas 的所有任务的信息？

我在芹菜中有多个任务。我使用链条、组和和弦的混合搭配来运行它们。但是，我仍然不知道如何访问所有已执行的任务（按执行顺序）...

python celery task-queue celery-task celery-canvas

回答 0 投票 0

如何退出 Celery 的 Flower Dashboard

我启动了一个花仪表盘，我不知道如何停止它。我终止了运行仪表板的屏幕会话，但它仍在运行。我在文档中找不到任何关于停止...

celery

回答 0 投票 0

使用 Python/Flask 管理长时间运行的 API 侦听器

我的 python 脚本（例如 downloader.py）监听一个流式 REST API 端点，它不断向它发送数据。在发出初始 GET 请求后，它使用诸如 requests iter_conten 之类的函数...

python rest flask redis celery

回答 1 投票 0

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

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

python celery

回答 0 投票 0

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

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

django selenium-webdriver heroku celery

回答 0 投票 0

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

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

django celery django-celery celery-task

回答 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

celery fastapi ubuntu-20.04 pipenv

回答 0 投票 0

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

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

python redis celery redis-sentinel

回答 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...

python cuda celery theano

回答 1 投票 0

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

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

python django apache-spark celery ray

回答 1 投票 0

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

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

python redis rabbitmq celery

回答 2 投票 0

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

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

python django celery

回答 6 投票 0

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

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

python rabbitmq celery

回答 0 投票 0

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

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

python django rabbitmq celery pika

回答 1 投票 0

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

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

python django rabbitmq celery

回答 4 投票 0

celery 相关问题

最新问题