twisted.internet

4熱度

2回答

我想修改scrapy日誌消息以在其開頭包含用戶標識。例如，而不是這個 2015-03-03 17:09:34+0530 [scrapy] INFO: Enabled spider middlewares: HttpErrorMiddleware, OffsiteMiddleware, RefererMiddleware, UrlLengthMiddleware, DepthMiddleware

2熱度

1回答

CPU使用率在啓動扭器

我監測python腳本的CPU佔用率的時間，這包含以下代碼 from twisted.internet import reactor, task def fun(): print "I don't know why CPU usage increases in the beginning" lc = task.LoopingCall(fun) lc.start(10) react

3熱度

1回答

reactor.connectTCP能否在reactor.run以扭曲的python運行之後發生？

我希望在反應堆運行後添加更多的協議和工廠。我無法找到說這是允許的文件。當我在reactor.connectTCP之前創建reactor.run時，程序會在工廠周圍掛起buildProtocol。運行reactor.run後，是否可以將reactor.connectTCP添加到反應器中？

1熱度

1回答

在條件結束後停止Twisted.internet中的電抗器

我有一個簡單的代碼，用於測試Twisted.internet模塊的工作方式。我想在某些情況發生時停止循環（例如：當我等於5），但我無法得到它運行。我有兩個主要錯誤： exceptions.UnboundLocalError: local variable 'i' referenced before assignment 2. 在情況下，我只需添加reactor.stop（）末沒有if語句一

2熱度

1回答

如果發生異常，停止任務。放棄呼叫

我是Twisted的新手，並且在終於弄清楚延遲是如何工作的之後，我正在努力完成任務。我想實現的是讓腳本在循環中發送一個REST請求，但是如果在某個點失敗，我想停止循環。由於我使用回調函數，因此我不能輕易捕捉異常，並且因爲我不知道如何停止errback循環，所以我被卡住了。這是我的代碼的簡化版本： def send_request(): agent = Agent(reactor)

1熱度

2回答

在Twisted Python中發送數據時的事件？

我正在使用Twisted框架編寫TCP/IP服務器。我以小塊發送非常大量的數據流。所以我需要知道我發送的數據何時通過Twisted的緩衝區進入操作系統，操作系統已準備好接收更多數據。發生這種情況時是否有辦法通知？我這樣做是爲了測量網絡吞吐量，所以我生成了無限量的數據。如果我使用的是普通套接字（不是Twisted），那麼答案就是使用poll（）和POLLOUT，但是我想用Twisted來做到這一

3熱度

2回答

deferToThread VS遞延（）

我想了解與低於2的代碼片段會發生什麼 - 代碼片段＃1 from twisted.internet import threads, defer, reactor def proc1(a): while True: print "Proc----------1" def proc2(a): while True: print "Proc------

1熱度

1回答

python twisted：每個id強制實施一個連接

我有一個扭曲的服務器，它使用SSL套接字並使用證書來識別連接到服務器的不同客戶端。我想強制每個可能的ID只有一個連接的狀態。我能想到的兩種方式是跟蹤連接的ID，然後不允許通過相同的ID進行第二次連接，或者允許第二次連接並立即終止第一次連接。我試圖做後，但我有一些問題（我會解釋我的選擇結束）我存儲的工廠類中的連接列表，然後在SSL握手後，我比較客戶端編號與該列表。如果它已經在該列表中，我嘗試撥打.

3熱度

1回答

腳本Scrapy。不出口，我想從腳本運行scrapy數據

，我不能讓程序創建導出文件我試圖讓該文件以兩種不同的方式導出：隨着管道隨着飼料出口。當我從命令行運行scrapy時，這兩種方式都有效，但是當我從腳本運行scrapy時，這兩種方式都不起作用。我並不孤單這個問題。這裏還有兩個類似的未解答的問題。直到我發佈問題之後，我才注意到這些。 JSON not working in scrapy when calling spider through

1熱度

1回答

Python - 扭曲客戶端 - 在ping迴路中檢查protocol.transport連接

我使用Twisted創建TCP客戶端套接字。我需要在connectionMade方法的循環間隔中檢查連接狀態。 from twisted.internet import reactor, protocol class ClientProtocol(protocol.Protocol): def connectionMade(self): while not thread_