Mailman 3 June 2012 - Twisted

[Twisted-Python] txWS !!
by vinod kumar July 1, 2012

July 1, 2012

Hi, Thanks a lot for your reply. The trouble is that the events I have are triggered by a homematic CCU. The CCU does it by multicall which has not yet been implemented in twisted servers. So, I'm running a non-twisted xmlrpc server in a thread so that my CCU triggers the events and it's happening too. I can see the events printed on the console too. Now, I just want a way to write the same to sockets. Can't we connect these to txWS factory ? Doesn't the txWS has some socket object so that we can just say socket.write..hmm Thanks, Vinodh ------------------------------------------------------------------- Hi Vinodh, txWS merely lets you connect to a Twisted Factory through WebSockets. You will still need to structure your code such that the events that you are responding to are connected to that Factory. It might be helpful to rewrite your XML-RPC server to use Twisted's XML-RPC (see http://twistedmatrix.com/documents/current/web/howto/xmlrpc.html for a tutorial on that) and then it will be easier to hook up your events without having to worry about threading or other blocking things. If you're having specific problems with txWS, let me know; it's important to us that txWS work smoothly for people using it. ~ C. ------------------------------- On Fri, Jun 29, 2012 at 04:52:06PM +0200, vinod kumar wrote: > Hi All, > > I have run and edited the example provided for txWS. The writing part > from server to client browser is shown only as self.transport.write() > inside dataReceived function in websockets.py. how do I write on to the > socket i.e. on to the browser, from a different function inside server > code(server.tac). I'm just starting another xmlrpc server on a thread where > I receive some notifications. I need to forward the same to socket. The > bold point below is where I want to write on to socket. How can we do > that? Please help me out. > ------------------------------------------------------- > import time > > from twisted.internet import reactor > from twisted.application import internet > from twisted.application.service import Application, Service > import xmlrpclib > from txws import WebSocketFactory > > from src.protocols.websockets import WebSocketServerFactory > from constants import * > > class WebSocketService(Service): > """ > A simple service that listens on port 8077 for WebSockets traffic. > """ > def __init__(self): > self.start_time = time.time() > > def start_service(self, application): > """ > Gets the show on the road. Fires up a factory, binds the port. > """ > echofactory = WebSocketServerFactory(self) > factory = WebSocketFactory(echofactory) > ws_server = internet.TCPServer(8077, factory) > ws_server.setName('ws-tcp') > ws_server.setServiceParent(application) > > def shutdown(self): > """ > Gracefully shuts down the service. > """ > reactor.callLater(0, reactor.stop) > > def listDevices(id): > print "listDevice: %(id)s" % {"id": str(id)} > return None > > def event(id, address, key, value): > #websocket.send("ufffffffffuuuuuu") > * #I need to write the below print statement on to browser * > print "event: %(id)s: %(address)s: %(key)s = %(value)s" % {"id": > str(id), > "address": str(address), "key": str(key), "value": str(value)} > > def aSillyBlockingMethod(x): > import time > import xmlrpclib > time.sleep(2) > from SimpleXMLRPCServer import SimpleXMLRPCServer > from SimpleXMLRPCServer import SimpleXMLRPCRequestHandler > from constants import * > server = SimpleXMLRPCServer((SERVER_IP, SERVER_PORT), logRequests=True, > allow_none=True) > server.register_introspection_functions() > server.register_multicall_functions() > print "server started at %s" % str(SERVER_URL) > server.register_function(listDevices) > server.register_function(event) > print 'function also got registered' > server.serve_forever() > .............................continues > > Thanks, > Vinodh

2 2

[Twisted-Python] Make Twisted/PyPy a milestone?
by Tobias Oberstein June 30, 2012

June 30, 2012

Hi all, I'd like to ask if it would be appropriate and whether there is interest in making "support Twisted on PyPy" a project milestone for Twisted. I'd start contributing by setting up a buildslave for PyPy so that issues can be made transparent and identified and progress tracked. Since PyPy is still very fast moving, that would need to be a beefy machine, since I would track PyPy trunk doing nightly PyPy builds and then use that for Twisted trials. It likely would involve stopping buildbot for the short period of PyPy installation, restarting it afterwards. Is there community interest in Twisted/PyPy .. people that might help with working on tickets (which I guess will likely result from such an effort)? My hope would also be that PyPy devs might be interested in having the PyPy codebase tested against such a broad suite like Twisted on a regular basis and would help with PyPy non-Twisted-but-triggered issues .. Cheers, Tobias PS: The current trial results (Ubuntu 10.04 LTS i386, Twisted trunk, select reactor) twisted.conch.test.test_manhole => ManholeLoopbackStdio: timeouts on all 13 test cases twisted.conch.test.test_recvline => HistoricRecvlineLoopbackStdio: timeouts on all 2 test cases => RecvlineLoopbackStdio: timeouts on all 9 test cases twisted.internet.test.test_endpoints => ServerStringTests => test_ssl: hangs forever!

3 3

[Twisted-Python] Twisted tutorial and Twisted sprint in San Francisco
by Ying Li June 29, 2012

June 29, 2012

Hi all! There will be a Twisted tutorial/learning session in San Francisco on Friday, July 13th, at 7pm. Glyph will be giving the tutorial, and several developers will be on hand to help. There will be a Twisted sprint the next day, Saturday July 14th, from 10am to 9pm (or later, if folks want to stay later!) - come whenever and for however long you like. Hack on Twisted or a Twisted-related project, learn more about how to use Twisted, or just hang out. Both events are hosted at Rackspace, which is located at 620 Folsom St, Suite 100, San Francisco 94107. (between 2nd St and Howard, or 2nd and 3rd if you prefer). Please RSVP at: http://www.meetup.com/San-Francisco-Twisted-Python-Meetup (so we know how much food to get!) Thanks!

