twisted

0熱度

2回答

我使扭曲的應用程序使用pysnmp發送snmp陷阱。執行sendNotification後，一段時間的應用程序停止工作後，UDP連接未關閉。重新啓動應用程序後查看日誌文件我可以看到連接正在關閉。所以我需要在sendtrap（）之後添加這個。日誌： 2017-03-17 09:57:30+0100 [UdpTwistedTransport (UDP)] Stopping protocol <py

0熱度

1回答

Python的扭曲：沒有模塊名爲web.server

我試圖執行以下導入命令：當我在的.py執行它 from twisted.web.server import NOT_DONE_YET 我能夠做的只是在解釋罰款，但腳本，我得到錯誤信息： ImportError: No module named web.server 出於某種原因，「web.server」被解釋爲一個模塊，而不是它被解釋爲雙絞線/ web /目錄> server.py文件> NOT_

0熱度

1回答

不能安裝裝配Scrapy /雙絞線

當我使用「PIP安裝」，安裝scrapy爲Windows上的Python，我要求這個反饋： Exception: Traceback (most recent call last): File "c:\users\limin\appdata\local\programs\python\python36\lib\site-packages\pip\compat\__init__.py",

1熱度

1回答

使用雙絞線和系統處理緩存預熱

我有一個簡單的扭曲應用程序，我使用systemd服務運行，執行腳本，隨後執行.tac文件。應用程序的結構爲JSON RPC端點（fastjsonrpc），內置到t.w.r.Resource，這在t.w.s.Site，並擔任t.a.i.TCPServer，整個事情包裝成一個t.a.Application。這工作正常。我遇到麻煩的地方是當我嘗試在啓動時預熱緩存。這個預熱過程非常慢（約300秒），並

0熱度

1回答

如何使用klein從中斷響應獲取errback？

This page描述瞭如何設置在生成響應之前連接到客戶端丟失時觸發的errback。有沒有辦法用klein做類似的事情？參考頁面的代碼如下，它適用於twisted.web。我想這樣的： request.notifyFinish().addErrback(self._responseFailed, call) 這是代碼來發出errback時，請求沒有完成，這與克萊恩一起工作。 from tw

0熱度

1回答

將扭曲的消費者轉換爲服務

我正在嘗試將基於扭曲的pika（RabbitMQ）消費者轉化爲服務。這裏是什麼，我已經把目前發生的相關位： worker.py import pika from pika.adapters import twisted_connection from twisted.internet import defer, reactor, protocol, task @defer.inlineCa

0熱度

1回答

如何使python的第三方庫扭曲自動完成崇高？

我已經在崇高的地方安裝了'Anaconda'軟件包。但它不適用於第三個庫，如扭曲等......我如何使它自動完成？提前致謝。

1熱度

1回答

在Alpine Linux for Python 3.6上編譯扭曲

我有下面的Dockerfile，我試圖用Python 3.6編譯Twisted作爲目標。 FROM alpine:3.5 RUN apk --update add \ build-base libffi-dev openssl-dev python3-dev \ libffi openssl ca-certificates python3 RUN apk add \

1熱度

1回答

從孩子通知父進程的最佳方式

我有一個Python扭曲的應用程序，其工作是執行os進程，監視它們的生命週期並收集它們的日誌和退出狀態。現在我想添加一個功能，允許子進程向父進程通知它的進度（例如50％完成）。如何以最佳方式啓用此通信？我想到了一個休息端點在家長的子帖子。有沒有其他更好的方法來啓用父進程和子進程之間的通信（可以是任何進程）？ PS：應用程序被寫入扭曲。

0熱度

1回答

如何在Twisted [autobahn] websocket服務器中實時流式輸出？

我想使用subprocess.Popen（）來執行一個C程序，並實時輸出它的輸出並將它發送給客戶端。但是，輸出緩衝並在執行結束時一起發送（Blocking性質）。我怎樣才能實時接收輸出，然後立即將其發送到Twisted Autobahn中。 def onConnect(self, request): try: self.cont_name = ''.join(random.c