twisted

1熱度

1回答

扭轉，在反應器停止時解鎖threads.blockingCallFromThread

看起來threads.blockingCallFromThread即使在反應器停止時也會阻止。有什麼方法可以解除它嗎？推遲它依靠來自另一端的RPC阻塞，並且肯定不會在反應堆停止時進入。

1熱度

1回答

twisted.protocols.ftp.FTPClient和Deferreds

大多數情況下，我需要一段時間才能習慣使用Deferreds，但我正在慢慢到達目的地。但是，我不清楚我如何處理響應，然後在使用Twisted的FTP模塊時使用處理後的響應調用另一個FTP命令。我使用example FTP code作爲我的跳板點。我想連接到FTP服務器，獲取所有頂級目錄，然後輸入每個目錄並下載所有文件。首先，我連接： creator = ClientCreator(reactor

1熱度

1回答

運行「deferToThread」

我最近開始對雙絞線沒有太多熟悉其functions.I工作有一個問題涉及到「deferToThread」的方法......我的代碼是在這裏用這個方法的功能得到結果 from twisted.internet.threads import deferToThread from twisted.internet import reactor results=[] class Tool(obj

1熱度

1回答

如何使用twisted來下載遠程文件？

我是比較新的扭曲，我打算用它來創建文件下載。它會接受一個文件的URL和許多部分來下載文件。我想到的是將文件拆分成用戶指定的部件數量，並通過延遲下載每個部件，完成後將所有部件進行組裝。但是，我需要一個協議，爲每個文件下載和每個協議調度推遲下載每個文件的塊？是否存在扭曲的組件來讀取具有查找的遠程文件？我真的不知道從哪裏開始。

1熱度

1回答

如何創建扭曲的部分下載？

你如何創建多個HTTPDownloader實例異步部分下載？並在所有下載完成後自動彙編文件？

1熱度

2回答

限制Python中的連接速率扭曲？

有什麼辦法來限制Python中的連接速率扭曲？我需要模擬慢數據線，超時和可選的數據丟失並使用扭曲的框架。

1熱度

1回答

twisted：檢查延期是否已被調用

這是我正在努力完成的。我正在遠程調用服務器以獲取信息，並且我想阻止等待信息。我創建了一個返回Deferred的函數，這樣當RPC進入回覆時，調用deferred。然後我有一個從threads.blockingCallFromThread(reactor, deferredfunc, args)線程調用的函數。如果出現問題 - 例如服務器故障 - 那麼呼叫將永不解除。在這些情況下，我寧願推遲推遲以

1熱度

2回答

生成UDP數據包的最快方法

我們正在構建一個測試工具，將二進制消息推送到UDP多播上。該原型使用Twisted反應器循環來推出消息，這實現了我們所需的流量級別 - 每秒大約120000條消息。我們在我們的測試機器上有16個內核，顯然我想將這些擴展到這些內核上以真正使線束飛行。有沒有人有任何關於如何構建應用程序（使用事件循環方法或CSP樣式方法）來提高此輸出的想法。原型中的大部分時間都花在寫入UDP上 - 因爲我不應該

1熱度

1回答

Python是否適合編寫標準，兼容和完整的SOAP Web服務？

我已經使用了幾個python soap庫（SOAPpy，soaplib和SOAPpy的Twisted wrapper）來編寫我的soap web服務。當我使用python客戶端（SOAPpy.SOAPProxy和SUDS）時，我能夠與我的web服務進行通信（返回簡單和複雜的類型對象）。但是，當我嘗試使用C＃ASP.net時，我遇到了很多問題。我回過頭來簡單的類型（int，string，doub

0熱度

1回答

扭曲的網頁getPage，2個客戶端在2類，管理兩個之間的事件

我試圖創建一個網橋程序twisted.web從Web服務器接收數據並將其發送到另一臺服務器，因此我使用2個getPage應用程序，爲了方便，我將它包裝在類中，該類包含所有回調和客戶端「例程」。1）auth 2）接收數據3）發送數據，所有這些都以循環方式完成，在這兩個客戶端！我現在打算做的是整合這兩個，這意味着我將不得不在類之外進行一些回調以便處理它們。客戶端1 < --->主< --->客戶端