djcelery

    1热度

    1回答

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

    0热度

    1回答

    我正在使用Django 1.11和Celery 4.0.2。 我们正在使用运行于kubernetes的PaaS(OpenShift 3) - Dockers。 我使用的是Python图像,它只会运行在启动一个命令(并按照退出代码 - 如果未能重新启动), 我怎么能在我运行Django同时运行celery worker以确保他们中的一个出现故障会杀死两个过程(工人和Django的) 我使用wsgi和

    0热度

    1回答

    我正在使用Django和Celery,并安装了应用程序djcelery。我试图在命令行上启动多个工作者。我可以运行python manage.py celeryd,没有任何问题。包括Celeryd Docs在内的任何地方都表示,该命令是celeryd-multi以启动多个工作人员。我尝试运行python manage.py celeryd-multi,我得到了Unknown command: 'c

    0热度

    1回答

    我有没有创造我的模型的周期性芹菜任务 @periodic_task(run_every=timedelta(seconds=1)) def store_products(): products = get_products() for product in products: Product.objects.create( name=product['

    7热度

    1回答

    所以我使用django和芹菜。 rabbitmq是经纪人。 redis是缓存。 mysql是db。 (在本地主机的一切) 我使用python2.7和使用的virtualenv基于虚拟环境 我开始在默认端口 Redis的服务器(本地)在一个新的终端,我跑 python manage.py runserver 在一个新的终端I启动芹菜像这样 celery -A ds_django worker -

    0热度

    1回答

    我不擅长英语,所以如果你不明白我的句子,给我任何评论。 我在django上使用芹菜作定期任务。 CELERYBEAT_SCHEDULE = { 'send_sms_one_pm': { 'task': 'tasks.send_one_pm', 'schedule': crontab(minute=0, hour=13), }, 'send_sm

    0热度

    1回答

    @shared_task def forgot_email(subject,user_cipher,key_cipher,to): print "comes here in the mail" try: email_content = {'user_cipher':user_cipher,'key_cipher': key_cipher} messag

    1热度

    2回答

    我知道|是一个按位“或”操作符,但它让我想知道如何在芹菜的情况下工作,而链接多个任务。 (first_task.s(url) | second_tasks.s()).apply_async() 我知道,第二个任务将采取的第一个函数的结果作为ARGS但是这怎么可能? '|'在哪里在dj-celery源代码中重载? @task def second_task(results): do_

    -3热度

    1回答

    我想做一个项目使用嵌套if。但它不起作用。为什么? 我的代码, schedule = Schedule.objects.all() for c in schedule : p = c.poll e = c.end_time s = c.start_time n = c.no_of_response now = timezone.

    1热度

    1回答

    我目前使用django 1.11,为了兼容性的原因,我不得不使用旧版本的芹菜(3.1)。 我想升级到芹菜4.0,因为我们的应用程序的另一部分需要更高版本的芹菜。 芹菜,django-celery和django 1.11是否兼容?文档中说celery 4.0与1.8版本以后的所有django版本都兼容,但这似乎并非如此。 python manage.py makemigrations <appnam