Futures WebSocket: Multiple stream types return successful SUBSCRIBE ACK but send zero data frames #526

Activity

1. uibeka commented on Apr 24, 2026

   

   uibeka

   on Apr 24, 2026

   Author

   More actions

   Update: The outage has expanded. In addition to the originally reported aggTrade and forceOrder streams, kline_1m and markPrice@1s are now also affected. These streams were initially working on pre-existing connections, but after those connections expired (24h lifetime), new subscriptions exhibit the same behavior — successful ACK, zero data frames.
   Current state (~14 hours into the incident):

   DEAD (ACK but zero data): aggTrade, kline_1m, markPrice@1s, forceOrder
   ALIVE: depth20@500ms, trade

   4 of 6 Futures WebSocket stream types are now non-functional despite successful subscriptions. Only depth20 and trade continue to deliver data.
2. alplabin commented on Apr 27, 2026

   

   alplabin

   on Apr 27, 2026

   Last edited by alplabin

   Contributor

   More actions

   Hey @uibeka, Have you seen that new entry points have been added to call these endpoints?

   If you want to retrieve WebSocket data using this library, we suggest looking at the example provided or testing it using the following code:

   import asyncio
   import logging
   
   from binance_sdk_derivatives_trading_usds_futures.derivatives_trading_usds_futures import (
       DerivativesTradingUsdsFutures,
   )
   
   logging.basicConfig(level=logging.INFO)
   client = DerivativesTradingUsdsFutures()
   
   async def usds_streams():
       connection = None
       try:
           connection = await client.websocket_streams.create_connection()
           await connection.subscribe(streams=["btcusdt@markPrice@1s", "btcusdt@aggTrade", "btcusdt@kline_1m", "!forceOrder@arr"], stream_url="market")
   
           connection.on("message", lambda data: print(f"Mark Price: {data}"), stream="btcusdt@markPrice@1s")
           connection.on("message", lambda data: print(f"Aggregate Trade: {data}"), stream="btcusdt@aggTrade")
           connection.on("message", lambda data: print(f"Kline 1m: {data}"), stream="btcusdt@kline_1m")
           connection.on("message", lambda data: print(f"Force Order:{data}"), stream="!forceOrder@arr")
   
           await asyncio.sleep(5)
           await connection.unsubscribe(streams=["btcusdt@markPrice@1s", "btcusdt@aggTrade", "btcusdt@kline_1m", "!forceOrder@arr"])
       except Exception as e:
           logging.error(f"usds_streams() error: {e}")
       finally:
           if connection:
               await connection.close_connection(close_session=True)
   
   if __name__ == "__main__":
       asyncio.run(usds_streams())
3. alplabin

   pinned and unpinned a comment on Apr 27, 2026
4. uibeka

   closed this as completedon Apr 28, 2026
5. Bogsey

   added 2 commits that reference this issue on Jun 25, 2026

   feat(common): add optional WebSocket-Streams lifecycle callbacks

   ...

   6dc035b

   feat(common): add optional WebSocket-Streams lifecycle callbacks

   ...

   3a0d45a