リアルタイムで更新するpandasのDataFrameをGUIにてテーブル表示したいです。
funcanimationの使い方がわからず、テーブルが新しく取得した情報を反映しません。
Runすると、一回だけ情報を取得し、GUIに反映しています。
継続して情報を取得し、GUIに反映させるにはどのようにすればよいでしょうか?
また、特定の行をif等で条件指定し、背景色(もしくはテキストカラー)を変更することは可能でしょうか?
よろしくお願いいたします。
lang
1from pubnub.callbacks import SubscribeCallback 2from pubnub.enums import PNStatusCategory 3from pubnub.pnconfiguration import PNConfiguration 4from pubnub.pubnub_tornado import PubNubTornado 5from pubnub.pnconfiguration import PNReconnectionPolicy 6import datetime 7import pandas as pd 8from tornado import gen 9import matplotlib.pyplot as plt 10from matplotlib.animation import FuncAnimation 11 12c = PNConfiguration() 13c.subscribe_key = 'sub-c-52a9ab50-291b-11e5-baaa-0619f8945a4f' 14c.reconnect_policy = PNReconnectionPolicy.LINEAR 15pubnub = PubNubTornado(c) 16 17df = pd.DataFrame(index=['datetime'], 18 columns=['id', 19 'side', 20 'price', 21 'size', 22 'exec_date', 23 'buy_child_order_acceptance_id', 24 'sell_child_order_acceptance_id']) 25 26fig, ax = plt.subplots() 27fig.patch.set_visible(False) 28ax.axis('off') 29ax.axis('tight') 30 31#dataframeに入ったものをGUIに表示する。 32def table(df): 33 ax.table(cellText=df.values, colLabels=df.columns, loc='center') 34 fig.tight_layout() 35 plt.show() 36 37#受信したデータを処理し、dataframeに入れる。 38def dataframe(db): 39 global df 40 now = datetime.datetime.now() 41 df.dropna(how='any') 42 for i in range(0, len(db), 1): 43 db1 = db[i] 44 if 0.01 <= db1['size']: 45 now2 = now.strftime("%H:%M:%S") 46 db1['exec_date'] = now2 47 db1['price'] = round(db1['price']) 48 db1['size'] = round(db1['size'], 1) 49 db2 = pd.Series(db1) 50 df = df.append(db2, ignore_index=True) 51 del df['buy_child_order_acceptance_id'] 52 del df['sell_child_order_acceptance_id'] 53 del df['id'] 54 table(df) 55 56#データを受信し、dataframeへ渡す。 57@gen.coroutine 58def main(channels): 59 60 class Callback(SubscribeCallback): 61 def presence(self, pubnub, presence): 62 pass 63 64 def status(self, pubnub, status): 65 if status.category == PNStatusCategory.PNUnexpectedDisconnectCategory: 66 pass 67 elif status.category == PNStatusCategory.PNConnectedCategory: 68 pass 69 elif status.category == PNStatusCategory.PNReconnectedCategory: 70 pass 71 elif status.category == PNStatusCategory.PNDecryptionErrorCategory: 72 pass 73 74 def message(self, pubnub, message): 75 db = message.message 76 dataframe(db) 77 78 s = Callback() 79 pubnub.add_listener(s) 80 pubnub.subscribe().channels(channels).execute() 81 82def pre_main(): 83 channels = [ 84 'lightning_executions_FX_BTC_JPY', 85 ] 86 main(channels) 87 pubnub.start() 88 root.mainloop() 89 90if __name__ == '__main__': 91 pre_main() 92
回答1件
あなたの回答
tips
プレビュー
バッドをするには、ログインかつ
こちらの条件を満たす必要があります。