為了縮短 IO 造成的延遲，所以需要使用 Redis 來加速。

安裝 Redis

• 根據 https://redis.io/docs/latest/operate/oss_and_stack/install/install-redis/install-redis-on-mac-os/ 的指示進行安裝
• MacOS 使用 brew install redis
• 裝完之後用 brew services 將服務開啟、並查看服務

brew services start redis
brew services info redis

• 裝完之後，根據 https://redis.io/docs/latest/operate/oss_and_stack/install/install-redis/ 的測試方式確認有開好 redis

redis-cli

設計

考慮到之後我們需要同時從 Fugle 行情 API 拿回四項不同種類的資料，（交易、K現、五檔、聚合），所以至少我也會將資料分成四個不同 channels。 不過當前我只要拿回台指期、之後還要拿選擇權。 這兩個行情理論上放在不同 channel 之後在整理上會比較方便。

初始化

• 在 MTXMonitor 的建構子中，加入 redis 的連線資訊，建立 connection pool

pool = redis.ConnectionPool(host='localhost', port=6379, decode_responses=True)
self.redis_client = redis.Redis(connection_pool=pool)

塞入行情

• 修改 handle_message 函式

def handle_message(self, message):
    msg_dict = json.loads(message)
    print(msg_dict)
    if 'event' in msg_dict and msg_dict['event'] == 'data':
        self.redis_client.publish('mtx', msg_dict['data'])
    elif 'event' in msg_dict and msg_dict['event'] == 'snapshot':
        self.redis_client.publish('mtx', msg_dict['data'])
    else:
        print(msg_dict)

從 Redis 讀出訊息寫檔案

def write_messageq_to_file(self):
    quote_queue = []
    sub = self.redis_client.pubsub()
    sub.subscribe('mtx')
    for message in sub.listen():
        if message['type'] == 'message':
            print(message['data'])
            self.redis_client.rpush('mtx', message['data'])
            json_data = json.dumps(message['data'])
            quote_queue.append(json_data)
        elif message['type'] == 'subscribe':
            print('subscribed')

    file_timemark = dt.now().strftime('%Y%m%d_%H%M%S')
    with open(f'./{file_timemark}.json', 'a') as f:
        f.write(str(quote_queue))
    print('file written')

結論

• 看起來還有些問題要修正，因為 Redis 有記憶體上限
• 晚點要來研究 Redis 的 Memory optimization 記憶體優化文件 https://redis.io/docs/latest/operate/oss_and_stack/management/optimization/memory-optimization/

今日盈虧

• 今天夜盤行情背離小那太多，感覺會崩，等等再來看怎麼復活
• 後續再修改持股量價在這裡