twisted

1熱度

1回答

stdiodemo和命令歷史

在播放和擴展stdiodemo.py，時想出了添加命令行歷史記錄的想法。這可能嗎？任何提示？感謝安東尼斯·K.

3熱度

1回答

以扭曲的形式在服務器和客戶端之間發送數據

我試圖在服務器和客戶端之間傳輸數據以實現扭曲。據我所知，使用self.transport.write（[數據]）只有在數據是字符串的情況下才有效。有沒有其他方式可以發送其他類型的對象？謝謝！

9熱度

1回答

如何在沒有errbacks的情況下對Twisted Deferred錯誤進行測試？

我有一些Twisted代碼可以創建多個Deferreds鏈。其中一些可能會失敗，如果沒有errback將它們放回到回調鏈中。我無法爲此代碼編寫單元測試 - 失敗的延遲會導致測試代碼完成後測試失敗。我如何爲這段代碼編寫一個通過單元測試？預計在正常運行中可能出現故障的每個Deferred應該在鏈條末端出現錯誤，並將其放回到回調鏈上？當DeferredList中Deferred失敗時會發生同樣的事情，

2熱度

2回答

使用延遲的Python扭曲異步寫入

關於Python Twisted框架，有人可以向我解釋如何向消費者異步寫入非常大的數據字符串，比如protocol.transport對象？我想我缺少的是一個write(data_chunk)函數返回Deferred。這是我想做些什麼： data_block = get_lots_and_lots_data() CHUNK_SIZE = 1024 # write 1-K at a time.

1熱度

2回答

運行Twisted中的每個勾號函數

我正在使用扭曲的框架，並且需要跟蹤自事件啓動以來已經過了多長時間，並在一定數量過去時執行操作。做到這一點的最佳方法似乎是檢查反應堆每個滴答時間的時間戳。如果這是最好的方法，我該怎麼做？如果不是，那麼更好的方法是什麼？

1熱度

1回答

扭曲的回調函數混淆

我正在研究一個扭曲的教程，以瞭解更多的python，看來我已經跑到了這裏的路障。下面的doRead（）函數是反應器的「回調」。我不明白的是除了部分是如何工作的。我閱讀代碼的方式是，如果bytes += self.sock.recv(1024)就已經引起了塊，然後它會到達代碼的以下部分： if e.args[0] == errno.EWOULDBLOCK: break 然後，它會一直

9熱度

1回答

如何編寫也是客戶端的扭曲服務器？

如何創建也是客戶端的扭曲服務器？我希望反應器能夠監聽，同時它也可以用來連接到同樣可以連接和監聽的服務器實例。

2熱度

1回答

在Twisted客戶端生成頭文件

我使用Twisted web「HTTPClient」協議與http服務器進行對話（使用扭曲的應用程序作爲客戶端），問題是我的大部分請求都不接受我的頭文件。有沒有某種方式（也許使用某些庫）來生成頭？我會後一些代碼，所以你可以看看 class Local(HTTPClient): def generateHeaders(self, type=None): self.sendHeader(

6熱度

2回答

Python扭曲：如何安排？

具有扭曲的爲期1天的經驗，我嘗試安排消息回覆發送到TCP客戶端： import os, sys, time from twisted.internet import protocol, reactor self.scenario = [(1, "Message after 1 sec!"), (4, "This after 4 secs"), (2, "End final after 2 s

2熱度

2回答

扭曲，等到連接關閉乾淨

我想幹淨地斷開，然後停止反應堆。但是，如果我這樣做： controller.connection.disconnect() reactor.stop() 然後我得到一個「連接失去了一個非乾淨的時尚」的消息。如果我在它們之間插入一個time.sleep(1)，則連接會乾淨地關閉。我怎麼才能等到連接真的關閉？