TwythonStreamer のラッパーは次のとおりです。
from twython import TwythonStreamer
class Twitter_talker(TwythonStreamer):
def __init__(self):
super(Twitter_talker, self).__init__(<my credentials here...>)
def on_success(self, data):
self.disconnect()
print data
def on_error(self, status_code, data):
print status_code
self.disconnect()
ツイッターからステータスを取得するための私の呼び出しは次のとおりです。
class Tweet_Handler(tornado.web.RequestHandler):
def get(self):
stream = Twitter_talker()
stream.statuses.filter(track='badminton')
Web サーバーへの GET REST API 呼び出しで「バドミントン」を探すこのストリームを作成します。コード化されていませんが、非同期呼び出しになります。つまり、ストリームが正常に作成されたことを示す「1」などの応答が返されます。
self.disconnect
値が「バドミントン」の DELETE REST API 呼び出しを受信した場合、どうすればよいですか?