djcelery

    1熱度

    1回答

    芹菜和django一起使用。我必須爲用戶提供一個選項,以便檢查失敗的任務,並根據需要修改失敗的任務數據並重新提交。我看過這個主題 - Celery Storing unrecoverable task failures for later resubmission。 所以我明白,芹菜不存儲任務的原始參數和kwargs,我們需要照顧。我很好,這樣做。 但是,如果我有一個提交鏈「SubTask1 |

    6熱度

    2回答

    我試圖在我的django項目上設置芹菜時,對這兩個應用程序之間的差異感到困惑。 兩者之間有什麼區別?在網上閱讀教程時,我看到他們都使用了,我不確定哪些對我最好。看起來,djcelery有點像芹菜,但爲django量身定製?但是芹菜不需要包含在安裝的應用程序中,而djcelery則可以。 謝謝

    3熱度

    2回答

    對異步進程運行manage.py celeryd時,一切都按預期工作,但每次啓動時都會出現奇怪的警告。這不會導致任何錯誤,但我很難讓它消失或理解其含義。 這就是: /home/user/lib/python2.7/billiard-2.7.3.15-py2.7-linux -x86_64.egg/billiard/forking.py:455: UserWarning: Will add

    0熱度

    1回答

    我有一個django芹菜視圖,它執行某些任務,並在任務完成後成功將其寫入數據庫。 我這樣做: result = file.delay(password, source12, destination) 而且, if result.successful() is True: #writes into database 但是任務已完成執行後不進入,如果condition.I試圖用re

    3熱度

    1回答

    我在django芹菜中使用數據庫後端。任務信息存儲在數據庫中名爲celery_taskmeta的表中。 這是我的任務: @celery.task def file_transfer(password, source12, destination): result = subprocess.Popen(['sshpass', '-p', password, 'rsync', '-az',

    1熱度

    1回答

    當我嘗試用芹菜和芹菜節拍啓動我的開發服務器時,出現以下錯誤。有一天這件事情第二天起作用它不會,我沒有改變任何可以解釋這一點的東西。我開始我的服務器使用的工頭和Procfile.dev像這樣: Procfile: web: python manage.py runserver celeryd: python manage.py celeryd -E -B --loglevel=INFO --con

    2熱度

    1回答

    我有芹菜任務是這樣的: @celery.task def file_transfer(password, source12, destination): result = subprocess.Popen(['sshpass', '-p', password, 'rsync', '-avz', source12, destination], stderr=su

    2熱度

    1回答

    我有一個生成通過Python的itertools產品大名單的程序;基本上是一組大量的單詞組合。有多個集合可以運行products()函數。我想要做的是讓Celery幫忙,把每一套芹菜任務分配給不同的芹菜任務,最後把它們結合起來。我的理解是和絃是做到這一點的方法。 所以基本上我有這樣的: callback = tabulate_results.subtask() header = [] for

    1熱度

    1回答

    所以我有一個任務創建一個工作目錄並在那裏完成所有工作。 該任務從服務器A調用,並在工作服務器上執行。 我需要確保任務完成後刪除工作目錄/ 取消。 我添加了一個任務,撤銷的處理程序,它看起來像這樣: @task def my_task(value): task_id = current_task.request.id work_dir = os.path.join(BASE_

    0熱度

    1回答

    我正嘗試異步地創建一堆芹菜任務。假設有1000個異步啓動的任務,並且我只有一個celeryd進程運行來執行任務。芹菜將創建多少個線程來處理這些任務? 如果芹菜有多個線程自動啓動來處理任務隊列,如何限制芹菜在給定的時間點只執行100個線程。 謝謝。