1 0

[Twisted-Python] Writing onto txWS
by vinod kumar June 29, 2012

June 29, 2012

Hi All, I have run and edited the example provided for txWS. The writing part from server to client browser is shown only as self.transport.write() inside dataReceived function in websockets.py. how do I write on to the socket i.e. on to the browser, from a different function inside server code(server.tac). I'm just starting another xmlrpc server on a thread where I receive some notifications. I need to forward the same to socket. The bold point below is where I want to write on to socket. How can we do that? Please help me out. ------------------------------------------------------- import time from twisted.internet import reactor from twisted.application import internet from twisted.application.service import Application, Service import xmlrpclib from txws import WebSocketFactory from src.protocols.websockets import WebSocketServerFactory from constants import * class WebSocketService(Service): """ A simple service that listens on port 8077 for WebSockets traffic. """ def __init__(self): self.start_time = time.time() def start_service(self, application): """ Gets the show on the road. Fires up a factory, binds the port. """ echofactory = WebSocketServerFactory(self) factory = WebSocketFactory(echofactory) ws_server = internet.TCPServer(8077, factory) ws_server.setName('ws-tcp') ws_server.setServiceParent(application) def shutdown(self): """ Gracefully shuts down the service. """ reactor.callLater(0, reactor.stop) def listDevices(id): print "listDevice: %(id)s" % {"id": str(id)} return None def event(id, address, key, value): #websocket.send("ufffffffffuuuuuu") * #I need to write the below print statement on to browser * print "event: %(id)s: %(address)s: %(key)s = %(value)s" % {"id": str(id), "address": str(address), "key": str(key), "value": str(value)} def aSillyBlockingMethod(x): import time import xmlrpclib time.sleep(2) from SimpleXMLRPCServer import SimpleXMLRPCServer from SimpleXMLRPCServer import SimpleXMLRPCRequestHandler from constants import * server = SimpleXMLRPCServer((SERVER_IP, SERVER_PORT), logRequests=True, allow_none=True) server.register_introspection_functions() server.register_multicall_functions() print "server started at %s" % str(SERVER_URL) server.register_function(listDevices) server.register_function(event) print 'function also got registered' server.serve_forever() .............................continues Thanks, Vinodh

3 2

Re: [Twisted-Python] deferred graph?
by Terry Jones June 29, 2012

June 29, 2012

Hi Dan > I'm a Twisted neophyte, but I've been using Python a long time. I'm a Twisted neophyte, but I've been using Twisted a long time. (I'd add a smiley, but that's not a joke.) > My question: Is there a way of producing a deferred graph in a Python > program at a given point in time? Perhaps something based on graphviz > and objgraph.py? We're able to detect when we're having the problem, we > just don't (yet) know its cause. You might be able to use this that I wrote some time ago. It might need some maintenance as the Twisted Deferred code has moved on since then. But the approach might help you: http://www.twistedmatrix.com/pipermail/twisted-python/2008-October/018535.h… Terry

2 1

[Twisted-Python] Catching error in protocol.ReconnectingClientFactory
by Martin June 28, 2012

June 28, 2012

Hi there, I've been looking around for a solution for several hours now, and maybe I'm just missing something.. I've a factory that implements protocol.ReconnectingClientFactory which works just fine, however, whenever the program ends running, I get a bunch of Unhandled error in Deferred messages in my log for each disconnection that occurred during runtime, such as Failure: twisted.internet.error.ConnectionLost: ... Is there any way I could somehow "handle" these during runtime, so that my log wouldn't be spammed with this at the end.. (or avoid it being spammed somehow..) I really don't care what the solution is, I already have the following method that logs everything for me def clientConnectionLost(self, connector, reason): log.msg('Lost connection. Reason: %s' % reason) just annoying that it's still finds the need to print it out at the end. Anyway, I don't claim to be anywhere near proficient in Twisted, so any help would be greatly appreciated. Thanks a lot in advance. Martin

6 12

[Twisted-Python] Log file ownership
by Enrique Samson Jr, June 27, 2012

June 27, 2012

Hi, I am running an app as root on Linux using a .tac file and twistd. The application object is initialized with a certain gid and uid. Logging is configured to rotate daily by way of DailyLogFile. However, the log file it creates is owned by root with 600 file permission and log rotation is failing. I have read about acl to configure default file permissions but is there a way to solve this only in Twisted? --Enrique

7 9

[Twisted-Python] XMLRPC --> Twisted
by vinod kumar June 27, 2012

June 27, 2012

Hi, I have made a server code in xmlrpc. It has a command "server.register_multicall_functions()". How do I write the same in twisted server? This is the main of the twisted server : -------------------- if __name__ == '__main__': from twisted.internet import reactor r = Example() reactor.listenTCP(7070, server.Site(r)) print 'avtundile' reactor.run() ----------------------- Thanks, Vinodh

3 2

[Twisted-Python] twisted/python3/ubuntu 12.10
by Wolfgang Rohdewald June 27, 2012

June 27, 2012

it seems that Ubuntu 12.10 will only preinstall Python3, no Python2.7. So programs using twisted (including my own) will not come preinstalled. how is progress going with twisted and Python3? -- Wolfgang

10 14

[Twisted-Python] Call Back for startService() !
by vinod kumar June 26, 2012

June 26, 2012

Hi, I want to execute something after the service starts. Is there any call back that I can associate with startService() ? I have checked the documentation, but couldn't find anything as such :( Thanks, Vinodh

3 2