-
1 votesanswersviews
芹菜仍在开工
我有芹菜的问题 . 我已经将Celery设置为妖魔化 . 这是命令： / home / user / sitios / incidencias / env / bin / python3 -m celery worker --concurrency = 4 --time-limit = 200 --app = incidencias --loglevel = INFO --logfile = /... -
0 votesanswersviews
Celeryd没有执行我的工作人员
我正在尝试在celery中使用daemonize我的任务，我已经测试过没有守护进程，而且它运行良好 . 但我不能像教程说的那样守护（http://docs.celeryproject.org/en/latest/tutorials/daemonizing.html#daemonizing）我有我的文件： solr_desa.py from celery import Celery celery ... -
1 votesanswersviews
当 Worker 没有开始时，无法撤销芹菜任务
我正在使用芹菜任务队列 . 当我没有工作人员启动任务时，我无法在不启动工作人员的情况下撤销任务 . 当我运行此命令 revoke(terminate=True, signal='SIGKILL') 时 . 它返回 state 为 PENDING . 我想知道是否可以撤销在没有 Worker 开始时我已经开始的任务？ 我尝试了持久的撤销，但它似乎在这种特定情况下无效 . -
0 votesanswersviews
芹菜没有配置不同的队列
我已经安装了芹菜4.1.1并设置了队列和路由，但是工作人员只接受名称'celery'的数据 . BROKER_URL = 'redis://localhost:6379/0' CELERY_RESULT_BACKEND = 'redis://localhost:6379/0' CELERY_DEFAULT_QUEUE = 'default' CELERY_TASK_SERIALIZER = 'js... -
2 votesanswersviews
在芹菜中重复任务
几天后，我的芹菜服务将无限期地一遍又一遍地重复一项任务 . 这有点难以复制，但是每周定期发生一次或更频繁地发生，具体取决于正在处理的任务量 . 我将非常感谢有关如何获取有关此问题的更多数据的任何提示，因为我不知道如何跟踪它 . 当它发生时，重新启动芹菜会暂时解决它 . 我有一个芹菜节点运行4个 Worker （版本3.1.23） . 经纪人和结果后端在Redis上 . 我只发布到一个队列，我不使用... -
0 votesanswersviews
Celery（Django Redis）任务失败：“由于目标机器主动拒绝它，因此无法 Build 连接”
UPDATE: 我决定尝试使用Django作为简单的代理，因为我认为我在Redis设置中做错了 . 但是，在进行docs中描述的更改后，在尝试使用 .delay() 运行Celery任务时，我得到与以下相同的错误 . Celery工作人员启动并显示它已连接到Django进行传输 . 这可能是防火墙问题吗？ ORIGINAL 我已经安装了Celery并为经纪人选择了Redis，并安装了它（我在Wi... -
1 votesanswersviews
如何将Celery任务注册到特定工作者？
我正在使用Python / Django开发Web应用程序，我有几个在芹菜中运行的任务 . 我必须一次运行一个任务A，所以我使用--concurrency = 1创建了worker，并使用以下命令将任务A路由到该worker . celery -A proj worker -Q A -c 1 -l INFO 当这个worker处理任务A并且其他任务被路由到默认队列时，一切正常 . 但是，当我使用... -
0 votesanswersviews
我想在芹菜中使用多个 Worker 来遍历一个列表
我有一个清单： url_list=["abc.com","def.com","xyz.com"."pqr.com"...] - 100,000 entries 我想使用100名芹菜 Worker 遍历这份清单，以减少完成工作所需的时间 . 我的问题是：我如何向 Worker 提供这个 url_list ，以便这100... -
0 votesanswersviews
ImportError：无法导入名称'TaskProducer'
我正在使用tcelery与Tornado异步运行任务 . 环境：OSX，Python3.4 这是 server.py ： from tornado import gen from tornado import ioloop from tornado.web import asynchronous, RequestHandler, Application import tasks import ... -
1 votesanswersviews
（芹菜）：在特定 Worker 中运行任务？
我有很多来自芹菜不同服务器的 Worker ，（如下图所示） 和许多任务： @task(name="task1") def task1(): ....... @task(name="task2") def task2(): ...... 我想只在“celery@40.218testlab_website”工作者上运行“task1” . 我该怎... -
3 votesanswersviews
使用芹菜和django的多个消息代理
我正在用django芹菜 . 我有两个芹菜应用程序在同一台服务器上运行，但使用不同的消息代理 . 一个是使用redis，另一个是使用django-orm . 使用redis后端的应用程序配置为仅从signgle队列接收任务 . 另一个应用程序配置为处理所有其他队列 . 现在的问题是，如果我使用redis bankend启用应用程序，则其他应用程序将停止从orm后端接收任何任务 . 我怎么能做到这一... -
6 votesanswersviews
芹菜如何运作？
我最近开始致力于分布式计算，以提高计算速度 . 我选择了Celery . 但是，我对某些术语不太熟悉 . 所以，我有几个相关的问题 . 来自Celery docs： 什么是任务队列？ ...芹菜通过消息进行通信，通常使用经纪人在客户和 Worker 之间进行调解 . 为了启动任务，客户端向队列添加消息，然后代理将该消息传递给工作者 . 什么是客户（这里）？什么是经纪人？为什么通过经纪人传递消息...