amqp

8熱度

2回答

RabbitMQ爲我正在計劃的項目打勾，保存一個。我會讓不同的工作人員在隊列中進行監聽，並且他們首先處理最新的消息（即最新的序列號）（LIFO）是很重要的。我的應用程序是這樣的新消息幾乎過時的舊信息。如果你有工作人員，你仍然可以處理舊信息，但重要的是先做好新信息。拖網各種論壇和這樣我只能看到一個解決方案，這是對客戶端來處理消息時，它應該首先之後：消耗所有消息他們根據再定購序列號重新提交給

24熱度

4回答

用於AMQP的良好Python庫

您能推薦用於訪問AMQP（RabbitMQ）的Python庫嗎？從我的研究pika似乎是首選。

2熱度

2回答

Python/Django AMQP？

我有一個Django的Web應用程序，它創建並保存數據庫中的作業。對於每項工作，我都必須發送電子郵件並將數據導出到其他系統。我想做異步。推薦的方法是什麼？它必須可靠（如果服務意外停止，則不會錯過任何作業）。如果發生錯誤，必須有簡單的方法來查找日誌。我希望能夠輕鬆添加更多可處理作業的工作人員。也許它會更好，如果作業隊列是相同的數據庫表，所以我可以通過簡單地更改他們在數據庫中的狀態輕鬆取消作

0熱度

2回答

我可以選擇哪一個？ SSH還是AMQP？

我的應用程序在Windows中運行，並使用C++/Qt實施。該應用程序將調用部署在Linux服務器中的另一個應用程序，該應用程序將調用一些第三方工具。 Linux服務器應用程序將基於第三方工具的運行發送一些狀態更新。通常，第三方應用程序將運行數小時，並且更新將在各個階段發送。除了狀態更新之外，Linux服務器還可能需要發送一些文件，Windows客戶端還會發送一些運行這些第三方工具所需的文件。

2熱度

1回答

Python扭曲 - 潛在經紀人和服務器端發生

背景：我有一個gtk客戶端，它使用了扭曲和透視代理來執行遠程對象執行和服務器/客戶端通信。這對我來說非常有用，並且可以輕鬆開始工作。我有我需要從客戶端進行通信的amqp（Message Queue/MQ）服務。我在客戶端和服務器周圍採用了一種安全模式，並且我不希望客戶端直接與Message Queue服務器通信，也不希望客戶端使用其他依賴於amqp庫的服務。理想情況下，我希望客戶端通過透視

2熱度

1回答

Qpid - 負載均衡的消息對消費者有不同的性能特點

我有以下情形：我推100個消息2名消費者共享的隊列。兩個訂閱者都以預獲取模式和顯式模式訂閱隊列。在處理每條消息之後，每個訂閱者接受消息以將其從隊列中刪除。僞代碼看喜歡的是： OnMessageTransfer(message) : DoSomethingWithMessage(message) Session.MessageAccept(message) 的消息是正確的負

5熱度

2回答

將現有的JMS庫與AMQP代理（RabbitMQ）結合使用

我們使用RabbitMQ和Spring-AMQP作爲我們的消息傳遞系統。但是有很多使用JMS的Java庫，我寧願不重寫到AMQP。我未能向Google發送將使用AMQP的JMS客戶端。我應該重寫庫直接使用AMQP嗎？

0熱度

3回答

如何在使用php擴展AMQP和RabbitMQ的消息上設置delivery_mode？

我已經設置了整個基礎設施，這意味着我已經配置了使用AMQP擴展名http://www.php.net/manual/en/book.amqp.php的php。我建立了持久的交流和隊列。現在我知道我應該根據http://www.rabbitmq.com/tutorial-two-python.html發佈delivery_mode = 2（或等效於php）的消息。我不知道我是否可以這樣做，如果是的話

13熱度

1回答

用於RPC API的文檔工具

有許多用於源代碼和API文檔的好工具（Doxygen,Headerdoc,Sphinx，僅舉幾例）。但是，它們都不擅長爲通過RPC接口提供的API生成文檔（如果您有關於如何使用這些工具合成RPC API文檔的建議，無論如何都建議使用這些工具）。我在其中至少具有JSON和AMQP一些支持文檔工具特別感興趣，但問題也將代表之類的東西Protobuf，Thrift和XML-RPC和與這些技術工作的任何

9熱度

3回答

芹菜（Django）限速

我正在使用Celery來處理多個數據挖掘任務。這些任務之一連接到遠程服務，它允許最多10個同時連接每用戶（或者換句話說，它CAN超過10個連接全球，但它CAN NOT超過每個人工作10個連接）。我認爲Token Bucket (rate limiting)是我在找，但我似乎無法找到它的任何實施。