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