泥を泳ぐ1
pubnubが使えないと詰んでいるのでリアルタイムレート取得から
miraaaman.hateblo.jp
r17u.hatenablog.com
ここらへんをまるこぴするがエラーが出る
のでぐぐる
github.com
そしてまたエラー
TypeError: 'Future' object is not callable
のでぐぐる
python - Tornado framework. TypeError: 'Future' object is not callable - Stack Overflow
lambda: を使えと、ちなみに意味は分かっとらんよ。動けばええんや(キリッ
from pubnub.callbacks import SubscribeCallback from pubnub.enums import PNStatusCategory from pubnub.pnconfiguration import PNConfiguration from pubnub.pubnub_tornado import PubNubTornado from pubnub.pnconfiguration import PNReconnectionPolicy import tornado.ioloop c = PNConfiguration() c.subscribe_key = 'sub-c-52a9ab50-291b-11e5-baaa-0619f8945a4f' c.reconnect_policy = PNReconnectionPolicy.LINEAR pubnub = PubNubTornado(c) from tornado import gen @gen.coroutine def main(channels): class Callback(SubscribeCallback): def message(self, pubnub, message): print(message.message) s = Callback() pubnub.add_listener(s) pubnub.subscribe().channels(channels).execute() if __name__ == '__main__': channels = [ 'lightning_ticker_FX_BTC_JPY', 'lightning_ticker_BTC_JPY', ] loop = tornado.ioloop.IOLoop() loop.run_sync(lambda: main(channels))