俺にも執筆活動させろボケ

泥を泳ぐ1

pubnubが使えないと詰んでいるのでリアルタイムレート取得から
miraaaman.hateblo.jp
r17u.hatenablog.com
ここらへんをまるこぴするがエラーが出る
f:id:nemui3900:20180217205708j:plain
のでぐぐる
github.com
そしてまたエラー
TypeError: 'Future' object is not callable
のでぐぐる
python - Tornado framework. TypeError: 'Future' object is not callable - Stack Overflow
lambda: を使えと、ちなみに意味は分かっとらんよ。動けばええんや(キリッ
f:id:nemui3900:20180217205933j:plain

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))