celery-task

    4熱度

    1回答

    透明地將Web請求上下文傳遞給芹菜任務

    我有一個多租戶設置，我想將某些客戶特定信息，特別是request.host傳遞給芹菜任務，理想情況下它應該在一個全局變量。有沒有辦法以對應用程序透明的方式進行設置？ 任務將被稱爲相同的方式： my_background_func.delay(foo, bar) 任務被定義的相同方式，不同之處在於它可以訪問一個被稱爲「請求」具有屬性「主機」全局變量： @celery_app.task def
    flask celery celery-task flask-extensions 2014-02-13

    2熱度

    1回答

    芹菜任務功能的自定義屬性

    我有芹菜任務功能，看起來像這 - @task(base=MyBaseTask) @my_custom_decorator def my_task(*args, **kwargs): my_task.ltc.some_func() #fails - attribute ltc doesn't exist on the object 和my_custom_decorator看起來像這
    python celery celery-task 2013-06-12

    7熱度

    3回答

    如何使用redis broker從芹菜中刪除任務？

    我有添加一些錯誤task到celery與Redis的broker ，但現在我想刪除不正確的task，我無法找到任何方式做到這一點 有一些命令或某些API來做這個 ？
    python celery celery-task celeryd 2013-06-19

    0熱度

    1回答

    如何在芹菜每個塊的執行結束時調用一個任務？

    我想在完成一大塊任務時更新一些聚合數據。它基本上是在一個塊的末尾實現和絃的概念。我如何實現這一點？
    celery celery-task djcelery 2013-06-20

    5熱度

    1回答

    如果其中一項任務失敗，將導致芹菜鏈中斷

    如果一個任務失敗，整個鏈斷裂，Celery鏈的重點是什麼？ 我有這樣的芹菜鏈： res = chain(workme.s (y=1111), workme2.s(2222), workme3.s(3333),)() 我做workme2失敗，這樣的重試次數： @celery.task(default_retry_delay=5, max_retries = 10, queue="sure")
    python django celery celery-task djcelery 2013-06-25

    3熱度

    1回答

    獲取當前芹菜任務ID在線程

    我想獲得一個正在運行的任務中任務ID的任何地方， 不知道我在哪個任務。 （這就是爲什麼我不能用https://stackoverflow.com/a/8096086/245024） 我想它是這樣的： @task def my_task(): foo() def foo(): logger.log(current_task_id) 這種模式將返回在許多不同的任務，我不想
    python celery django-celery celery-task 2013-11-24

    1熱度

    1回答

    子類芹菜任務爲`ClassTask` mixin

    面對我的問題與事實，我是新來的芹菜和這（1）可能已被回答在別的地方（如果是這樣，我找不到答案）或（ 2）可能有更好的方法來實現我的目標，而不是我直接要求的。 此外，我知道celery.contrib.methods，但task_method並不完全符合我的要求。 我的目標 我想創建一個類混入它可將整個類成芹菜任務。例如，一個mixin通過類似下面（其現在不運行）的代碼表示： from celery
    python celery celery-task 2014-01-15

    18熱度

    3回答

    芹菜停止執行鏈條

    我有一個定期執行的check_orders任務。它完成一組任務，以便我可以計算執行任務花費的時間，並在完成所有任務時執行某些操作（這是res.join [1]和grouped_subs的用途）分組的任務是鏈接任務。 我想要的是當第一個任務不符合條件（失敗）時，不要執行鏈中的第二個任務。我無法弄清楚這是否適合我的生活，我覺得這是作業隊列管理器的基本功能。當我嘗試了[2]之後我已經註釋掉的東西（引發異
    python celery django-celery celery-task celerybeat 2013-07-04

    2熱度

    1回答

    如何在django上測試時禁用芹菜任務

    我試圖測試一些包含調用芹菜任務的函數。任務涉及到第三方網站的調用，我需要在測試過程中避免它。 任何想法如何在測試過程中禁用所有芹菜任務？
    django django-celery celery-task 2013-10-29

    5熱度

    1回答

    在芹菜如何獲得任務狀態爲所有任務的具體任務名稱？

    在celery我想獲取特定任務名稱的所有任務的任務狀態。爲此嘗試下面的代碼。 import celery.events.state # Celery status instance. stat = celery.events.state.State() # task_by_type will return list of tasks. query = stat.tasks_by_typ
    python celery celery-task celeryd 2013-07-22
最新問題