2

Tornado WebSocket と Tweepy Streaming の 2 つの主要なモジュールがあり、それらが互いに通信できるようにしようとしています。

下on_statusのStdOutListenerTweepy クラス ( でマーク) の下で、から渡されたデータを使用して、上位の Tornado クラス<--を呼び出したいと思います。WSHandler.on_messageon_status

ただし、以下のコードで未定義のインスタンスなどに関連するエラーメッセージが表示されるため、そうすることができません。どんな助けでも大歓迎です！

(また、両方のモジュールを同時に実行することができた唯一の非ブロッキング方法は、スレッドを使用するIOLoop.add_callbackことStdOutListenerです。なぜなら、この実装が推奨されるかどうか、または理由を知りたいです。ありがとう!)

import os.path
import tornado.httpserver
import tornado.websocket
import tornado.ioloop
import tornado.web
import threading
import time
import datetime

# websocket
class FaviconHandler(tornado.web.RequestHandler):
    def get(self):
        self.redirect('/static/favicon.ico')

class WebHandler(tornado.web.RequestHandler):
    def get(self):
        self.render("websockets.html")

class WSHandler(tornado.websocket.WebSocketHandler):
    def open(self): 
        cb = tornado.ioloop.PeriodicCallback(self.spew, 1000, io_loop=main_loop)
        cb.start()
        print 'new connection'
        self.write_message("Hi, client: connection is made ...")

    def on_message(self, message):
        print 'message received: \"%s\"' % message
        self.write_message("Echo: \"" + message + "\"")
        if (message == "green"):
            self.write_message("green!")

    def on_close(self):
        print 'connection closed'

    def spew(self):
        msg = 'spew!'
        print(msg)
        self.on_message(msg)

handlers = [
    (r"/favicon.ico", FaviconHandler),
    (r'/static/(.*)', tornado.web.StaticFileHandler, {'path': 'static'}),
    (r'/', WebHandler),
    (r'/ws', WSHandler),
]

settings = dict(
    template_path=os.path.join(os.path.dirname(__file__), "static"),
)

application = tornado.web.Application(handlers, **settings)


# tweepy
from tweepy.streaming import StreamListener
from tweepy import OAuthHandler
from tweepy import Stream
import simplejson as json


# new stream listener 
class StdOutListener(StreamListener, WSHandler):
    """ A listener handles tweets are the received from the stream. 
    This is a basic listener that just prints received tweets to stdout.

    """

    # tweet handling
    def on_status(self, status):
        print('@%s: %s' % (status.user.screen_name, status.text))
        WSHandler.on_message(status.text) # <--- THIS is where i want to send a msg to WSHandler.on_message

    # limit handling
    def on_limit(self, track):
        return

    # error handling
    def on_error(self, status):
        print status


def OpenStream():
    consumer_key="[redacted]"
    consumer_secret="[redacted]"
    access_token="[redacted]"
    access_token_secret="[redacted]"
    keyword = 'whatever'

    l = StdOutListener()
    auth = OAuthHandler(consumer_key, consumer_secret)
    auth.set_access_token(access_token, access_token_secret)
    stream = Stream(auth, l, gzip=True) 
    stream.filter(track=[keyword])



if __name__ == "__main__":
    threading.Thread(target=OpenStream).start()
    http_server = tornado.httpserver.HTTPServer(application)
    http_server.listen(8888)
    main_loop = tornado.ioloop.IOLoop.instance()
#   main_loop.add_callback(OpenStream)
    main_loop.start()
4

1 に答える 1

5

on_messageクラスメソッドではなく、インスタンスメソッドです。次のように、インスタンスで呼び出す必要があります。

handler = WSHandler()
handler.on_message('hello world')

ただし、実際にメッセージを送受信するには、ブラウザー接続によってインスタンスを作成する必要があるため、それだけではできません。

おそらく必要なのは、開いている接続のリストを保持することです ( Tornado websocket デモはこの良い例です):

class WSHandler(tornado.websocket.WebSocketHandler):
    connections = []

    def open(self):
        self.connections.append(self)

    ....

    def on_close(self):
        self.connections.remove(self)

ではStdOutListener.on_status、次のようなことができます。

for connection in WSHandler.connections:
    connection.write_message(status.text)
于 2012-09-18T21:31:29.387 に答える