Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
如何让 celery Worker 停止接收新任务 (Kubernetes)
因此 我们有一个 kubernetes 集群 运行一些带有 celery 工作线程的 pod 我们使用 python3 6 来运行这些工作程序 celery 版本是 3 1 2 我知道 真的很旧 我们正在努力升级它 我们还设置了一些自动缩放
python3x
Kubernetes
Celery
djangocelery
celerytask
如何在 Celery 中仅当所有其他任务完成后才开始任务
在 Celery 中 我只想在所有其他任务完成后才开始一项任务 我找到了一些像这样的资源 Celery 在其他任务完成时启动任务 https stackoverflow com questions 25576890 celery start
python
Celery
celerytask
Django 1.6 + RabbitMQ 3.2.3 + Celery 3.1.9 - 为什么我的 celery 工作人员会死掉:WorkerLostError:工作人员过早退出:信号 11 (SIGSEGV)
这似乎解决了一个非常相似的问题 但并没有给我足够的洞察力 https github com celery billiard issues 101 https github com celery billiard issues 101听起来尝
django
rabbitmq
Celery
celerytask
celerybeat
如何通过celery任务访问orm?
我正在尝试使用 sqlalchemy celerybeats 翻转数据库中特定类型对象的布尔标志 但是如何从tasks py 文件访问我的orm from models import Book from celery decorators
Flask
Celery
flasksqlalchemy
celerytask
celerybeat
即使任务启动后,AsyncResult(task_id)也会返回“PENDING”状态
在项目中 我尝试轮询长时间运行的任务的task state并更新其运行状态 它在开发中有效 但当我将项目移动到生产服务器上时它不起作用 即使我可以看到任务在花上开始 我仍然收到 待处理 消息 但是 当任务完成时 当task state SU
python
django
Celery
djangocelery
celerytask
Celery AttributeError:异步错误
我在 Mac OS X 10 13 4 上本地运行 RabbitMQ 和 Celery 当我运行 add delay x y 时 以下代码在本地运行 usr bin env python from celery import Celery
python
Celery
celerytask
Celery + SQS 两次接收相同的任务,同时具有相同的任务 ID
在 Flask 应用程序中使用带有 SQS 的 celery but celery 同时接收两次具有相同任务 ID 的相同任务 像这样运行工人 celery worker A app jobs run l info pidfile var
Flask
Celery
amazonsqs
celerytask
在芹菜中的多个队列中确定队列的优先级?
我们使用 celery 来执行异步后台任务 并且有 2 个队列用于不同优先级的任务 我们有 2 个节点集群分别为它们提供服务 事情进展顺利 正如预期的那样 问题 我们得到的大多是低优先级的任务 为了优化资源利用率 我想知道是否有一种方法可以
Celery
celerytask
如何使 celery 任务从任务内部失败?
在某些情况下 我想让芹菜任务从该任务中失败 我尝试了以下方法 from celery task import task from celery import states task def run simulation if some co
Celery
celerytask
芹菜导入错误
这是我正在运行的代码 from future import absolute import from celery import Celery celery1 Celery celery broker amqp backend amqp i
python
Celery
pycharm
celerytask
在 Celery 链中使用分组结果
我陷入了相对复杂的芹菜链配置 试图实现以下目标 假设有如下一系列任务 chain1 chain DownloadFile s http someserver file gz downloads file returns temp file
python
Celery
celerytask
Celery 结果错误“args 必须是列表或元组”
我正在运行一个 Django 网站 并且刚刚让 Celery 运行 但我遇到了令人困惑的错误 以下是代码的结构 在测试 py中 from tasks import from celery result import AsyncResult
python
django
Celery
celerytask
celeryd
在哪里设置 celery 任务的task_id?
我无法找到使用我自己的 task id 设置 task id 的任何示例 沿着这些思路的东西 def testview1 request for i in xrange 0 1000 result add delay i 4 task id
python
djangocelery
celerytask
测试 celery 任务是否仍在处理中
如何测试任务 task id 是否仍在处理中celery http celeryproject org 我有以下场景 在 Django 视图中启动任务 将 BaseAsyncResult 存储在会话中 关闭 celery 守护进程 硬 以便
python
django
Celery
celerytask
Airflow - Python 文件不在同一个 DAG 文件夹中
我正在尝试使用 Airflow 来执行一个简单的 python 任务 from future import print function from airflow operators python operator import Pytho
python
Celery
celerytask
airflow
AttributeError:“PathDistribution”对象没有属性“name”
我正在尝试使用运行一个简单的工作流程celery并使用this https docs celeryproject org en stable userguide canvas html文档 我正在使用链按顺序运行任务 工作流程如下 提取文件
python3x
Celery
spacy
celerytask
如何覆盖 celery 任务的后端
我们使用 Redis 作为结果后端 然而 对于一项任务 我们希望覆盖它以使用 RabbitMQ 的文档任务后端 http celery readthedocs org en latest userguide tasks html Task
python
Celery
celerytask
如何按名称限制运行 Celery 任务的最大数量
如何限制可以同时运行的特定 Celery 任务的实例数量 我有一个处理大文件的任务 我遇到一个问题 用户可能启动多个任务 导致服务器耗尽 CPU 和内存 因为它试图同时处理太多文件 我想确保在任何给定时间仅运行这一类型任务的 N 个实例 并
python
Celery
celerytask
在数据库中保存 celery 任务(用于重新运行)
我们的工作流程目前是围绕旧版本的 celery 构建的 因此请记住 事情已经不是最佳的 我们需要运行一个任务并将该任务运行的记录保存在数据库中 如果该任务失败或挂起 这种情况经常发生 我们希望重新运行 就像第一次运行一样 但这不应该自动发生
django
Celery
celerytask
Celery工人导入错误:没有名为“项目”的模块
当我尝试启动工作人员时 我遇到了一个问题 导入错误 没有名为 项目 的模块 回溯 最近一次调用最后一次 File usr local bin celery line 11 in
python
django
Celery
djangocelery
celerytask
1
2
»