celery

    0熱度

    1回答

    我必須使用Celery 4.0.2和RabbitMQ 3.6.10來處理異步任務。然後,我按照這個教程:https://www.codementor.io/uditagarwal/asynchronous-tasks-using-celery-with-django-du1087f5k 但是,我的任務有一個小問題,因爲它不可能有結果。我的任務始終處於「待定」狀態。 我的問題是我得做什麼才能得到結果

    0熱度

    1回答

    我在記錄設置上遇到困難。我正在運行芹菜工人和擊敗使用主管。 芹菜是django項目。 我創建了一個文件夾logs我想要所有日誌。 權限: /日誌/ drwxrwxrwx 2 django django 4096 Jul 20 15:03 logs /日誌/ any_file total 1488 drwxrwxrwx 2 django django 4096 Jul 20 15:03 .

    1熱度

    1回答

    請考慮以下方案; 有3種不同類型的任務。 A,B和C。 A旨在生成B的輸入,B應接收來自A的輸入後創建許多C任務。 在開始,我只能夠定義group(A, B)爲C s由B執行。但我想等待所有C任務完成,以便得出主要任務完成的結論。 有沒有辦法通過使用芹菜工具來做到這一點?

    0熱度

    2回答

    我創建一個使用應用程序工廠模式的瓶服務,我需要使用芹菜異步任務。我也使用docker和docker-compose來包含和運行一切。我的結構是這樣的: server | +-- manage.py +-- docker-compose.yml +-- requirements.txt +-- Dockerfile | +-- project | | | +-- api |

    0熱度

    1回答

    我在我的django項目中使用了redis的Celery。我試圖從celery_app延遲10秒鐘來調用expire函數。每當函數執行時,該頁面只是說本地主機沒有響應。我假設它是因爲我的後端不工作?任何人都可以幫忙嗎? P.S.如果我刪除了2線,結果 celery_app.py from __future__ import absolute_import import os from cele

    1熱度

    1回答

    我有一個有很多Celery任務的項目,其中一個任務一次只能執行一個(這是對第三方API的請求,它禁止多個併發連接)。 我可以通過啓動一個獨立的芹菜過程與單獨的隊列和併發實現這一1. 普通芹菜過程: celery -A sourcery worker -Q default -c 4 一個單獨的單工作進程: celery -A sourcery worker -Q separate_queue -

    0熱度

    1回答

    我有這樣的任務: @app.task(name='somesmalltask') def some_small_task(some_input): some_list = [] #do something to some_list return some_list 是否有可能做這樣的事情: all_results = map(lambda x: some_sma

    1熱度

    1回答

    我的問題是我有一個函數,通過芹菜的apply_async每3天執行一次。如果未在2天內獲得批准,我會設置掛單以取消掛單。問題是,如果管理員重新考慮它並將狀態更改回掛起狀態,則應重新啓動計時器,過期不終止。我不確定是否芹菜的.revoke()會明確地取消一個.expire()調用。我不希望他們都停止一個具體的。誰能幫忙? tasks.py @app.task(name="expire") def

    0熱度

    1回答

    我試圖將現有的芹菜組呼叫轉換成和絃以防止死鎖。以前的代碼有重試和到期時間。我設法讓和絃在沒有這些設置的情況下工作,但是當我嘗試應用設置時,我沒有看到正在運行的任務。我沒有看到有關在整個和絃上應用相同設置的文檔中的任何內容。我正在運行芹菜版本3.1.6。 以前的代碼: jobs = group([reset_device.s(topoid, dev_list[i], waittime

    0熱度

    1回答

    使用芹菜3.x中,在任務完成時,工人將日誌和實際時間花了,喜歡這裏Celery time statistics per-task-name 描述升級到4.1後,芹菜工人不再日誌任務結果,甚至沒有未處理的異常,但對於後者,您可以輕鬆使用信號處理程序,我想知道什麼更改或什麼是錯誤的,記錄任務完成時很重要。