合约价格同步

um_price_stream.py

@@ -4,7 +4,6 @@ from db.redis_db import RedisClientLocal
 
 SOCKET = "wss://fstream.binance.com/ws"
 SUBSCRIBE_MESSAGE = "{\"method\": \"SUBSCRIBE\",\"params\":[\"!markPrice@arr\"]}"
-MARK_PRICES = {}
 
 
 def on_open(ws):
@@ -19,9 +18,8 @@ def on_close(ws):
 def on_message(ws, message):
     message = json.loads(message)
     for item in message:
-        print(item)
-        MARK_PRICES[item["s"]] = item["p"]
         redis_con.con().set(f"laravel_cache:premium-price:binance:{item['s']}", item['p'])
+    print("保存成功")