ccxtライブラリを使用し、1秒毎に板情報を取得、csv出力したい。

Question

閲覧ありがとうございます。

前提・実現したいこと

Python初心者です。
ccxtライブラリを使用して板情報を取得し、csv出力するプログラムを作成しています。
下記は1秒おきにデータを取得し、5回取得できたらcsvで保存し、それを繰り返すプログラムになります。

発生している問題・エラーメッセージ

取得したデータが下記となります。
取得時間は1秒毎に取得出来ているのですが、
「ask_price」「ask_size」「bid_price」「bid_size」　はすべて同じデータが出力されています。
この部分を取得時間時の数値としたいのですが、アドバイス頂けると幸いです。
よろしくお願い致します。

	time	    ask_price_0	ask_size_0	bid_price_0	bid_size_0
0	14:53:17	5244383	    0.2	        5244250	   0.05276649
1	14:53:18	5244383	    0.2	        5244250	   0.05276649
2	14:53:19	5244383	    0.2	        5244250	   0.05276649
3	14:53:20	5244383	    0.2	        5244250	   0.05276649
4	14:53:21	5244383	    0.2	        5244250	   0.05276649

該当のソースコード

import ccxt
import time
import os
import pandas as pd
from datetime import datetime as dt

exchange = ccxt.binance()
book = exchange.fetch_order_book('BTC/USDT')

SLEEP_T = 1  #スリープ時間[sec]
DATA_T = 5  #データ保存の時間[sec]

def get_board():                   #板情報取得
    dict_data = {'time':dt.now()}  #現在時刻取得
    for enum, [[bid_price, bid_size], [ask_price, ask_size]] in enumerate(zip(book['bids'], book['asks'])):
        dict_data.update({f'ask_price_{enum}': ask_price})
        dict_data.update({f'ask_size_{enum}': ask_size})
        dict_data.update({f'bid_price_{enum}': bid_price})
        dict_data.update({f'bid_size_{enum}': bid_size})
    return pd.Series(dict_data)

def get_board_repeat():    #板情報取得 ループ処理
    init_time = dt.now()   #開始時間
    end_time = dt.now()    #終了時間
    print('START /', init_time)
    main_list = []                                 #Pandasデータフレームの元となるリストを初期化
    while (end_time - init_time).seconds < DATA_T: #データ保存の時間
        try:                                       #例外が発生しなかった場合
            dict_data = get_board()                #Pandas Seriesに変換
            main_list.append(dict_data)            #Pandas Seriesをリストに追加
        except Exception as e:                     #例外が発生した場合
            print('exception-Z: ', e.args)
        time.sleep(SLEEP_T)                        #スリープ時間
        end_time = dt.now()                        #現在時刻を取得
    df_data = pd.concat(main_list, axis = 1).T     #Pandas Seriesのリストを結合・転置し、キー名をデータフレームの列名とする
    df_data.to_csv('./order_book/order_book_day_{}_init_{}_{}_end_{}_{}.csv'.format(init_time.day, init_time.hour, init_time.minute, end_time.hour, end_time.minute))
    print('END /', end_time)

if __name__ == '__main__':
    if not os.path.exists('./order_book'):        #「order_book」フォルダの存在確認
        os.mkdir('./order_book')                  #フォルダなければ作成
    while True:
        try:                                      #例外が発生しなかった場合
            get_board_repeat()
        except Exception as e:                    #例外が発生した場合
            print('exception-Y: ', e.args)

補足情報（FW/ツールのバージョンなど）

Python:3.8.8
VScode:1.59.1

Answer 1

get_board関数の中で毎回取得してあげれば良いのではないでしょうか？

# 例
def get_board():
    book = exchange.fetch_order_book('BTC/USDT') # この行を追加
    dict_data = {'time':dt.now()}

Comments

[ASL]

ご回答ありがとうございます。
無事にデータを取得する事が出来ました。
ありがとうございました。

Answer 2

book = exchange.fetch_order_book('BTC/USDT')

を一回実行しているだけで、その後更新していません。

その結果、毎回同じ値が出ています。

Comments

[ASL]

ご回答ありがとうございます。
繰り返し実行する為にはどのような編集を行えばよろしいでしょうか。