celery-task

    2熱度

    1回答

    芹菜：@shared_task和非標準BROKER_URL

    我有一個使用包括虛擬主機的BROKER_URL的Celery 3.1.19設置。 # in settings.py BROKER_URL = 'amqp://guest:[email protected]:5672/yard' 芹菜正常啓動，加載的任務，這些任務我的@ app.task裝飾做工精細內定義。我認爲我的rabbitmq和芹菜配置是正確的。 任務，我用@shared_tasks進行
    python rabbitmq celery-task 2015-11-20

    3熱度

    2回答

    芹菜工人詳細信息

    我有芹菜任務，有100個輸入數據在隊列中，需要使用5名工人執行。 如何獲取哪個工作人員正在執行哪個輸入？ 每個工人都執行了多少個輸入及其狀態？ 如果任何任務失敗，如何分別獲取失敗的輸入數據並用可用的工作人員重新執行？ 是否有任何可能的方式來定製芹菜根據工人的具體情況。 我們可以結合芹菜工人限制和花 我沒有使用任何框架。
    python celery-task 2016-01-12

    1熱度

    1回答

    python芹菜db更新，其中是執行的密碼

    我有一個使用芹菜爲我的分佈式任務的python應用程序。我需要更好地理解保護我的應用程序以及工作人員獲得它的課程的位置。 所以我有一個tasks.py文件，我開始對計算機192.168.0.10 from celery import Celery import peewee from models import Album, Artist app = Celery('tasks', bro
    python celery celery-task 2016-01-20

    14熱度

    1回答

    發送電子郵件任務具有正確的上下文

    此代碼是我的芹菜工人腳本： from app import celery, create_app app = create_app('default') app.app_context().push() 當我嘗試運行工人我會得到這個錯誤： File "/home/vagrant/myproject/venv/app/mymail.py", line 29, in send_email_ce
    python python-2.7 flask celery celery-task 2015-12-04

    2熱度

    1回答

    定期任務在django芹菜中不能正常工作

    你好朋友，我需要你的幫助，在django應用程序的定期任務中。我正在嘗試使用芹菜進行定期任務，但它不能正常工作。我有一個簡單的任務，其中只有一個打印語句。芹菜工作只適用於第一時間，我也試過「芹菜拍」，但沒有得到結果 我「task.py」是 from __future__ import absolute_import from myapp.celery import app from celer
    python django-celery celery-task celerybeat periodic-task 2015-10-16

    0熱度

    1回答

    推遲執行芹菜任務

    我想把任務放到芹菜上，但是我希望任務在30秒後執行，而不是立即執行。 例如： @celery.task def task(): # waiting 30 seconds do something.... 我可以用它來使它：sleep(30)，但有沒有更好的解決辦法？
    python celery celery-task 2015-12-09

    3熱度

    1回答

    收集來自並行Celery任務執行的結果

    我正在嘗試實現一個相當簡單的Celery工作流，​​其中我接收到與元組（或列表）相同任務的多個並行調用的結果。 @app.task def add(x, y): return x + y @app.task def master(): return group(add.s(1, 2), add.s(3, 4))() 由此，我想在一個通用的方法檢索(3, 7)，即，在
    python celery celery-task 2015-12-14

    0熱度

    1回答

    限制在Python Celery eta？

    芹菜是否對任務有eta限制？我想在12天后執行方法foo，芹菜會有問題嗎？或者我需要配置任何芹菜設置這麼長的eta？ next_run = datetime.now() + timedelta(days = 12) foo.apply_async(args=[], eta = next_run)
    python asynchronous celery celery-task 2015-12-16

    0熱度

    1回答

    芹菜任務內的貨幣

    我是蟒蛇和芹菜的新手。 我的工作是非常沉重的IO界限，需要做http請求，查詢redshift，mysql並寫入mysql。 我們正在考慮使用芹菜來連續運行作業，但我認爲如果有可能在我的芹菜任務中進行併發處理。基本上，每個任務都可以批量處理一組數據，異步進行調用。 我試圖使用龍捲風gen.coroutine，但沒有明確的原因與芹菜失敗。 gevent或eventlet會好嗎？任何人都可以提出一些建
    python-2.7 concurrency celery celery-task 2015-11-03

    4熱度

    4回答

    氣流 - Python文件不在同一個DAG文件夾中

    我想使用Airflow執行一個簡單的任務python。 from __future__ import print_function from airflow.operators.python_operator import PythonOperator from airflow.models import DAG from datetime import datetime, timedelt
    python celery celery-task airflow 2015-11-03
最新問題