pyzmq

0熱度

2回答

我有一個生產者 - 消費者實施，我正在實施與pyzmq（我從here的例子：我有一個生產者，同時生產對象到幾種不同類型的消費者，其中每種類型的消費者，處理這個對象在另外，我有一個經理/主管，負責獲取有關處理對象狀態的消息（例如sent_from_producer_to_consumer_1，processed_by_consumer_2等），它爲每個對象存儲字典中的所有這些狀態關鍵是對象邏輯ID，

1熱度

2回答

如何在一個ioloop中運行pyzmq和一個web服務器？

我想編寫一個使用Tornado託管Web服務器的單線程程序，並且還可以在ZMQ套接字上接收消息（使用PyZMQ Tornado事件循環：http://learning-0mq-with-pyzmq.readthedocs.org/en/latest/pyzmq/multisocket/tornadoeventloop.html），但我不確定如何構造它。我應該使用 from zmq.eventloo

0熱度

1回答

如何防止ZeroMQ中的連接？

我有一個PUSH/PULL設置，但沒有任何東西阻止知道PULL套接字綁定的IP地址和端口並向其發送垃圾的人。什麼是防止這種情況的正確方法，只允許我授權連接到它的客戶端？如果這是不可能的，我可以告訴套接字只接受一個（第一個）連接並忽略任何後續的連接？

4熱度

2回答

Python ZeroMQ模塊導入錯誤

我安裝了ZeroMQ，在我的源代碼中添加了官方的ZeroMQ回購，然後通過apt-get install libzmq3-dev安裝，然後使用apt-get install python-zmq安裝模塊。當我打開了在import zmq Python解釋器和類型，我得到以下錯誤： Traceback (most recent call last): File "<input>", li

1熱度

1回答

龍捲風和ZeroMQ

我一直在試圖遵循代碼Eventloops and PyZMQ，具體如下代碼： from tornado.ioloop import IOLoop from zmq.eventloop.ioloop import ZMQPoller loop = IOLoop(ZMQPoller()) 我想這和我得到這個異常： Traceback (most recent call last):

2熱度

1回答

如何檢查zeromq中的發送數據是否成功

我是zmq和網絡編程的新手。我想用pyzmq庫編寫一個簡單的函數來發送/接收客戶端和服務器之間的數據（使用REQ/REP模式）。我所做的發送數據爲以下幾點： def send_data(socket, data): try: socket.send(data) except: return False return True 如果數據成功發

1熱度

1回答

模擬與外部設備通信的pythonic方式是什麼？ RPyC？

想一想Python腳本通過串口發送命令到外部設備的情況，比方說。腳本駐留在某臺Linux機器上，設備對某些命令作出反應。這個想法是通過將「發送」命令模擬到包含將由設備生成的轉儲的文件來模擬我的機器上的所有鏈，否則。這是我第一次嘗試這樣的事情，聽到有這種情況的人的經歷會很高興。我紅在網絡上，人們都在談論幾個方向：多處理 RPyC 線程 ZMQ 這可能是更多，但不知道的。有什麼建議麼？

3熱度

2回答

IPython並行計算與pyzmq集羣計算

我目前正在使用C語言編寫的一些模擬代碼，它運行在不同的遠程機器上。雖然C部分已經完成，但我想通過使用python模擬api和某種作業隊列系統來擴展它來簡化我的工作，它應該執行以下操作： 1.指定一組參數，在該參數上模擬應進行，並經工作人員把它們放在一個隊列中的主機上 2.perform模擬在遠程機器上 3.返回結果給主機我看了一下爲實現不同的框架這項任務和我的第一選擇歸結爲IPython.par

1熱度

1回答

ZMQ對（用於信令）由於連接不好而阻塞

我有兩個線程。一個是Worker Thread，另一個是Communication Thread。 Worker Thread正在從串口讀取數據，進行一些處理，然後將結果排隊發送到服務器。 Communication Tthread正在讀取隊列中的結果併發送它。我們面臨的挑戰是連接是無線的，雖然通常會出現，但它可能很缺乏（在幾分鐘內掉入和退出範圍），如果我失去連接，我不想阻止Worker Thre

3熱度

2回答

IPython Notebook未打開;拋出「找不到符號」錯誤

我似乎無法從終端打開IPython Notebook。我收到以下錯誤： self._handle = _dlopen(self._name, mode) OSError: dlopen(/Users/Username/anaconda/lib/python2.7/site-packages/zmq/libzmq.so, 10): Symbol not found: __ZNSs4_Rep20_S