pika

1熱度

1回答

我有一堆芹菜任務將其結果發送到RabbitMQ消息隊列。發佈的結果可能會變得非常大（高達幾兆）。對於將大量數據放入RabbitMQ消息是否是一個好主意，意見不統一，但我在其他情況下看到了這項工作，只要內存得到控制，它似乎就可以工作。但是，對於我目前的一組任務，兔子似乎只是丟棄似乎太大的消息。我已經縮小它歸結爲一個相當簡單的測試用例： #!/usr/bin/env python import s

15熱度

2回答

沒有處理程序可以發現記錄「pika.adapters.blocking_connection」

類似的問題似乎都基於使用自定義記錄器，我很高興只使用默認/無。我的pika python應用程序運行並接收消息，但在幾秒鐘後崩潰No handlers could be found for logger "pika.adapters.blocking_connection"，有什麼想法？ import pika credentials = pika.PlainCredentials('xxx_

0熱度

2回答

我怎樣才能傳遞參數鼠兔回調

我使用鼠用RabbitMQ的服務器如下進行交互： 1. P1信息發送到的RabbitMQ 2. C1是PyQt4的桌面托盤應用程序，這將顯示一旦收到上述消息。的代碼如下： import sip sip.setapi('QVariant', 2) from PyQt4 import QtCore, QtGui import systray_rc class Window(QtGui

2熱度

1回答

文檔在鼠兔

從「queue_declare」結果對象在下面的教程：http://www.rabbitmq.com/tutorials/tutorial-three-python.html，有下面的代碼。 result = channel.queue_declare(exclusive=True) queue_name = result.method.queue 這哪裏是「結果」對象爲記錄鼠兔？我

1熱度

1回答

應用程序崩潰後，錯過了太多的心跳

我有一個應用程序，分發負載的一堆工人。到目前爲止，所有工作人員都在同一臺虛擬機上運行，而且還不需要擴展。我的問題是，像每3-4天一樣，工作人員崩潰與下面的錯誤消息 - 客戶端和rabbitmq服務器之間沒有接觸1200秒（我猜）。 Traceback (most recent call last): File "/var/www/vhosts/niklas/workers/buil

9熱度

2回答

在Pika或RabbitMQ中，如何檢查是否有消費者目前正在消費？

我想檢查一下消費者/工作者是否存在消費消息我即將發送。如果沒有任何工人，我將開始一些工人（消費者和出版商都在一臺機器上），然後去發佈消息。如果有像connection.check_if_has_consumers一個功能，我會有點實現它這樣的 - import pika import workers # code for publishing to worker queue conne

3熱度

1回答

Django - 在apache根據請求創建的所有進程之間共享一個RabbitMQ連接？

我堆棧Django的1.3（Python 2.7版） + 阿帕奇 + mod_wsgi的阿帕奇派生每個請求一個新的進程。有時候在那些我必須請求發佈消息的RabbitMQ的一些任務重稍後完成（如通知關於他們剛剛發佈了一個貓的照片別人的追隨者）。發佈涉及到連接RabbitMQ，這是昂貴的。（見本SO問題：RabbitMQ create connection is an expensive ope

1熱度

1回答

如何將kombu與pika異步一起使用？

我想用kombu編寫一個服務器，它將同時處理兩條消息。我的運輸是rabbitmq。我相信答案是用海帶與鼠兔，異步。但是，似乎沒有關於如何執行此操作的任何文檔。幫助？

11熱度

1回答

Pika + RabbitMQ：將basic_qos設置爲prefetch = 1依然會佔用隊列中的所有消息

我有一個python worker客戶端，它將每個鉤子綁定到RabbitMQ隊列上的10個worker。有點像這樣： #!/usr/bin/python worker_count=10 def mqworker(queue, configurer): connection = pika.BlockingConnection(pika.ConnectionParameters(hos

1熱度

1回答

Pika超時問題與RabbitMQ

我與Pika提供超時錯誤的問題。相同的代碼（下面）在其他環境中工作正常，但在這個失敗。 connection = pika.BlockingConnection(pika.ConnectionParameters(host=host)) rabbitmqctl狀態 [{pid,30059}, {running_applications,[{rabbit,"RabbitMQ","2.8.2"}