twisted

1熱度

1回答

如何從ApplicationBunner在autobahnPython中獲取反應器

我有一個使用高速公路的ApplicationRunner類連接到WAMP路由器（交叉開關）的高速公路客戶端。在主要部分，它十分重視我ApplicationSession類「再調度」是這樣的： if __name__ == '__main__': from autobahn.twisted.wamp import ApplicationRunner runner = Appli

0熱度

1回答

扭曲的python從kafka讀取並寫入elasticsearch

我是Twisted的新手，這是我的第一個程序。我無法從kafka-python庫中找到使用KafkaConsumer的方法，並使用treq來觸發對elasticsearch的發佈請求。我能在小塊分解問題：創建卡夫卡消費迭代器，並從中讀取數據（的話題可能是巨大的） def consumeKafka(): consumer = KafkaConsumer(bootstrap_serve

-1熱度

1回答

在view.py外部使用Django

我有一個基於扭曲的腳本運行，即管理IO，監視串行輸入，編寫日誌等。它使用Twisted每分鐘和每小時運行事件以及中斷串行流量。能的Django被用於提供這種接口，例如採取現場值，並使用 #python code generating value1 and value2 def displayValues(request): context = { 'value1':v

0熱度

1回答

從dbpool.runQuery獲取延遲，而不是使用Twisted和Oracle的數據

我想從Oracle獲取一些數據，使用Twisted和runQuery並繼續獲取延遲而不是實際數據。這怎麼解決？一些代碼（我排除一些不必要的部分，但這個想法應該清楚）： from twisted.enterprise import adbapi from twisted.internet import defer import service_config ORACLE_DSN = se

0熱度

3回答

tearDown在扭曲試驗超時後未被調用？

我在我的測試套件中看到一個問題，一切正常，直到我超時。如果由於超時而導致測試失敗，tearDown函數永遠不會被調用，從而使反應堆不清潔，從而導致其餘測試失敗。我認爲應該在超時後調用tearDown，有人知道爲什麼會發生這種情況嗎？

0熱度

1回答

扭曲的線程和線程池差異

有什麼用 from twisted.internet import reactor, threads ，並只使用一個線程池使用 import thread 之間的區別？實際上扭曲的事情是什麼？另外，使用扭絞線是否安全？

0熱度

1回答

Python未處理錯誤追蹤（最近呼叫最後）：

這是我的代碼，我正在尋找答案，但沒有解決我的問題。我是新來扭曲，仍然在學習。爲什麼我在Windows命令提示符下運行telnet localhost 72後出現此錯誤？這是我的代碼： from twisted.internet.protocol import Factory from twisted.protocols.basic import LineReceiver from twi

0熱度

1回答

扭曲的WebSocket - 從另一個文件調用時廣播不起作用

我正在建立一個Websocket服務器，它登錄到另一個服務器並通過套接字將數據推送到網頁（通過訂閱功能）。只要我一直從websocket運行的文件調用廣播函數，一切都很好。但是從另一個python文件調用廣播方法，其中我的推送功能正在打印到命令行，沒有客戶端正在收到消息。我認爲，從另一個文件調用廣播會創建另一個實例，並且self.clients爲空。所以總結一下，連接的客戶端從loginGES

0熱度

2回答

寫一個異步HTTP客戶端使用扭曲的框架

我想寫一個異步HTTP客戶端使用扭曲的框架，異步/同時觸發5個請求到5個不同的服務器。然後比較這些響應並顯示結果。有人可以幫忙解決這個問題。

0熱度

1回答

扭曲：從阻止請求返回

我有一個render()函數，它不使用延遲，因爲它直接返回響應更快。我不想直接返回字符串，而是先將它寫入請求對象，然後手動完成並返回。能夠在第二個代碼片段中使用return語句是很重要的。 def render(self, request) return b"not authorized" 應該成爲（如果可以這樣做） def render(self, request) re