celery-task

    1熱度

    2回答

    註冊基於類的任務

    我正在使用Celery版本4.0.2。 與先前版本的Celery相比，似乎基於類的任務沒有自動註冊（即，如果您配置了自動發現功能）。 但是，我甚至沒有實現手動註冊基於類的任務。 按照芹菜更改日誌： http://docs.celeryproject.org/en/latest/changelog.html#version-4-0-1 因爲4.0.1版本，應該可以註冊手動任務： from celer
    python celery celery-task 2017-07-04

    0熱度

    1回答

    如何在芹菜中添加日誌處理程序？

    所以我這裏我tasks.py是exerpt： import builtins import logging import os import urllib import inspect from celery import Celery from common.environment_helper import EnvironmentHelper from config impor
    python asynchronous logging celery celery-task 2017-08-28

    0熱度

    1回答

    如何消費者從一個不同的應用程序中的芹菜隊列

    我在我的生產者應用程序中使用Celery將API調用插入到我的RabbitMQ中的代碼如下。 celery.send_task('tasks.process_redox', (payload,), queue="redox_inbound") 我想知道，代碼看起來會從該隊列中消耗什麼？我有下面但它不工作，似乎無法找到它在 @celery.task() def process_redox(pa
    python rabbitmq celery celery-task 2017-07-14

    1熱度

    1回答

    與多個應用程序一起使用Celery隊列

    如何爲多個應用程序使用同名的Celery隊列？ 我有具有N客戶端數據庫，這都需要在一個特定的隊列M. 對於每個客戶端數據庫芹菜任務處理的應用程序，我有一個單獨的芹菜工人我啓動等： celery worker -A client1 -n [email protected]%h -P solo -Q long celery worker -A client2 -n [email protected]
    celery django-celery celery-task 2017-07-18

    1熱度

    1回答

    將任務添加到現有的組或和絃

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

    7熱度

    2回答

    在芹菜中的多個隊列中優先隊列？

    我們將芹菜用於異步後臺任務，我們有2個隊列用於不同的優先級任務。我們有2個節點集羣單獨服務它們。事情如預期般運作良好。 問： 我們得到多爲低優先級任務。爲了優化資源利用率，我想知道是否有辦法配置worker（偵聽高優先級隊列）來偵聽這兩個隊列。但只要有一份工作在那裏，就從更高優先級的隊列中選擇工作？否則返回低優先級隊列。 我已經通過討論@Celery Task Priority討論了基於優先級的任
    celery celery-task 2017-09-13

    0熱度

    1回答

    阻止任務在芹菜和絃中運行的任務選項

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

    1熱度

    1回答

    （芹菜）：在特定的工作人員中運行任務？

    我從芹菜中不同的服務器很多工人，（下面的圖片顯示） 很多任務： @task(name="task1") def task1(): ....... @task(name="task2") def task2(): ...... 我只想對「[email protected]_website運行「獨立寫作」 「工人。我應該如何配置？ celery -A tasks -n
    celery worker celery-task 2017-07-28

    0熱度

    1回答

    過程不會與芹菜中的多處理模塊產生

    我有一個非常標準的設置：Django + Rabbitmq +芹菜。 我想在芹菜中產生一個使用標準python多處理模塊的進程。 我注意到，過程本身並沒有產卵。什麼可能是沒有產生這個過程的原因。這裏是代碼： import multiprocessing as mp from celery.schedules import crontab from celery.decorators impor
    multiprocessing celery python-multiprocessing celery-task celerybeat 2017-09-27

    1熱度

    1回答

    send_task只適用於特定用戶

    設置： Celery 4.1，RabbitMQ 3.6.1（作爲經紀人），Redis（作爲後端，這裏不相關）。 有兩個兔子用戶： admin_user與.* .* .*權限。 remote_user權限爲ack ack ack。 admin_user可觸發任務並由芹菜工作人員用來處理任務。 remote_user僅可以觸發一個類型的任務 - ack和在專用ack隊列後來排入由ack工人被消耗（由a
    rabbitmq celery amqp celery-task rabbitmqctl 2017-08-13
最新問題