celery

    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

    0熱度

    2回答

    芹菜：限制隊列的任務

    我有多個隊列，我們​​假設這些是Q1和Q2。 我也有一些任務，其中之一是T1。 如何配置芹菜，以便工人只需要T1從Q1，並從不接受Q2T1？
    python celery amqp 2017-09-27

    0熱度

    1回答

    Celery任務 - 插入記錄到數據庫不起作用

    這是我第一次使用Celery（Celery 4.1，Python 3，Django 1.10）。我正在玩一個簡單的任務，將記錄插入我的主數據庫。奇怪的是我沒有收到錯誤消息，但是記錄沒有插入到數據庫中。下面的代碼： views.py： def test_view(request): test.delay() return HttpResponse() tasks.py fro
    django celery 2017-09-28

    0熱度

    1回答

    如何獲取從另一個容器（Docker Compose）運行的RabbitMQ的IP地址？

    我下面this教程。在那裏，我需要將RabbitMQ IP地址設置爲我的Celery設置。 我有我的搬運工，compose.yml三個容器：NGINX，Django的+芹菜，和RabbitMQ的。這些全部使用docker-compose up運行。但是，我需要在不同的容器中擁有celery.py的RabbitMQ IP地址。 通過谷歌尋找，docker-machine ip <container>
    python django docker rabbitmq celery 2017-09-29

    0熱度

    1回答

    django中不存在匹配查詢

    這裏我收到一個錯誤，匹配查詢不存在。它是工作在我的本地機器，但是當我在泊塢窗運行它，我得到這個錯誤，
    python django celery 2017-10-04

    0熱度

    1回答

    celerybeat如何通過調度器將參數傳遞給函數？

    即時通過celerybeat時間表傳遞參數給我的函數有問題。搜索後，看起來好像我應該能夠通過它們與args命令，但即時通過下面的錯誤。任何人都可以將我指向正確的方向嗎？ CELERYBEAT_SCHEDULE = { 'maintenance_mail_1_day': { 'task': 'home.tasks.maintenance_mail', 'schedu
    python celery celerybeat 2017-10-05

    0熱度

    1回答

    爲什麼加載頁面時不是芹菜任務異步？

    任務運行但我的頁面等待它完成任務，然後加載頁面。幾乎打敗了異步的目的，我在heroku上得到了一個超時 - 單獨的問題。所以，我打電話給views.py中的任務並將其發送到tasks.py。不知道我還需要什麼，但在邏輯上看起來很適合我？ settings.py BROKER_URL=['amqp://[email protected]//','cloudamqp'] BROKER_POOL_LI
    django heroku celery 2017-10-05

    0熱度

    1回答

    從kombu安裝（u'json'，）沒有編碼器

    我想我錯過了某個步驟，但我一直在找，並找不到它。當我運行我的芹菜任務時，當我撥打get_task.delay(args)時，我得到此錯誤消息no encoder installed for (u'json',)。我想我有自己的自定義序列化？ settings.py CELERY_ACCEPT_CONTENT = ['pickle'] CELERY_TASK_SERIALIZER = 'json'
    django celery kombu 2017-10-06

    0熱度

    1回答

    燒瓶返回「好」給用戶並處理數據

    我剛開始燒瓶，我正在製作一個服務器應用程序，它將處理一些請求，現在對於POST請求部分它有一個過程，這將需要一些時間意味着我將不得不讓用戶留在移動應用程序中，等待我回復他發送的第一個POST請求。 是否有某種方式可以將OK例如返回到移動應用程序並在後臺處理數據？ 什麼我迄今想到會是這樣的： - if request.method=='POST': #signal another proc
    python flask celery 2017-10-07

    1熱度

    2回答

    設置動態調度celerybeat

    我在我的Notification模型中有send_time字段。我想在當時向所有移動客戶端發送通知。 我在做什麼現在的問題是，我創建了一個任務，並安排它每分鐘 tasks.py @app.task(name='app.tasks.send_notification') def send_notification(): # here is logic to filter notifica
    django celery celerybeat 2017-10-10
最新問題