###前提・実現したいこと
一定時間ごとにPubnubを読み込むプログラムを書いているのですが、下記のコードでは関数が1度読み込まれた後、読み込まれたり読み込まれなかったり不安定です。プログラミング初心者なので、Pubnubに問題があるのか、その他の部分に問題があるのか分からず困っています。
よろしくお願いします。
###該当のソースコード
python
1# coding: utf-8 2from pubnub.callbacks import SubscribeCallback 3from pubnub.enums import PNStatusCategory 4from pubnub.pnconfiguration import PNConfiguration 5from pubnub.pubnub_tornado import PubNubTornado 6from pubnub.pnconfiguration import PNReconnectionPolicy 7import threading 8 9c = PNConfiguration() 10c.subscribe_key = 'sub-c-52a9ab50-291b-11e5-baaa-0619f8945a4f' 11c.reconnect_policy = PNReconnectionPolicy.LINEAR 12pubnub = PubNubTornado(c) 13 14from tornado import gen 15@gen.coroutine 16 17def timer_clear(): 18 pubnub.unsubscribe().channels(channels).execute() 19 pubnub.stop() 20 21def main(channels): 22 class Callback(SubscribeCallback): 23 24 def message(self, pubnub, message): 25 print(message.message) 26 timer=threading.Timer(5,timer_clear) 27 timer.start() 28 29 s = Callback() 30 pubnub.add_listener(s) 31 pubnub.subscribe().channels(channels).execute() 32 33 34channels = [ 35 'lightning_ticker_FX_BTC_JPY' 36] 37 38 39while True: 40 time.sleep(5) 41 main(channels) 42 pubnub.start() 43
あなたの回答
tips
プレビュー