twisted

-1熱度

1回答

我試圖做到以下幾點：作爲客戶端連接到現有的WebSocket 過程從此套接字接收數據流，併發布到另一websocket 我正在使用twisted和autobahn來做到這一點。通過爲客戶端派生一個WebSocketClientProtocol，並在第二個派生一個ApplicationSession，我設法讓這兩部分分開工作。這兩個運行在同一個反應堆上。但我不確定如何讓他們溝通。我想在客戶端收到

0熱度

1回答

命名管道扭曲和MongoDB

語境：我的最終目標是使一個可擴展的下載。我選擇了兩種腳本體系結構，因爲mongo在扭曲時不能很好地工作，所以我讓一個非扭曲的腳本執行數據庫讀寫操作，而另一個腳本扭曲一個腳本，執行處理操作，獲取儘可能多的數據第一個腳本。我有一個包含url的集合的mongoDB數據庫。事情是這樣的： record = {url:'www.somesite.com'} [PART OF SCRIPT 1] 我有

1熱度

1回答

瞭解扭曲和異步編程。爲什麼代碼工作，另一個不是？

對不起，第一牆的文字。我一直在努力理解Twisted和異步編程。我使用Python 2.7和Twisted 15.4.0。我試圖this example爲downloadPage（）和它完美的作品。我對它進行了修飾，將lambda中的回調更改爲正確的函數。有效。我也嘗試從callback和errback中刪除reactor.stop（）語句，它唯一的影響是腳本在下載後不會停止。由於事件循環仍

1熱度

1回答

瞭解Python扭曲的循環調用 - 保存LoopingCall函數的返回

我正在使用Twisted並每x秒進行一次循環調用。我用於循環調用的函數會生成一個return語句。 def f(): # Obtain stuff return stuff def main(): LoopingCall(f).start(x) 如何檢索f的返回結果？謝謝！

0熱度

1回答

異常處理使用MySQL與扭曲的adbapi和scrapy

我正在使用this scrapy管道。如果insert_record函數中的sql存在任何錯誤，它將自動失敗。例如，如果一個列名是誤拼寫，這樣 def _insert_record(self, tx, item): print "before tx.execute" result = tx.execute( """ INSERT INTO table(col_on

3熱度

1回答

Python Twistd MySQL - 獲取更新行ID（不插入）

Python，Twistd和SO新手。我正在編寫一個程序，組織多個房間的座位。我只包括下表中的相關列。基本MySQL表表 ID 座椅 ID 的table_id 名卡 SEAT_ID 的Seat和Table表是預填的 '名稱' 列最初NULL。第一階段我想通過找到給出一組表ID的第一個可用座位更新座位的名字。兩個我希望能夠從第一階段獲得更新的行ID（因爲我已經不知道這一點）添加到Ca

0熱度

1回答

twisted.cred.portal.IRealm，門戶和頭像之間的關係是什麼

我試圖使用Twisted的HTTP基本身份驗證來控制對某些受保護資源的訪問。據一些文章，有必要使用三個重要概念：領域，門戶網站和頭像。現在我想知道Realm和頭像是否是一一對應的。讓我們來看一個例子 import sys from zope.interface import implements from twisted.python import log from twisted.

2熱度

1回答

蟒蛇TREQ失敗，扭曲/ OpenSSL的錯誤是由於在Windows

空信任庫當我在http://www.google.com運行下面的示例代碼，它工作正常但是，當我嘗試https://www.google.com，我得到這個錯誤： Requesting https://www.google.com Unhandled error in Deferred: Unhandled Error Traceback (most recent call last):

0熱度

1回答

打印到基於雙絞線中的客戶端應用程序連接

我有一個TCP客戶端在我的扭曲應用下面的代碼不同的日誌文件： from twisted.internet import reactor, protocol from twisted.python import log import time class EchoClient(protocol.Protocol): def connectionMade(self): i

0熱度

1回答

來自其他來源的扭曲延期變量

我正在運行IRC bot，我終於想出瞭如何正確獲取用戶的身份驗證。我現在正在執行這個檢查來引用我的數據庫，而不是依靠他們的用戶名。我有一個命令 def privmsg(self, user, channel, msg): if msg.startswith(".join"): # sends whois signal irc.IRCClient.whois(se