pyzmq

    6熱度

    2回答

    我花了一個星期搜索並嘗試不同的解決方案,沒有運氣。我已經看到其他幾個人在一年內遇到同樣的問題。 問題: 的Windows 10臨建15063.674 我使用的是最新的蟒蛇5構建與Python 3.6.2和所有的包都更新到最新。 運行Jupyter筆記本,一段時間後,蟒蛇會看到一個對話框「蟒蛇已停止工作」崩潰。這似乎發生在筆記本已經打開一段時間之後,但我一直無法精確定位確切的時間。它超過15分鐘,但

    3熱度

    1回答

    我的python後端使用像'\x00k\x8bEg'這樣的字節數組作爲ID。爲了在我的NodeJS正確顯示這些前端我用看到波紋管 hex_data = binascii.hexlify('\x00k\x8bEg') text_string = hex_data.decode('utf-8') 此操作可能返回回來的東西,看起來像這樣:006b8b4569 我想恢復這個操作,並取回我的我創建的字

    0熱度

    1回答

    有沒有辦法看到連接後ZeroMQ(實際上是pyzmq)端口連接到哪個端口? 例如... import zmq context = zmq.Context() socket = context.socket(zmq.PAIR) port = socket.bind_to_random_port("tcp://*") # some other code that might change th

    1熱度

    1回答

    我想在Python(pyzmq)中使用ZeroMQ和多處理。作爲一個微型(不)工作的例子,我有一個服務器和客戶端類,它們都從multiprocessing.Process繼承。如果我運行此服務器進程似乎在接收呼叫msg = socket.receive_string()掛 #mpzmq_class.py from multiprocessing import Process import z

    4熱度

    2回答

    我努力實現以下目標: 有多個泊塢窗容器執行一段時間任務 對本地主機上運行,​​除了其他任務管理 (啓動/停止組件)容器 有時容器內運行 的服務需要發佈結果。因此他們使用ZMQ將 綁定到一個暴露的端口併發送結果。 本地主機上運行的組件訂閱特定端口並在 上偵聽。 問題是每個容器都需要localhost網絡上的特定/不同端口來綁定和發佈結果。這意味着我需要聽所有的集裝箱港口。 是否可以收聽單個端口並且所

    0熱度

    2回答

    我讀過我的文檔大多數例子都是基本用例。 只需一個進程發佈X事件,另一個進程訂閱X事件。 但在我的應用程序中,X是一種變量。所以我們可以說我的X代表我的用戶。 所以我可以做一個像user-ID這樣的服務器事件發佈意味着如果我有1000個用戶連接到服務器,那麼可以發佈和訂閱這麼多的動態主題,然後另外20個服務器訂閱這1000個這個服務器上的主題。 讓我們看看這個例子。 我有10臺服務器。每個服務器連接

    0熱度

    1回答

    我有幾個經銷商連接到一個路由器插座。經銷商異步發送數據,路由器收集/處理數據。 我需要做的是找到一種方法來知道經銷商何時停止發送數據/從路由器插座斷開連接。 我構建了所有連接標識的映射。 我有一個監視器連接到路由器端口,我收到連接/斷開連接的通知。 問題是我找不到一種方法來確定哪個經銷商的顯示器通知。通知只給我一個沒用的FD。 有沒有辦法在通知和連接ID之間進行映射?

    0熱度

    1回答

    我是新來的森蚺,經過對勝利新鮮水蟒4.4.0 7 64 我得到以下崩潰: (C:\ProgramData\Anaconda2) C:\Users\LordTitiKaka>jupyter notebook Traceback (most recent call last): File "C:\ProgramData\Anaconda2\Scripts\jupyter-notebook-

    1熱度

    1回答

    事先,我對這種問題感到抱歉,因爲我是ZeroMQ的新手,並且在閱讀隱祕的ZeroMQ文檔並編寫了一些測試用例之後,我一直在設計我的程序。 我的第一個版本是使用ROUTER(作爲前端)和DEALER(作爲後端)。見下: [ clients N] --> [ Frontend ] --> [ Backend ] --> [ Workers N ] 這是簡單和標準的,所以代碼工作正常。現在,我有了新

    0熱度

    1回答

    我想在芹菜工作者端使用jupyter內核。每個芹菜工作者將會有一個Jupyter內核。 爲了實現它,我覆蓋了芹菜的默認Worker類,在工作人員的初始化過程中,我啓動了jupyter內核,並使用stop方法關閉了jupyter內核。 我面臨的當前問題是如何在任務運行時訪問任務內的內核實例? 是否有更好的方法覆蓋celery應用程序的Worker類定義,而不是app.Worker = CustomW