celery-task

    1热度

    2回答

    注册基于类的任务

    我正在使用Celery版本4.0.2。 与先前版本的Celery相比，似乎基于类的任务没有自动注册（即，如果您配置了自动发现功能）。 但是，我甚至没有实现手动注册基于类的任务。 按照芹菜更改日志： http://docs.celeryproject.org/en/latest/changelog.html#version-4-0-1 因为4.0.1版本，应该可以注册手动任务： from celer
    python celery celery-task 2017-07-04

    0热度

    1回答

    如何在芹菜中添加日志处理程序？

    所以我这里我tasks.py是exerpt： import builtins import logging import os import urllib import inspect from celery import Celery from common.environment_helper import EnvironmentHelper from config impor
    python asynchronous logging celery celery-task 2017-08-28

    0热度

    1回答

    如何消费者从一个不同的应用程序中的芹菜队列

    我在我的生产者应用程序中使用Celery将API调用插入到我的RabbitMQ中的代码如下。 celery.send_task('tasks.process_redox', (payload,), queue="redox_inbound") 我想知道，代码看起来会从该队列中消耗什么？我有下面但它不工作，似乎无法找到它在 @celery.task() def process_redox(pa
    python rabbitmq celery celery-task 2017-07-14

    1热度

    1回答

    与多个应用程序一起使用Celery队列

    如何为多个应用程序使用同名的Celery队列？ 我有具有N客户端数据库，这都需要在一个特定的队列M. 对于每个客户端数据库芹菜任务处理的应用程序，我有一个单独的芹菜工人我启动等： celery worker -A client1 -n [email protected]%h -P solo -Q long celery worker -A client2 -n [email protected]
    celery django-celery celery-task 2017-07-18

    1热度

    1回答

    将任务添加到现有的组或和弦

    请考虑以下方案; 有3种不同类型的任务。 A，B和C。 A旨在生成B的输入，B应接收来自A的输入后创建许多C任务。 在开始，我只能够定义group(A, B)为C s由B执行。但我想等待所有C任务完成，以便得出主要任务完成的结论。 有没有办法通过使用芹菜工具来做到这一点？
    celery celery-task 2017-07-20

    7热度

    2回答

    在芹菜中的多个队列中优先队列？

    我们将芹菜用于异步后台任务，我们有2个队列用于不同的优先级任务。我们有2个节点集群单独服务它们。事情如预期般运作良好。 问： 我们得到多为低优先级任务。为了优化资源利用率，我想知道是否有办法配置worker（侦听高优先级队列）来侦听这两个队列。但只要有一份工作在那里，就从更高优先级的队列中选择工作？否则返回低优先级队列。 我已经通过讨论@Celery Task Priority讨论了基于优先级的任
    celery celery-task 2017-09-13

    0热度

    1回答

    阻止任务在芹菜和弦中运行的任务选项

    我试图将现有的芹菜组呼叫转换成和弦以防止死锁。以前的代码有重试和到期时间。我设法让和弦在没有这些设置的情况下工作，但是当我尝试应用设置时，我没有看到正在运行的任务。我没有看到有关在整个和弦上应用相同设置的文档中的任何内容。我正在运行芹菜版本3.1.6。 以前的代码： jobs = group([reset_device.s(topoid, dev_list[i], waittime
    celery celery-task chord 2017-07-26

    1热度

    1回答

    （芹菜）：在特定的工作人员中运行任务？

    我从芹菜中不同的服务器很多工人，（下面的图片显示） 很多任务： @task(name="task1") def task1(): ....... @task(name="task2") def task2(): ...... 我只想对“[email protected]_website运行“独立写作” “工人。我应该如何配置？ celery -A tasks -n
    celery worker celery-task 2017-07-28

    0热度

    1回答

    过程不会与芹菜中的多处理模块产生

    我有一个非常标准的设置：Django + Rabbitmq +芹菜。 我想在芹菜中产生一个使用标准python多处理模块的进程。 我注意到，过程本身并没有产卵。什么可能是没有产生这个过程的原因。这里是代码： import multiprocessing as mp from celery.schedules import crontab from celery.decorators impor
    multiprocessing celery python-multiprocessing celery-task celerybeat 2017-09-27

    1热度

    1回答

    send_task只适用于特定用户

    设置： Celery 4.1，RabbitMQ 3.6.1（作为经纪人），Redis（作为后端，这里不相关）。 有两个兔子用户： admin_user与.* .* .*权限。 remote_user权限为ack ack ack。 admin_user可触发任务并由芹菜工作人员用来处理任务。 remote_user仅可以触发一个类型的任务 - ack和在专用ack队列后来排入由ack工人被消耗（由a
    rabbitmq celery amqp celery-task rabbitmqctl 2017-08-13
最新问题