kombu

    0熱度

    1回答

    Python的海帶消費者獲取隊列消息，但回調不能觸發

    如果我跑跟着代碼，我發現我可以從隊列中獲取消息，但callback不能觸發 from kombu.mixins import ConsumerMixin from kombu import Exchange, Queue task_exchange = Exchange('nginx', type='direct') task_queues = [Queue(exchange=task_e
    kombu 2016-05-20

    1熱度

    1回答

    芹菜拍不啓動的EOFError（「跑出輸入」）

    一切工作完美的罰款，直至： celery beat v3.1.18 (Cipater) is starting. __ - ... __ - _ Configuration -> . broker -> amqp://user:**@staging-api.user-app.com:5672// . loader -> celery.loaders.app.AppLoad
    celery celerybeat kombu 2015-09-25

    0熱度

    2回答

    Kombu /芹菜消息

    我有一個簡單的應用程序，發送&接收消息，kombu，並使用芹菜任務消息。 Kombu alon，我可以正確接收消息。當我發送「你好」時，kombu收到「你好」。但是當我添加任務時，kombu收到的是芹菜的任務ID。 我的這個項目的目的是讓我可以安排何時發送和接收消息，因此Celery。 我想知道的是爲什麼kombu接收任務ID而不是發送的消息？我已經搜索和搜索，並沒有在這個問題上找到任何相關的結果
    python celery celery-task kombu 2015-06-26

    0熱度

    1回答

    無法使用芹菜作爲經紀人發送郵件

    我是新來的芹菜試圖發送電子郵件，但我無法接收郵件。 settings.py import djcelery djcelery.setup_loader() BROKER_URL = 'django://' INSTALLED_APPS = ( 'grappelli', 'django.contrib.admin', 'django.contrib.auth', 'django.con
    python django django-celery kombu 2015-10-05

    0熱度

    1回答

    芹菜花是可以關閉工人，但無法重新啓動它

    我已經安裝了芹菜，Django芹菜，Kombu &花。 芹菜花監測罰款。它能夠關閉工作人員，但無法重新啓動它們。 花響應： [I 140903 15:49:12 web:1856] 200 GET/(127.0.0.1) 77.49ms [I 140903 15:49:13 web:1856] 304 GET /static/img/glyphicons-halflings.png (127.0
    python django celery kombu flower 2014-09-03

    0熱度

    1回答

    芹菜kombu失敗後，self.connections.acquire

    當我的芹菜服務運行7-10天后，我收到了這個異常從不知從哪裏，這導致我的任務不被處理。重啓芹菜可以解決問題。 INTERNAL ERROR: RuntimeError('Acquire on closed pool',) Traceback (most recent call last): File "/usr/lib/python2.7/dist-packages/celery/ap
    python rabbitmq celery kombu 2016-04-22

    2熱度

    1回答

    kombu.exceptions.EncodeError：[<Vkwallpost：Vkwallpost對象> ...不是JSON序列化 - 只在本地主機上

    我使用的是Django + Celery + Kombu + rabbitmq：我的任務已成功完成（Ubuntu 14.04） [2016-01-21 02:29:05,027: INFO/MainProcess] Task vk_wall.tasks.get_wallposts_by_owner_id[cbdfbdf7-1f01-4cf1-bd5a-77fae7a07003] succeeded
    python django celery kombu 2016-01-20

    1熱度

    1回答

    使用kombu從多個虛擬主機消耗隊列

    我有以下情況。我有一個虛擬主機列表。在每個虛擬主機中，我有一個隊列（所有虛擬主機中都有相同的名稱）。有沒有辦法同時消耗隊列？ （我不想爲每個虛擬主機創建一個單獨的進程），我想有一個消費者，消耗所有的隊列。 我正在使用kombu和rabbitmq。 由於
    rabbitmq producer-consumer kombu 2016-05-10

    4熱度

    1回答

    芹菜：socket.error超時

    我使用： celery==3.1.12 kombu==3.0.19 amqp==1.4.5 芹菜工人開始： celery worker --without-gossip --without-heartbeat --without-mingle 芹菜setiings： CELERY_ALWAYS_EAGER = False CELERY_EAGER_PROPAGATES_EXCEPTI
    python sockets rabbitmq celery kombu 2016-03-24

    3熱度

    1回答

    使用Kombu ConsumerMixin，如何聲明多個綁定？

    我有一個名爲experiment的RabbitMQ主題交換。我正在構建一個消費者，我希望接收所有以「foo」開頭的路由鍵和其路由鍵以「bar」開頭的消息。 根據RabbitMQ文檔，並基於我在管理UI中的實驗，應該有一個交換，一個隊列和兩個連接它們的綁定（foo.#和bar.#）。 我不知道如何使用Kombu的ConsumerMixin來表達這一點。我覺得我應該可以這樣做： q = Queue(e
    python rabbitmq amqp kombu 2016-05-13
最新問題