django-celery

    4热度

    3回答

    我想用芹菜运行任务。我按照这个教程link 一切都已成功安装。现在的事情是我不知道如何执行任务。我运行芹菜,它找不到任务。 我想知道我需要调用什么来执行任务,以及我需要如何配置RabbitMQ服务器上的任务,django-admin .. 我找不到任何完整的教程。

    1热度

    1回答

    在使用eventlet池时,芹菜会不会使Django查询非阻塞? 如果没有,是否有一个已知的好方法使它如此?

    1热度

    2回答

    我的问题是以下内容: 我有一个django应用程序,我可以上传文件。当一个文件被上传,芹菜启动任务处理上取决于它的版本类似下面的特定队列文件: import my_library @app.task() def process_file(file): result = my_library.process(file) model = MyModel(result=resu

    1热度

    2回答

    我开发了一个django应用程序,它将采取备份,我想用芹菜做这件事,我需要知道芹菜所有的数据库是什么,以便我可以从用户那里获得输入并将其作为参数提供给芹菜任务而不是使用管理面板选项。 我需要实现什么: def mycelerytask(hassomearguemnts): will do some work. 我需要给参数芹菜任务编程,而不是使用管理面板的说法。 我想用django

    0热度

    1回答

    我已完全在本地主机上使用Django 1.8.5 + Celery 3.1.18,并定期执行任务设置。 但是在服务器上(Ubuntu 14.04),我需要额外的文件celerybeat.conf(首先是celery.conf)来定期在服务器上执行任务。 如果我手动启动服务器上简单的任务,芹菜正在(UPD:用-B选项也是周期性的任务也工作): celery worker -A engine -B -

    1热度

    1回答

    我想通过HTTP使用芹菜类的HttpDispatch进行任务调用,但我需要设置授权标头。我怎样才能做到这一点? from celery.task.http import HttpDispatch request = HttpDispatch( url='http://example.com/multiply', method='GET', {10}) request.disp

    0热度

    1回答

    我有一个芹菜任务,循环接收者列表发送消息。如果任何发送调用失败,我不希望芹菜任务退出,而是继续循环中的其他项目。 在我的情况下,这不会发生在task.retry(throw = False)上。我确实看到这个任务正在退出,而没有做任何事,甚至进一步迭代循环。 我不想要弦和链,它不是并行任务执行。我怎样才能做到这一点? @celery_app.task() def send_msg_to_lis

    1热度

    1回答

    我有一个芹菜运行在码头集装箱处理rabbitmq的任务。我试图停止并删除芹菜容器,同时允许当前正在运行的任务完成。该文档建议,发送TERM或INT信号到主进程应该加热关机芹菜,尽管我发现子进程刚刚被杀死。 当我送TERM正在运行的进程,它抛出: WorkerLostError('Worker exited prematurely: signal 15 (SIGTERM).',) 当我送INT运行过

    0热度

    1回答

    我的settings.py CELERY_ACCEPT_CONTENT = ['json', 'msgpack', 'yaml', 'pickle', 'application/json'] CELERY_TASK_SERIALIZER = 'json' CELERY_RESULT_SERIALIZER = 'json' CELERY_RESULT_BACKEND = 'djcelery.b

    2热度

    1回答

    目前,djcelery允许我通过PeriodicTask模型安排循环任务。例如,每隔一分钟就会运行一个时间间隔的任务,或者像每个月中的第一天中午一样由crontab指定的时间间隔。然而,我真正想要做的是安排一个固定日期的任务,然后在一个时间间隔重复。例如,首先在2016年3月3日的凌晨2点运行,然后每小时运行一次。 有没有办法在django和芹菜(有或没有djcelery)内实现此目的?谢谢