twisted.internet

0熱度

1回答

我有一系列的客戶端需要通過ws協議不斷連接到我的服務器。由於許多不同的原因，連接偶爾會下降。這是可以接受的，但是當它發生時，我希望我的客戶重新連接。目前我的臨時解決方法是讓父進程啓動客戶端，當它檢測到連接丟失時，終止它（客戶端從不處理任何關鍵數據，不會對sigkill產生副作用），並重新創建一個新客戶端。雖然這樣做的工作，我非常希望解決實際問題。這大致是我的客戶： from autobahn.

0熱度

1回答

扭曲反應堆無法從線程正確

調用函數我有twisted.internet.reactor問題，我所有的客戶有完全一致的環境中，但只有一些經驗，這個問題：他們正確地通過ws和交流第一幾條消息connectTCP到服務器。在約一分鐘，他們應該通過 def execute(self, message, callback=None): print(">>>", message, flush=True) reac

0熱度

1回答

從客戶端接收數據而不使用Twisted中的「dataReceived」功能

如何從客戶端接收數據，繞過標準類功能協議？例如， class TW(protocol.Protocol): def get_data(delim = '\n'): #some code return data 即，沒有使用「dataReceived」函數，並且不凍結所有其他服務器客戶端？

0熱度

1回答

Python扭曲的延遲returnValue與字典不兼容

我在包中廣泛使用twisted.internet.defer，我遇到了一個問題，我花了2天后無法解決。以下是我的問題場景。 # all imports done and correct class infrastructure: # line 1 @inlineCallbacks def dict_service(self): client = MyClient(

1熱度

1回答

如何獲取可能會意外終止的扭曲spawn過程的退出代碼？

我正在使用twisted來產生本地進程，這可能會在某種情況下終止。我有一個自定義twisted.internet.protocol.ProcessProtocol類的反應堆。如果本地進程突然終止，我無法獲得processEnded的返回值。 exitCode設置爲None。一個MCV的例子是這樣的： from twisted.internet import error,protocol,rea

0熱度

3回答

長延期任務的扭曲反應器塊

我正在研究一個涉及向api提出許多請求的項目，並且我正在做出決定並保存在db中的每個反饋。我正在使用adbapi與mysql進行通信。我正在接收請求作爲POST，其中包含要推送到遠程API並保存的項目列表。我已經注意到，雖然處理延期的所有其他操作塊中的項目，直到一部分完成。下面是一個例子，顯示了類似於我正在做的事情。 #!/usr/bin/python2.7 from twisted.w

2熱度

1回答

強制加捻反應器在sigterm上停止

我有一個GCE服務器設置來處理一些數據分析。我可以通過使用twisted與它溝通。我是這臺服務器的唯一客戶端。系統是安裝程序是這樣的： spawn_multiprocessing_hierarchy() reactor.run() # Blocks main thread stop_everything_and_cleanup() 當我試圖阻止系統和客戶端連接，reactor會忽略（？或

0熱度

2回答

扭曲的Python工廠方法使用反應器的包裝

我有一個簡單的客戶端/服務器安裝時不獲取調用。這裏的客戶端代碼： from twisted.internet import reactor from twisted.internet import protocol from twisted.internet.endpoints import TCP4ClientEndpoint class MyProtocol(protocol.Prot

2熱度

1回答

禁用SSL證書檢查扭曲代理

我正在使用Twisted（16.3）和Treq（15.1）在Python（2.7）中進行異步請求。我對通過HTTPS的一些請求存在問題。有些網站使他們的請求時，有一個無效的證書，因此，我得到這個： twisted.python.failure.Failure OpenSSL.SSL.Error 我希望我的客戶信任任何服務器，包括那些沒有證書或自簽名的證書。如何禁用我的客戶端上的證書檢查？

0熱度

1回答

試圖在OSX上使用扭曲

我最近發現了Twisted python庫，並試圖使用測試腳本進行設置。 from twisted.internet.protocol import Protocol, Factory from twisted.internet import reactor class Pong(Protocol): def connectionMade(self): self.tra