celery 相关问题

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

celery postgres 后端不存储重试次数

上下文失败的任务按预期重试 postgresql 后端不存储失败任务的重试次数测试这些返回无， AsyncResult(task_id='some_taskid', app=app).retries 选择...

python-3.x celery celery-task

回答 0 投票 0

如何在 Django 中更新 Celery 任务的状态？

朋友们有一个问题：我想在Django中更新celery的任务状态。我想要的一个例子： 1-在任务中创建一个任务，比如从多个文本文件中提取数字： @shared_tas ...

django celery django-celery

回答 0 投票 0

关于构建 docker image level=error msg="Can't close tar writer: io: read/write on closed pipe"

time="2017-10-27T07:39:20Z" level=error msg="无法将文件 /var/app/current/app/content_classifier/forest.pickle 添加到 tar：io：读/写封闭管道” time="2017-10-27T07:39:20Z" level=错误信息...

linux docker celery amazon-elastic-beanstalk celerybeat

回答 10 投票 0

Celery 找不到我的 django 模块

当我尝试使用命令 celery -A blogger.celery worker 启动 celery 时，我遇到了以下错误。我从我的包目录运行命令，我有我的 celery.py

python django redis celery django-celery

回答 0 投票 0

尝试将 CloudAMQP 与 Flask 和 Celery 一起使用时出现连接被拒绝错误：如何解决？

我在使用 Flask 和 Celery 连接到我的 CloudAMQP 实例时遇到问题。我在 https://api.cloudamqp.com/console/ 创建了一个免费帐户并设置了以下 Flask 配置：来自芹菜

python flask celery

回答 0 投票 0

向 RabbitMQ 消息队列添加任务时出现 Django 芹菜错误：AttributeError: 'ChannelPromise' object has no attribute '__value__'

我在 digitalocean 上设置了 celery、rabbitmq 和 django 网络服务器。 RabbitMQ 在我的 Django 应用程序未运行的另一台服务器上运行。当我尝试使用延迟将任务添加到队列时，我...

python django rabbitmq celery system-design

回答 2 投票 0

如何在FastAPI中将花端口5556映射到enpoint？

我有一个简单的 FastAPI 应用程序。我使用 celery 进行异步任务处理，使用 flower dashboard 监控任务我的主要应用程序在端口 80 上运行我的任务监控花仪表盘是

python-3.x docker-compose celery fastapi flower

回答 0 投票 0

如何获取芹菜中任务的持续时间？

我想测量芹菜中的任务运行时间。我知道我们可以使用时间作为开始时间和结束时间。然后得到持续时间。但我想使用内置芹菜。例如在这个 URL 中我们有任务事件：

celery

回答 0 投票 0

如何安排任务在特定时间每n分钟运行一次（celery-django）

在django中使用celerybeat时，我想安排一个任务在特定时间启动，然后每5分钟运行一次。我能够让任务每 5 分钟运行一次，使用 crontab(min...

django celery celerybeat

回答 2 投票 0

How to start a Celery worker from a script/module __main__?

我在模块中定义了一个 Celery 应用程序，现在我想从其 __main__ 中的同一个模块启动工作程序，即通过使用 python -m 而不是命令行中的 celery 运行模块。我...

python celery celeryd

回答 6 投票 0

如何忽略 celery chord 中的错误并允许进程继续

我有一个包含多个任务、链和弦的芹菜工作流程。其中一些任务需要顺序执行，另一些任务可以并行执行。问题是出现错误时...

python celery django-celery chord

回答 0 投票 0

如何为 GCP 云日志设置 Celery 日志记录？

我正在尝试在我的 GCP 云日志记录中获取 Celery 任务日志。尽管我在 GCP Cloud 日志记录中看到了全局 Celery 日志，但从 celery.task 中发出的日志不会显示在 GCP 上。这是我现在的同事...

python-3.x google-cloud-platform logging celery

回答 0 投票 0

无法在 Celery 任务中将 Pytorch 与 CUDA 结合使用

我有一个使用 torch 库的 celery 任务，它在内部使用 CUDA。当我运行任务时，它没有说 “无法在分叉子进程中重新初始化 CUDA。要将 CUDA 与多处理一起使用...

pytorch celery

回答 2 投票 0

Celery worker 设置和拆卸

我的 Celery 任务需要的资源设置起来有点昂贵，但可以重复用于同一线程上的许多任务，但需要在工作人员关闭时关闭。（具体来说，他们需要 ...

celery

回答 1 投票 0

Python - 使用不同的参数多次加载和使用新进程

我想创建一个带有加载函数的单独 python 进程，以后可以多次使用不同的参数访问/使用/调用它（以克服 GIL）。这有点像多进程...

python multiprocessing celery gil

回答 3 投票 0

Celery Groups：如何创建一组已经运行的任务？

我有一组长期运行的任务，我需要在小组中进行协调。挑战在于任务必须在创建后立即触发，而不是在定义所有任务之后（如下所示）。问题...

python asynchronous celery scheduling group

回答 0 投票 0

类型的对象不是 JSON 可序列化的 Django

Django 项目 - 发送电子邮件。有一个视图函数接收 POST 请求，循环遍历数据库中的所有电子邮件并将请求参数传递给 Celery 任务。赛勒...

django celery django-celery celery-task

回答 0 投票 0

如何在 Django 中仅通过数据库使用 Celery？

查看 https://docs.celeryq.dev/en/v5.2.7/getting-started/backends-and-brokers/index.html 听起来好像不可能/不可取。有一个关于 SQLAlchemy 的部分，但是 Dja...

python django celery

回答 2 投票 0

发送 ctrl+c 到 celery 任务启动的进程

我正在尝试将 ctrl+c 发送到由 celery worker 启动的进程/函数，但该进程没有收到 SIGINT，就像在这个问题中一样。芹菜任务调用 run_bot()： def run_bot():

python celery

回答 0 投票 0

使用 RabbitMQ 设置 Celery

我正在尝试使用 RabbitMQ (3.8.19) (Django 4.1.5) 设置 Celery (5.2.7) 结果，该任务以“Unacked”状态出现在“celery”队列中，30 分钟后进入“Ready”状态

python django rabbitmq celery

回答 0 投票 0

celery 相关问题

最新问题