celery-task

    1熱度

    1回答

    我想通過HTTP使用芹菜類的HttpDispatch進行任務調用,但我需要設置授權標頭。我怎樣才能做到這一點? from celery.task.http import HttpDispatch request = HttpDispatch( url='http://example.com/multiply', method='GET', {10}) request.disp

    1熱度

    2回答

    好吧,我想我有一個相對簡單的問題,就像我用它打磚牆。我有一個應用程序和一個網頁,允許您使用celery & redis(broker)在服務器端運行多個腳本。 所有我想要做的是,當我開始一個任務給它一個名稱/ ID(任務將被描繪成在客戶端上的按鈕),即 @app.route('/start_upgrade/<task_name>') def start_upgrade(task_name):

    0熱度

    2回答

    我是芹菜任務的單元測試。 我有鏈式任務也有組,所以會產生和絃。 測試應該是這樣的: 運行芹菜任務(延遲) 等待任務和全部任務 斷言 我試過如下: def wait_for_result(result): result.get() for child in result.children or list(): if isinstance(child, GroupRes

    2熱度

    1回答

    目前,djcelery允許我通過PeriodicTask模型安排循環任務。例如,每隔一分鐘就會運行一個時間間隔的任務,或者像每個月中的第一天中午一樣由crontab指定的時間間隔。然而,我真正想要做的是安排一個固定日期的任務,然後在一個時間間隔重複。例如,首先在2016年3月3日的凌晨2點運行,然後每小時運行一次。 有沒有辦法在django和芹菜(有或沒有djcelery)內實現此目的?謝謝

    3熱度

    3回答

    我在我的django應用程序中使用芹菜,並且我設置了芹菜花來監控芹菜的任務。我已經設置了在註冊/提交/ FP等事件時將電子郵件發送給用戶的任務。現在Flower給了我一個很好的任務細節和狀態。現在,對於每一次失敗的任務,我都想要一封電子郵件發送到我的帳戶,以便我沒有每天檢查花朵是否有失敗的任務。 我確實在我的settings.py文件 CELERY_SEND_TASK_ERROR_EMAILS =

    0熱度

    2回答

    所以這就是我想要做的。我有一個計劃任務,每X分鐘運行一次。在任務中,我創建了一組我希望它們相互平行運行的任務。他們都完成後,我想記錄,如果該組成功完成或沒有。這是我的代碼: @shared_task(base=HandlersImplTenantTask, acks_late=True) def my_scheduled_task(): try: needed_ids =

    1熱度

    1回答

    我最近安裝了花0.8.4,我在Digital Ocean創建了一個快照,然後使用這個快照啓動一個新的服務器。現在花仍然顯示老工人的名字。如何在保留現有工人信息的同時刪除此工作人員。 芹菜開始: worker -n [email protected]%h -f /usr/local/src/imbue/application/imbue/log/celeryd.log --loglevel=DEBU

    1熱度

    1回答

    在獲取我在創建芹菜任務之前創建的對象時出現MyModel matching query does not exist.錯誤。我正在從我的APIView中調用該任務。 my_model_obj = MyModel(x=1, y=2) my_model_obj.save() my_celery_task.delay(my_model_obj.id) 我的任務函數中,我做的: @task()

    0熱度

    1回答

    我有一個芹菜任務,循環接收者列表發送消息。如果任何發送調用失敗,我不希望芹菜任務退出,而是繼續循環中的其他項目。 在我的情況下,這不會發生在task.retry(throw = False)上。我確實看到這個任務正在退出,而沒有做任何事,甚至進一步迭代循環。 我不想要弦和鏈,它不是並行任務執行。我怎樣才能做到這一點? @celery_app.task() def send_msg_to_lis

    0熱度

    1回答

    我已將API與我的Django網站集成。對於通過API的完整訂單,需要發送和接收5個請求和響應。最後2個請求並不是非常重要的,要依次發送。我已將這2個請求分配給芹菜任務。 情景:我發出處理10個訂單的請求,因此每個訂單有5個請求,其中2個請求分配給芹菜任務。因此芹菜共有10項任務將由經紀人分配。每個任務都有2個請求。 結果:正在進行API調用時,芹菜未被分配全部10個任務,因此對於每組10個任務,