→ lycantrope: multiprocess+queue或async 03/06 13:33
推 ddavid: multi-threading? 03/06 15:30
→ f416720001: 沒用過dash 但這需求需要的是要有地方儲存吧,sql存 03/08 21:01
→ f416720001: 個資料吧 03/08 21:01
問了chatgpt 後目前用了以下
import threading
class WebApp:
def __init__(self):
self.realtime_process = RealtimeProcess()
self.start_background_thread()
def start_background_thread(self):
thread = threading.Thread(target=self.update_data)
thread.daemon = True # 设置为守护线程,确保主程序退出时可以关闭
thread.start()
def update_data(self):
while True:
self.quotes = self.realtime_process.realtime_quotes()
self.data = self.realtime_process.realtime_data(self.quotes)
self.dgroups_data, self.dgroups_stocks = (
self.realtime_process.realtime_dgroups_data(self.quotes)
)
sleep(60)
這樣是可以運行沒錯
但是我在檢查時為何self.realtime_process.realtime_quotes()
getting data 2024-03-09 09:19:26.535743
getting dgroups_data 2024-03-09 09:19:26.536059
getting quotes 2024-03-09 09:20:24.959123
getting quotes 2024-03-09 09:20:26.716042
getting data 2024-03-09 09:20:27.876317
getting dgroups_data 2024-03-09 09:20:27.876640
我應該是要每60秒運行一次
但是他卻運行了兩次
因為 self.realtime_quote 是要連接到永豐金API
運行兩次很快就把流量額度用完了
會是什麼問題呢?
已檢查過其他地方沒有用到 update_data
※ 編輯: NoLoveNoMore (59.115.76.99 臺灣), 03/09/2024 09:24:20
→ lycantrope: 寫一個function每60秒跑一次,有這麼複雜w 03/09 12:58