celery-task

    0熱度

    1回答

    使用蟒蛇沒有Django的芹菜定期任務

    你好，我是芹菜和蟒蛇的新手。我正在使用rabbitmq-server創建一個簡單的任務。但我不知道如何實現使用芹菜在python節拍的定期任務。我搜索，但每一個地方，我與Django的定期任務。 我用這個代碼tasks.py： 芹菜芹菜進口從 時間導入的strftime app = Celery('tasks',broker='pyamqp://[email protected]//') @a
    python-2.7 celery-task celerybeat 2016-12-28

    0熱度

    1回答

    芹菜send_task和異常時重試

    我想retry（official doc）引發異常時的任務。芹菜允許通過使用形式self.retry(...) 現在，我不知道如何用戶self因爲我有一個沒有任何類的功能。 我的代碼是這樣的 .. imports ... app = Celery('elasticcelery') @app.task(name='rm_doc') def rm_doc(schema_id, id):
    celery django-celery celery-task 2016-10-10

    -2熱度

    1回答

    如何在Celery中創建條件子任務鏈？

    我正在創建一個應用程序，該應用程序將創建一個要執行的任務鏈，但鏈會根據用戶對該片添加的願望執行任務。 例如，如果用戶想要start_boo鏈可能是： def start_boo(): chain = start_foo.s() | start_bar.s() | start_baz.s() chain() 但是，如果foo和baz已經開始了，我們不希望這樣做;而是寧願是這樣
    python-3.x celery celery-task 2016-08-23

    0熱度

    1回答

    在HTTP請求中使用Celery任務ID安全嗎？

    我開始在基於Flask的Web應用程序中使用Celery來在服務器端運行異步任務。 一些資源得到一個「/動作」子資源以該用戶/客戶端可以發送包括JSON體指定動作的POST，例如： curl -H "Content-Type: application/json" -X POST \ -d '{"doPostprocessing": { "update": true}}}' \
    celery celery-task 2016-08-25

    -1熱度

    1回答

    僅在一臺機器上運行芹菜週期性任務

    我正在使用芹菜的django項目。我在名爲app1和app2的項目中有三個兩個大模塊。我爲兩臺獨立的機器上運行的應用程序創建了兩個芹菜應用程序。在app1和app2中有不同的任務，我想運行差異機器，它工作正常。但我的問題是我有一些periodic_tasks。我爲他們定義了一個名爲periodic_tasks的隊列。我想在單獨的第三臺機器上運行這些定期任務。或者在第三臺機器上，我只想運行週期性任務
    celery celery-task celerybeat celeryd 2016-10-17

    10熱度

    3回答

    如何將芹菜作業的參數輸入到要查詢的數據庫中;使用mysql

    我使用MySql作爲芹菜的後端結果。我也想將程序參數存儲在數據庫中。 例如： add.apply_async(args=[num1, num2, user] 在這種情況下，我想存儲在數據庫用戶的說法，讓我可以在以後查詢。 目前，我返回提供的存儲在數據庫中的參數。 def add(num1, num2, user): return [num1+num2, user] 但是，當任務處
    python mysql celery celery-task 2016-07-13

    1熱度

    1回答

    芹菜任務無法從項目內導入模塊的ImportError

    我想指出，只有在運行芹菜工時纔會出現以下錯誤。 與在終端下面的命令： celery -A MarketPlaceTasks worker --loglevel=info Traceback (most recent call last): File "/usr/lib/python2.7/dist-packages/celery/app/trace.py", line 218, in
    python python-2.7 enums celery celery-task 2016-09-14

    0熱度

    1回答

    工作人員無法在燒瓶芹菜任務中獲取新數據插入到

    我有三臺服務器運行我的程序，每臺服務器有八臺芹菜工人從redis獲取任務。也就是說每個服務器的芹菜任務可以由另一個服務器執行。 在每個服務器： 提交更改和呼叫任務 ... try: db.session.commit() except Exception as e: current_app.logger.error(str(e)) db.se
    python flask celery celery-task celeryd 2016-11-04

    0熱度

    1回答

    使用芹菜節拍在多個時間點（使用不同參數）調度任務

    我試圖實現的內容 編寫一個調度程序，它使用數據庫在不同的時間安排類似的任務。 ，因爲我是用芹菜節拍相同，下面的代碼片段會給一個想法 try: reader = MongoReader() except: raise try: tasks = reader.get_scheduled_tasks() except: raise celerybeat_s
    python-3.x celery scheduler celery-task celerybeat 2016-11-09

    1熱度

    1回答

    芹菜 - 散裝隊列任務

    我已經一些排隊的芹菜任務大量（1000），例如起見代碼讓我們說這就是： for x in xrange(2000): example_task.delay(x) 是否有排隊的更好/更有效的方法大量的任務一次？他們都有不同的論點。
    python celery celery-task 2016-11-18
最新問題