5ifSSKrSSKrSSKJr SSKJrJrJrJrJ r SSK J r SSK J r SSKJr SSKJr SSKJr SS KJr SS KJr SS KJr "S S \\5r"SS5r"SS\5rg)N)Enum)OptionalListDictCallableAny)KEEPALIVE_TIMEOUT)KeepAliveWebsocket)ReconnectingWebsocket)ThreadedApiManager) AsyncClient) FuturesType) ContractType)get_loopc(\rSrSrSrSrSrSrSrSr g) BinanceSocketTypeSpot USD_M_FuturesCoin_M_FuturesVanilla_OptionsAccountN) __name__ __module__ __qualname____firstlineno__SPOT USD_M_FUTURESCOIN_M_FUTURESOPTIONSACCOUNT__static_attributes__r`/var/www/html/BTCUSD/btcusdt_trading_app/venv/lib/python3.13/site-packages/binance/ws/streams.pyrrs D#M%NGGr$rc \rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rS r\S4S\S\4SjjrSXS\\4SjjrSSS\R24S\S\\S\S\S\S\4 SjjrSYS\S\\S\S\S\4 SjjrSZS\S\S\4Sjjr S[S\S\4S jjr!S\4S!jr"S\S"\S#\\S$\\4S%jjr#\RH4S"\4S&jjr%\RH\RL\'RP4S"\S\S'\'4S(jjr)S]S)\4S*jjr*S"\4S+jr+S"\4S,jr,\RL4S"\S\4S-jjr-S"\4S.jr.S"\4S/jr/S0r0S1r1S2r2S^S"\S4\4S5jjr3S3\RL4S"\S4\S\4S6jjr4S3\RL4S4\S\4S7jjr5\RL4S"\S\4S8jjr6\RL4S"\S\4S9jjr7S:\RL4S;\S\4S<jjr8S"\4S=jr9S>r:S?\;\4S@jrSCr?SDr@SErASFrBSGrCSHrDSIrES"\4SJjrFS"\4SKjrGS"\SL\4SMjrHS"\4SNjrI\RH4S"\4SOjjrJS_S"\S#\4SPjjrKS \RL4S"\S#\4SQjjrLSRrMS"\SL\4SSjrNS"\4STjrOS"\4SUjrPSVrQSWrRg)`BinanceSocketManagerzwss://stream.binance.{}:9443/z$wss://stream.testnet.binance.vision/zwss://demo-stream.binance.com/zwss://fstream.binance.{}/zwss://stream.binancefuture.com/z wss://fstream.binancefuture.com/zwss://dstream.binance.{}/z wss://dstream.binancefuture.com/z#wss://nbstream.binance.{}/eoptions/51020dclientmax_queue_sizecURRUR5UlURRUR5UlURRUR5UlUR RUR5Ul0Ul[5UlXl X l URRUl URRUl X0l 0Ulg)aInitialise the BinanceSocketManager :param client: Binance API client :type client: binance.AsyncClient :param user_timeout: Timeout for user socket in seconds :param max_queue_size: Max size of the websocket queue, defaults to 100 :type max_queue_size: int N) STREAM_URLformattld FSTREAM_URL DSTREAM_URL OPTIONS_URL_connsr_loop_client _user_timeouttestnetdemo_max_queue_size ws_kwargs)selfr- user_timeoutr.s r%__init__BinanceSocketManager.__init__*s//00<++226::>++226::>++226::> Z  )||++ LL%% -r$N stream_urlcU(aU$URnUR(aURnU$UR(a URnU$N)r0r:STREAM_TESTNET_URLr;STREAM_DEMO_URLr>rBs r%_get_stream_url$BinanceSocketManager._get_stream_urlFsH  __ <<00JYY--Jr$ws/Fpathprefix is_binary socket_typereturnc T^^TSU3n[TRSS5nU(aUSU3nUTR;a\[SUTR U5UUU4SjUTRR TR S.TRD6TRU'TRU$)N_ TIME_UNITz ?timeUnit=c0>TRTSU35$)NrQ _exit_socket)pr>rNs r%2BinanceSocketManager._get_socket..asD$5$5 Qqc6J$Kr$)rKurlrL exit_cororM https_proxyr.r)getattrr8r6r rHr[r<r=)r>rKrBrLrMrNconn_id time_units` ` r% _get_socket BinanceSocketManager._get_socketPs!M4&)DLL+t< V:i[1D $++ %#8 $((4K# LL44#33 $.. $DKK {{7##r$c <^^[RSU3mTTR;ag[STRTR U5UUUU4SjUTR TRRS.TRD6TRT'TRT$)NrQc&>TRT5$rDrT)rVr]r>s r%rW:BinanceSocketManager._get_account_socket..xsD$5$5g$>r$)r-rYkeepalive_typerLrZrMr?r[r) rr"r6r r8rHr9r[r=)r>rKrBrLrMr]s` @r%_get_account_socket(BinanceSocketManager._get_account_socketjs'../q7 $++ %#5 $||((4#>#!// LL44 $.. $DKK {{7##r$ futures_typec[RnU[R:XaHURnUR (a UR nOeUR(a URnOGURnUR (a URnOUR(a URnURXX4S9$)N)rN) rrrUSD_Mr3r:FSTREAM_TESTNET_URLr;FSTREAM_DEMO_URLr4DSTREAM_TESTNET_URLDSTREAM_DEMO_URLr_)r>rKrgrLrNrBs r%_get_futures_socket(BinanceSocketManager._get_futures_sockets*;)H)H ;,, ,))J||!55 !22 ))J||!55 !22 &RRr$c\URnURUUUS[RS9$)NF)rMrN)r5r_rr!)r>rKrLrBs r%_get_options_socket(BinanceSocketManager._get_options_sockets:%%    )11    r$cB# URU5IShvN gN7frD) _stop_socket)r>rKs r%rU!BinanceSocketManager._exit_sockets%%%s symboldepthintervalcUR5S-nU(a US:waUU3nU(aUS;a USUS3nO [S5eURU5$)aqStart a websocket for symbol market depth returning either a diff or a partial book https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md#partial-book-depth-streams :param symbol: required :type symbol: str :param depth: optional Number of depth entries to return, default None. If passed returns a partial book instead of a diff :type depth: str :param interval: optional interval for updates, default None. If not set, updates happen every second. Must be 0, None (1s) or 100 (100ms) :type interval: int :returns: connection key string if successful, False otherwise Partial Message Format .. code-block:: python { "lastUpdateId": 160, # Last update ID "bids": [ # Bids to be updated [ "0.0024", # price level to be updated "10", # quantity [] # ignore ] ], "asks": [ # Asks to be updated [ "0.0026", # price level to be updated "100", # quantity [] # ignore ] ] } Diff Message Format .. code-block:: python { "e": "depthUpdate", # Event type "E": 123456789, # Event time "s": "BNBBTC", # Symbol "U": 157, # First update ID in event "u": 160, # Final update ID in event "b": [ # Bids to be updated [ "0.0024", # price level to be updated "10", # quantity [] # ignore ] ], "a": [ # Asks to be updated [ "0.0026", # price level to be updated "100", # quantity [] # ignore ] ] } @depth1)rr,@mszAWebsocket interval value not allowed. Allowed values are [0, 100])lower ValueErrorr_)r>rvrwrx socket_names r% depth_socket!BinanceSocketManager.depth_socketslDllnx/ Uc\(M%1K 8#!, Qxj;  W ,,r$cNUR5SU3nURU5$)aStart a websocket for symbol kline data https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md#klinecandlestick-streams :param symbol: required :type symbol: str :param interval: Kline interval, default KLINE_INTERVAL_1MINUTE :type interval: str :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "e": "kline", # event type "E": 1499404907056, # event time "s": "ETHBTC", # symbol "k": { "t": 1499404860000, # start time of this bar "T": 1499404919999, # end time of this bar "s": "ETHBTC", # symbol "i": "1m", # interval "f": 77462, # first trade id "L": 77465, # last trade id "o": "0.10278577", # open "c": "0.10278645", # close "h": "0.10278712", # high "l": "0.10278518", # low "v": "17.47929838", # volume "n": 4, # number of trades "x": false, # whether this bar is final "q": "1.79662878", # quote volume "V": "2.34879839", # volume of active buy "Q": "0.24142166", # quote volume of active buy "B": "13279784.01349473" # can be ignored } } @kline_)r~r_)r>rvrxrKs r% kline_socket!BinanceSocketManager.kline_sockets-R,,.! 3%%r$ contract_typechUR5SURSU3nURUSUS9$)aStart a websocket for symbol kline data for the perpeual futures stream https://binance-docs.github.io/apidocs/futures/en/#continuous-contract-kline-candlestick-streams :param symbol: required :type symbol: str :param interval: Kline interval, default KLINE_INTERVAL_1MINUTE :type interval: str :param futures_type: use USD-M or COIN-M futures default USD-M :param contract_type: use PERPETUAL or CURRENT_QUARTER or NEXT_QUARTER default PERPETUAL :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "e":"continuous_kline", // Event type "E":1607443058651, // Event time "ps":"BTCUSDT", // Pair "ct":"PERPETUAL" // Contract type "k":{ "t":1607443020000, // Kline start time "T":1607443079999, // Kline close time "i":"1m", // Interval "f":116467658886, // First trade ID "L":116468012423, // Last trade ID "o":"18787.00", // Open price "c":"18804.04", // Close price "h":"18804.04", // High price "l":"18786.54", // Low price "v":"197.664", // volume "n": 543, // Number of trades "x":false, // Is this kline closed? "q":"3715253.19494", // Quote asset volume "V":"184.769", // Taker buy volume "Q":"3472925.84746", //Taker buy quote asset volume "B":"0" // Ignore } } _@continuousKline_ rQz@continuousKline_rJrLrg)r~valuern)r>rvrxrgrrKs r%kline_futures_socket)BinanceSocketManager.kline_futures_socketsBf,,.!=#6#6"77H S''U'VVr$ update_timec,URSUS35$)a0Start a miniticker websocket for all trades This is not in the official Binance api docs, but this is what feeds the right column on a ticker page on Binance. :param update_time: time between callbacks in milliseconds, must be 1000 or greater :type update_time: int :returns: connection key string if successful, False otherwise Message Format .. code-block:: python [ { 'e': '24hrMiniTicker', # Event type 'E': 1515906156273, # Event time 's': 'QTUMETH', # Symbol 'c': '0.03836900', # close 'o': '0.03953500', # open 'h': '0.04400000', # high 'l': '0.03756000', # low 'v': '147435.80000000', # volume 'q': '5903.84338533' # quote volume } ] z!miniTicker@arr@r}r_)r>rs r%miniticker_socket&BinanceSocketManager.miniticker_socketPs<"2;-r BCCr$cFURUR5S-5$)aStart a websocket for symbol trade data https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md#trade-streams :param symbol: required :type symbol: str :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "e": "trade", # Event type "E": 123456789, # Event time "s": "BNBBTC", # Symbol "t": 12345, # Trade ID "p": "0.001", # Price "q": "100", # Quantity "b": 88, # Buyer order Id "a": 50, # Seller order Id "T": 123456785, # Trade time "m": true, # Is the buyer the market maker? "M": true # Ignore. } @trader_r~r>rvs r% trade_socket!BinanceSocketManager.trade_socketps <  9::r$cFURUR5S-5$)aStart a websocket for symbol trade data https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md#aggregate-trade-streams :param symbol: required :type symbol: str :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "e": "aggTrade", # event type "E": 1499405254326, # event time "s": "ETHBTC", # symbol "a": 70232, # aggregated tradeid "p": "0.10281118", # price "q": "8.15632997", # quantity "f": 77489, # first breakdown trade id "l": 77489, # last breakdown trade id "T": 1499405254324, # trade time "m": false, # whether buyer is a maker "M": true # can be ignored } @aggTraderrs r%aggtrade_socket$BinanceSocketManager.aggtrade_sockets :  <==r$cDURUR5S-US9$)aStart a websocket for aggregate symbol trade data for the futures stream :param symbol: required :param futures_type: use USD-M or COIN-M futures default USD-M :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "e": "aggTrade", // Event type "E": 123456789, // Event time "s": "BTCUSDT", // Symbol "a": 5933014, // Aggregate trade ID "p": "0.001", // Price "q": "100", // Quantity "f": 100, // First trade ID "l": 105, // Last trade ID "T": 123456785, // Trade time "m": true, // Is the buyer the market maker? } rrgrnr~r>rvrgs r%aggtrade_futures_socket,BinanceSocketManager.aggtrade_futures_sockets,8'' LLN[ (|(  r$cFURUR5S-5$)aStart a websocket for a symbol's miniTicker data https://binance-docs.github.io/apidocs/spot/en/#individual-symbol-mini-ticker-stream :param symbol: required :type symbol: str :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "e": "24hrMiniTicker", // Event type "E": 123456789, // Event time "s": "BNBBTC", // Symbol "c": "0.0025", // Close price "o": "0.0010", // Open price "h": "0.0025", // High price "l": "0.0010", // Low price "v": "10000", // Total traded base asset volume "q": "18" // Total traded quote asset volume } z @miniTickerrrs r%symbol_miniticker_socket-BinanceSocketManager.symbol_miniticker_sockets 6  >??r$cFURUR5S-5$)aStart a websocket for a symbol's ticker data https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md#individual-symbol-ticker-streams :param symbol: required :type symbol: str :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "e": "24hrTicker", # Event type "E": 123456789, # Event time "s": "BNBBTC", # Symbol "p": "0.0015", # Price change "P": "250.00", # Price change percent "w": "0.0018", # Weighted average price "x": "0.0009", # Previous day's close price "c": "0.0025", # Current day's close price "Q": "10", # Close trade's quantity "b": "0.0024", # Best bid price "B": "10", # Bid bid quantity "a": "0.0026", # Best ask price "A": "100", # Best ask quantity "o": "0.0010", # Open price "h": "0.0025", # High price "l": "0.0010", # Low price "v": "10000", # Total traded base asset volume "q": "18", # Total traded quote asset volume "O": 0, # Statistics open time "C": 86400000, # Statistics close time "F": 0, # First trade ID "L": 18150, # Last trade Id "n": 18151 # Total number of trades } @tickerrrs r%symbol_ticker_socket)BinanceSocketManager.symbol_ticker_sockets!R  :;;r$c$URS5$)aStart a websocket for all ticker data By default all markets are included in an array. https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md#all-market-tickers-stream :param coro: callback function to handle messages :type coro: function :returns: connection key string if successful, False otherwise Message Format .. code-block:: python [ { 'F': 278610, 'o': '0.07393000', 's': 'BCCBTC', 'C': 1509622420916, 'b': '0.07800800', 'l': '0.07160300', 'h': '0.08199900', 'L': 287722, 'P': '6.694', 'Q': '0.10000000', 'q': '1202.67106335', 'p': '0.00494900', 'O': 1509536020916, 'a': '0.07887800', 'n': 9113, 'B': '1.00000000', 'c': '0.07887900', 'x': '0.07399600', 'w': '0.07639068', 'A': '2.41900000', 'v': '15743.68900000' } ] !ticker@arrrr>s r% ticker_socket"BinanceSocketManager.ticker_socketsT ..r$cBURS[R5$)aStart a websocket for all ticker data By default all markets are included in an array. https://binance-docs.github.io/apidocs/futures/en/#all-market-tickers-streams :returns: connection key string if successful, False otherwise Message Format .. code-block:: python [ { "e": "24hrTicker", // Event type "E": 123456789, // Event time "s": "BTCUSDT", // Symbol "p": "0.0015", // Price change "P": "250.00", // Price change percent "w": "0.0018", // Weighted average price "c": "0.0025", // Last price "Q": "10", // Last quantity "o": "0.0010", // Open price "h": "0.0025", // High price "l": "0.0010", // Low price "v": "10000", // Total traded base asset volume "q": "18", // Total traded quote asset volume "O": 0, // Statistics open time "C": 86400000, // Statistics close time "F": 0, // First trade ID "L": 18150, // Last trade Id "n": 18151 // Total number of trades } ] r)rnrrirs r%futures_ticker_socket*BinanceSocketManager.futures_ticker_socketCsH'' {7H7HIIr$cBURS[R5$)aStart a websocket for all ticker data By default all markets are included in an array. https://binance-docs.github.io/apidocs/delivery/en/#all-market-tickers-streams :returns: connection key string if successful, False otherwise Message Format .. code-block:: python [ { "e": "24hrTicker", // Event type "E": 123456789, // Event time "s": "BTCUSDT", // Symbol "p": "0.0015", // Price change "P": "250.00", // Price change percent "w": "0.0018", // Weighted average price "c": "0.0025", // Last price "Q": "10", // Last quantity "o": "0.0010", // Open price "h": "0.0025", // High price "l": "0.0010", // Low price "v": "10000", // Total traded base asset volume "q": "18", // Total traded quote asset volume "O": 0, // Statistics open time "C": 86400000, // Statistics close time "F": 0, // First trade ID "L": 18150, // Last trade Id "n": 18151 // Total number of trades } ] r)rnrCOIN_Mrs r%futures_coin_ticker_socket/BinanceSocketManager.futures_coin_ticker_socketisH'' {7I7IJJr$TfastcvU(aSOSnURUR5U-[RS9$)aStart a websocket for a symbol's futures mark price https://binance-docs.github.io/apidocs/delivery/en/#index-price-stream :param symbol: required :param fast: use faster or 1s default :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "e": "indexPriceUpdate", // Event type "E": 1591261236000, // Event time "i": "BTCUSD", // Pair "p": "9636.57860000", // Index Price } z@indexPrice@1sz @indexPricer)rnr~rr)r>rvr stream_names r%index_price_socket'BinanceSocketManager.index_price_sockets< +/&M '' LLN[ ({7I7I(  r$cZU(aSOSnURUR5U-US9$)aStart a websocket for a symbol's futures mark price https://binance-docs.github.io/apidocs/futures/en/#mark-price-stream :param symbol: required :param fast: use faster or 1s default :param futures_type: use USD-M or COIN-M futures default USD-M :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "e": "markPriceUpdate", // Event type "E": 1562305380000, // Event time "s": "BTCUSDT", // Symbol "p": "11185.87786614", // Mark price "r": "0.00030000", // Funding rate "T": 1562306400000 // Next funding time } z @markPrice@1s @markPricerr)r>rvrrgrs r%symbol_mark_price_socket-BinanceSocketManager.symbol_mark_price_sockets5.*.o< '' LLN[ (|(  r$c6U(aSOSnURX2S9$)aStart a websocket for all futures mark price data By default all symbols are included in an array. https://binance-docs.github.io/apidocs/futures/en/#mark-price-stream-for-all-market :param fast: use faster or 1s default :param futures_type: use USD-M or COIN-M futures default USD-M :returns: connection key string if successful, False otherwise Message Format .. code-block:: python [ { "e": "markPriceUpdate", // Event type "E": 1562305380000, // Event time "s": "BTCUSDT", // Symbol "p": "11185.87786614", // Mark price "r": "0.00030000", // Funding rate "T": 1562306400000 // Next funding time } ] z!markPrice@arr@1sz!markPrice@arrrrn)r>rrgrs r%all_mark_price_socket*BinanceSocketManager.all_mark_price_sockets#..2)7G '' 'OOr$cDURUR5S-US9$)aStart a websocket for a symbol's ticker data By default all markets are included in an array. https://binance-docs.github.io/apidocs/futures/en/#individual-symbol-book-ticker-streams :param symbol: required :param futures_type: use USD-M or COIN-M futures default USD-M :returns: connection key string if successful, False otherwise .. code-block:: python [ { "u":400900217, // order book updateId "s":"BNBUSDT", // symbol "b":"25.35190000", // best bid price "B":"31.21000000", // best bid qty "a":"25.36520000", // best ask price "A":"40.66000000" // best ask qty } ] @bookTickerrrrs r%symbol_ticker_futures_socket1BinanceSocketManager.symbol_ticker_futures_sockets,*'' LLN] *(  r$cDURUR5S-US9$)aStart a futures websocket for a single symbol's ticker data https://binance-docs.github.io/apidocs/futures/en/#individual-symbol-ticker-streams :param symbol: required :type symbol: str :param futures_type: use USD-M or COIN-M futures default USD-M :returns: connection key string if successful, False otherwise .. code-block:: python { "e": "24hrTicker", // Event type "E": 123456789, // Event time "s": "BTCUSDT", // Symbol "p": "0.0015", // Price change } rrrrs r%'individual_symbol_ticker_futures_socketrrgs r%all_ticker_futures_socket.BinanceSocketManager.all_ticker_futures_sockets:'''KKr$cFURUR5S-5$)aStart a websocket for the best bid or ask's price or quantity for a specified symbol. https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md#individual-symbol-book-ticker-streams :param symbol: required :type symbol: str :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "u":400900217, // order book updateId "s":"BNBUSDT", // symbol "b":"25.35190000", // best bid price "B":"31.21000000", // best bid qty "a":"25.36520000", // best ask price "A":"40.66000000" // best ask qty } rrrs r%symbol_book_ticker_socket.BinanceSocketManager.symbol_book_ticker_socket's 0  >??r$c$URS5$)amStart a websocket for the best bid or ask's price or quantity for all symbols. https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md#all-book-tickers-stream :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { // Same as @bookTicker payload } rrrs r%book_ticker_socket'BinanceSocketManager.book_ticker_socketAs  ..r$streamscJSSRU53nURUSS9$)a,Start a multiplexed socket using a list of socket names. User stream sockets can not be included. Symbols in socket name must be lowercase i.e bnbbtc@aggTrade, neobtc@ticker Combined stream events are wrapped as follows: {"stream":"","data":} https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md :param streams: list of stream names in lower case :type streams: list :returns: connection key string if successful, False otherwise Message Format - see Binance API docs for all types streams=/stream?rL)joinr_)r>rrKs r%multiplex_socket%BinanceSocketManager.multiplex_socketSs0$#((7+,-Y77r$cxSRUVs/sHo"PM sn5nSU3nURUSS9$s snf)zStart a multiplexed socket using a list of socket names. https://developers.binance.com/docs/derivatives/option/websocket-market-streams rrrr)rrq)r>rsr stream_paths r%options_multiplex_socket-BinanceSocketManager.options_multiplex_sockethsH hh737a734   . '' I'FF 4s 7cLSSRU53nURUSUS9$)aWStart a multiplexed socket using a list of socket names. User stream sockets can not be included. Symbols in socket name must be lowercase i.e bnbbtc@aggTrade, neobtc@ticker Combined stream events are wrapped as follows: {"stream":"","data":} https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md :param streams: list of stream names in lower case :param futures_type: use USD-M or COIN-M futures default USD-M :returns: connection key string if successful, False otherwise Message Format - see Binance API docs for all types rrrr)rrn)r>rrgrKs r%futures_multiplex_socket-BinanceSocketManager.futures_multiplex_socketrs9(#((7+,-'' (  r$cURnUR(a URnOUR(a URnUR SUS9$)a4Start a websocket for user data https://github.com/binance-exchange/binance-official-api-docs/blob/master/user-data-stream.md https://binance-docs.github.io/apidocs/spot/en/#listen-key-spot :returns: connection key string if successful, False otherwise Message Format - see Binance API docs for all types userrBr0r:rEr;rFrerGs r% user_socket BinanceSocketManager.user_socketsG__ <<00J YY--J'':'FFr$cURnUR(a URnOUR(a URnUR SUS9$)zStart a websocket for futures user data https://binance-docs.github.io/apidocs/futures/en/#user-data-streams :returns: connection key string if successful, False otherwise Message Format - see Binanace API docs for all types futuresrr3r:rjr;rkrerGs r%futures_user_socket(BinanceSocketManager.futures_user_socketsI%% <<11J YY..J'' j'IIr$c6URSURS9$)zStart a websocket for coin futures user data https://binance-docs.github.io/apidocs/delivery/en/#user-data-streams :returns: connection key string if successful, False otherwise Message Format - see Binanace API docs for all types coin_futuresr)rer4rs r%coin_futures_user_socket-BinanceSocketManager.coin_futures_user_sockets ''4CSCS'TTr$cURnUR(a URnOUR(a URnUR SUS9$)zStart a websocket for cross-margin data https://binance-docs.github.io/apidocs/spot/en/#listen-key-margin :returns: connection key string if successful, False otherwise Message Format - see Binance API docs for all types marginrrrGs r% margin_socket"BinanceSocketManager.margin_socketsG__ <<00J YY--J''Z'HHr$cURnUR(a URnOUR(a URnUR SUS9$)zStart a websocket for futures data https://binance-docs.github.io/apidocs/futures/en/#websocket-market-streams :returns: connection key string if successful, False otherwise Message Format - see Binance API docs for all types rrrrGs r%futures_socket#BinanceSocketManager.futures_socketsI%% <<11J YY..J'' j'IIr$cURnUR(a URnOUR(a URnUR SUS9$)zStart a websocket for coin futures data https://binance-docs.github.io/apidocs/delivery/en/#websocket-market-streams :returns: connection key string if successful, False otherwise Message Format - see Binance API docs for all types rr)r4r:rlr;rmrerGs r%coin_futures_socket(BinanceSocketManager.coin_futures_socketsI%% <<11J YY..J'':'NNr$cURnUR(a URnOUR(a URnUS- nUR SUS9$)zStart a websocket for portfolio margin user data https://developers.binance.com/docs/derivatives/portfolio-margin/user-data-streams :returns: connection key string if successful, False otherwise Message Format - see Binance API docs for all types zpm/portfolio_marginrrrGs r%portfolio_margin_socket,BinanceSocketManager.portfolio_margin_socketsT%% <<11J YY..Je ''(:z'RRr$cURnUR(a URnOUR(a URnUR XS9$)a@Start a websocket for isolated margin data https://binance-docs.github.io/apidocs/spot/en/#listen-key-isolated-margin :param symbol: required - symbol for the isolated margin account :type symbol: str :returns: connection key string if successful, False otherwise Message Format - see Binance API docs for all types rr)r>rvrBs r%isolated_margin_socket+BinanceSocketManager.isolated_margin_socketsE__ <<00J YY--J'''FFr$cFURUR5S-5$)aSubscribe to a 24-hour ticker info stream for options trading. API Reference: https://developers.binance.com/docs/derivatives/option/websocket-market-streams/24-hour-TICKER Stream provides real-time 24hr ticker information for all symbols. Only symbols whose ticker info changed will be sent. Updates every 1000ms. :param symbol: The option symbol to subscribe to (e.g. "BTC-220930-18000-C") :type symbol: str rrqupperrs r%options_ticker_socket*BinanceSocketManager.options_ticker_sockets '' (BCCr$expiration_datecLURUR5S-U-5$)aSubscribe to a 24-hour ticker info stream by underlying asset and expiration date. API Reference: https://developers.binance.com/docs/derivatives/option/websocket-market-streams/24-hour-TICKER-by-underlying-asset-and-expiration-data Stream provides real-time 24hr ticker information grouped by underlying asset and expiration date. Updates every 1000ms. :param symbol: The underlying asset (e.g., "ETH") :type symbol: str :param expiration_date: The expiration date (e.g., "220930" for Sept 30, 2022) :type expiration_date: str z@ticker@rr>rvr s r%#options_ticker_by_expiration_socket8BinanceSocketManager.options_ticker_by_expiration_sockets%'' (Co(UVVr$cFURUR5S-5$)arSubscribe to a real-time trade information stream. API Reference: https://developers.binance.com/docs/derivatives/option/websocket-market-streams/Trade-Streams Stream pushes raw trade information for a specific symbol or underlying asset. Updates every 50ms. :param symbol: The option symbol or underlying asset (e.g., "BTC-200630-9000-P" or "BTC") :type symbol: str rrrs r%options_recent_trades_socket1BinanceSocketManager.options_recent_trades_socket*s '' (ABBr$cLURUR5S-U-5$)a)Subscribe to a Kline/Candlestick data stream. API Reference: https://developers.binance.com/docs/derivatives/option/websocket-market-streams/Kline-Candlestick-Streams Stream pushes updates to the current klines/candlestick every 1000ms (if existing). Available intervals: - Minutes: "1m", "3m", "5m", "15m", "30m" - Hours: "1h", "2h", "4h", "6h", "12h" - Days: "1d", "3d" - Weeks: "1w" :param symbol: The option symbol (e.g., "BTC-200630-9000-P") :type symbol: str :param interval: Kline interval, default KLINE_INTERVAL_1MINUTE :type interval: str rr)r>rvrxs r%options_kline_socket)BinanceSocketManager.options_kline_socket7s%('' (BX(MNNr$c^URUR5S-[U5-5$)aSubscribe to partial book depth stream for options trading. API Reference: https://developers.binance.com/docs/derivatives/option/websocket-market-streams/Partial-Book-Depth-Streams Stream provides top N bids and asks from the order book. Default update speed is 500ms if not specified in the stream name. :param symbol: The option symbol (e.g., "BTC-200630-9000-P") :type symbol: str :param depth: Number of price levels. Valid values: "10", "20", "50", "100" :type depth: str rz)rqrstr)r>rvrws r%options_depth_socket)BinanceSocketManager.options_depth_socketMs)'' (ACJ(NOOr$c\URUR5S-[U5-US9$)a9Subscribe to a futures depth data stream https://binance-docs.github.io/apidocs/futures/en/#partial-book-depth-streams :param symbol: required :type symbol: str :param depth: optional Number of depth entries to return, default 10. :type depth: str :param futures_type: use USD-M or COIN-M futures default USD-M rzr)rnr~r)r>rvrwrgs r%futures_depth_socket)BinanceSocketManager.futures_depth_socket\s5'' LLNX %E 2(  r$c$URS5$)a6Subscribe to a new symbol listing information stream. Stream provides real-time notifications when new option symbols are listed. Updates every 50ms. Stream name: option_pair API Reference: https://developers.binance.com/docs/derivatives/option/websocket-market-streams/New-Symbol-Info Response fields include: - Event type and timestamps - Underlying index (e.g., 'BTCUSDT') - Quotation asset (e.g., 'USDT') - Trading pair name (e.g., 'BTC-221116-21000-C') - Conversion ratio and minimum trade volume - Option type (CALL/PUT) - Strike price and expiration time option_pair)rqrs r%options_new_symbol_socket.BinanceSocketManager.options_new_symbol_socketks&'' 66r$cLURUR5S-U-5$)aSubscribe to an options open interest stream. Stream provides open interest information for specific underlying asset on specific expiration date. Updates every 60 seconds. Stream name format: @openInterest@ API Reference: https://developers.binance.com/docs/derivatives/option/websocket-market-streams/Open-Interest Response fields include: - Event type and timestamps - Option symbol (e.g., 'ETH-221125-2700-C') - Open interest in contracts - Open interest in USDT :param symbol: The underlying asset (e.g., "ETH") :type symbol: str :param expiration_date: The expiration date (e.g., "221125" for Nov 25, 2022) :type expiration_date: str z@openInterest@rr s r%options_open_interest_socket1BinanceSocketManager.options_open_interest_sockets&*'' 9I(IO([\\r$cFURUR5S-5$)aSubscribe to an options mark price stream. Stream provides mark price information for all option symbols on specific underlying asset. Updates every 1000ms. Stream name format: @markPrice API Reference: https://developers.binance.com/docs/derivatives/option/websocket-market-streams/Mark-Price Response fields include: - Event type and timestamps - Option symbol (e.g., 'ETH-220930-1500-C') - Option mark price :param symbol: The underlying asset (e.g., "ETH") :type symbol: str rrrs r%options_mark_price_socket.BinanceSocketManager.options_mark_price_sockets $'' (EFFr$cFURUR5S-5$)aSubscribe to an options index price stream. API Reference: https://developers.binance.com/docs/derivatives/option/websocket-market-streams/Index-Price-Streams Stream provides index price information for underlying assets (e.g., ETHUSDT). Updates every 1000ms. Response fields include: - Event type and timestamps - Underlying symbol (e.g., 'ETHUSDT') - Index price :param symbol: The underlying symbol (e.g., "ETHUSDT") :type symbol: str z@indexrrs r%options_index_price_socket/BinanceSocketManager.options_index_price_sockets '' (ABBr$cF# XR;agURU g7f)zyStop a websocket given the connection key :param conn_key: Socket connection key :type conn_key: string :returns: None N)r6)r>conn_keys r%rt!BinanceSocketManager._stop_sockets  ;; &  KK !s!) r4r3r5r0r8r6r7r<r9r;r:r=rD)NrJF)zstream?streams=)rJNNiTr*)Srrrrr0rErFr3rjrkr4rlrmr5WEBSOCKET_DEPTH_5WEBSOCKET_DEPTH_10WEBSOCKET_DEPTH_20r r intr@rrrHrrboolr r_r rerrnrqrUrKLINE_INTERVAL_1MINUTErrir PERPETUALrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr rrrrrr!r$r'rtr#rr$r%r'r's0J?6O-K;9-K<97K '!  8(3-%)):)?)? $$SM$ $  $ ' $ $:%) $$SM$ $  $  $0CTSS'2Sc>@8C7H7H  )4 @@s@:)<3)@@4/$8S 8*GS G?J>O>O Cy 0; 2G"J" UI"J O S"GSG& DC D W# WPS W C3 C%0$F$FOO, P3 Ps P>BP[PaPa  3  s  7*]3]].GG(CC$ "r$r'c|^\rSrSrSAS\\S\\S\\\\4S\S\S\\\\4S\\S \\ RS \ 4U4S jjjr S r SBS \S\S\\\4S\\S\4 SjjrSCS \S\S\\S\\ S\4 Sjjr\R$4S \S\S\4Sjjr\R$\R*\R.4S \S\S\S\S\4 SjjrSDS \S\ S\4SjjrS \S\S\4SjrS \S\S\4Sjr\R*4S \S\S\S\4SjjrS \S\S\4S jrS \S\S\4S!jrS \S\4S"jrSES \S\S$\S\4S%jjr S#\R*4S \S\S$\S\S\4 S&jjr!S#\R*4S \S$\S\S\4S'jjr"\R*4S \S\S\S\4S(jjr#\R*4S \S\S\S\4S)jjr$\R*4S \S\S\4S*jjr%S \S\S\4S+jr&S \S\4S,jr'S \S-\(\S\4S.jr)S \S-\(\S\4S/jr*\R*4S \S-\(\S\S\4S0jjr+S \S\4S1jr,S \S\4S2jr-S \S\4S3jr.S \S\4S4jr/S \S\4S5jr0S \S\4S6jr1S \S\S\4S7jr2S \S\S\4S8jr3S \S\S9\S\4S:jr4S \S\S\4S;jr5\R$4S \S\S\4S<jjr6SFS \S\S\S\4S>jjr7S=\R*4S \S\S\S\4S?jjr8S@r9U=r:$)GThreadedWebsocketManageriapi_key api_secretrequests_paramsr2r:session_paramsr[loopr.c L>[T U]UUUUUUUU5 SUlXlgrD)superr@_bsmr<) r>r9r:r;r2r:r<r[r=r. __class__s r%r@!ThreadedWebsocketManager.__init__s9          59 -r$cx# UR(de[URURS9Ulg7f)N)r-r.)r8r'r<r@rs r%_before_socket_listener_start6ThreadedWebsocketManager._before_socket_listener_starts-|||(<<//  s8:callbackrparamsrKrOc[R"5nUR(dP[R"5U- S:a [S5e[R"S5 UR(dMP[ URU5"S0UD6nU=(d UR nSUR U'URR[RURXgU55 U$)Nz;Binance Socket Manager failed to initialize after 5 secondsg?Tr) timer@ RuntimeErrorsleepr\_path_socket_runningr7call_soon_threadsafeasyncio create_taskstart_listener)r>rFrrGrK start_timesocket socket_paths r%_start_async_socket,ThreadedWebsocketManager._start_async_socketsYY[ ))yy{Z'!+"#`aa JJsO)))K0:6:/6<< ,0[) ''   !4!4V(!S r$rvrwrxc,URUSUUUS.S9$)Nr)rvrwrxrFrrGrV)r>rFrvrwrxs r%start_depth_socket+ThreadedWebsocketManager.start_depth_sockets0''& $(  r$c*URUSUUS.S9$)NrrvrxrYrZr>rFrvrxs r%start_kline_socket+ThreadedWebsocketManager.start_kline_sockets- ''& $(  r$rgrc .URUSUUUUS.S9$)Nr)rvrxrgrrYrZ)r>rFrvrxrgrs r%start_kline_futures_socket3ThreadedWebsocketManager.start_kline_futures_socket s3''. $ ,!. (  r$rc(URUSSU0S9$)NrrrYrZ)r>rFrs r%start_miniticker_socket0ThreadedWebsocketManager.start_miniticker_socket3s,''+{(  r$c(URUSSU0S9$)NrrvrYrZr>rFrvs r%start_trade_socket+ThreadedWebsocketManager.start_trade_socket>s*''&&(  r$c(URUSSU0S9$)NrrvrYrZris r%start_aggtrade_socket.ThreadedWebsocketManager.start_aggtrade_socketGs*'')&(  r$c*URUSUUS.S9$)NrrvrgrYrZr>rFrvrgs r%start_aggtrade_futures_socket6ThreadedWebsocketManager.start_aggtrade_futures_socketPs- ''1 ,(  r$c(URUSSU0S9$)NrrvrYrZris r%start_symbol_miniticker_socket7ThreadedWebsocketManager.start_symbol_miniticker_socket_s*''2&(  r$c(URUSSU0S9$)NrrvrYrZris r%start_symbol_ticker_socket3ThreadedWebsocketManager.start_symbol_ticker_sockeths*''.&(  r$c$URUS0S9$)NrrYrZr>rFs r%start_ticker_socket,ThreadedWebsocketManager.start_ticker_socketq!''?2(  r$Trc(URUSX#S.S9$)Nr)rvrrYrZ)r>rFrvrs r%start_index_price_socket1ThreadedWebsocketManager.start_index_price_socketvs('',$3(  r$c*URUSX#US.S9$)Nr)rvrrgrYrZ)r>rFrvrrgs r%start_symbol_mark_price_socket7ThreadedWebsocketManager.start_symbol_mark_price_sockets*''2$LQ(  r$c(URUSX#S.S9$)Nr)rrgrYrZ)r>rFrrgs r%start_all_mark_price_socket4ThreadedWebsocketManager.start_all_mark_price_sockets( ''/ ?(  r$c(URUSX#S.S9$)NrrprYrZrqs r%"start_symbol_ticker_futures_socket;ThreadedWebsocketManager.start_symbol_ticker_futures_sockets( ''6$C(  r$c(URUSX#S.S9$)NrrprYrZrqs r%-start_individual_symbol_ticker_futures_socketFThreadedWebsocketManager.start_individual_symbol_ticker_futures_sockets( ''A$C(  r$c(URUSSU0S9$)NrrgrYrZ)r>rFrgs r%start_all_ticker_futures_socket8ThreadedWebsocketManager.start_all_ticker_futures_sockets*''3"L1(  r$c(URUSSU0S9$)NrrvrYrZris r%start_symbol_book_ticker_socket8ThreadedWebsocketManager.start_symbol_book_ticker_sockets(''3f%(  r$c$URUS0S9$)NrrYrZr{s r%start_book_ticker_socket1ThreadedWebsocketManager.start_book_ticker_sockets"''+?(  r$rc(URUSSU0S9$)NrrrYrZr>rFrs r%start_multiplex_socket/ThreadedWebsocketManager.start_multiplex_sockets(''*w'(  r$c(URUSSU0S9$)NrrrYrZrs r%start_options_multiplex_socket7ThreadedWebsocketManager.start_options_multiplex_sockets*''2w'(  r$c(URUSX#S.S9$)Nr)rrgrYrZ)r>rFrrgs r%start_futures_multiplex_socket7ThreadedWebsocketManager.start_futures_multiplex_sockets( ''2&E(  r$c$URUS0S9$)NrrYrZr{s r%start_user_socket*ThreadedWebsocketManager.start_user_sockets!''=(  r$c$URUS0S9$)NrrYrZr{s r%start_futures_user_socket2ThreadedWebsocketManager.start_futures_user_socket"''+@(  r$c$URUS0S9$)NrrYrZr{s r%start_coin_futures_user_socket7ThreadedWebsocketManager.start_coin_futures_user_sockets"''+Eb(  r$c$URUS0S9$)NrrYrZr{s r%start_margin_socket,ThreadedWebsocketManager.start_margin_socketr~r$c$URUS0S9$)NrrYrZr{s r%start_futures_socket-ThreadedWebsocketManager.start_futures_sockets"''+;B(  r$c$URUS0S9$)NrrYrZr{s r%start_coin_futures_socket2ThreadedWebsocketManager.start_coin_futures_socketrr$c(URUSSU0S9$)NrrvrYrZris r%start_isolated_margin_socket5ThreadedWebsocketManager.start_isolated_margin_sockets(''0f%(  r$c(URUSSU0S9$)NrrvrYrZris r%start_options_ticker_socket4ThreadedWebsocketManager.start_options_ticker_sockets(''/f%(  r$r c(URUSX#S.S9$)Nr )rvr rYrZ)r>rFrvr s r%)start_options_ticker_by_expiration_socketBThreadedWebsocketManager.start_options_ticker_by_expiration_socket s(''=$I(  r$c(URUSSU0S9$)NrrvrYrZris r%"start_options_recent_trades_socket;ThreadedWebsocketManager.start_options_recent_trades_sockets*''6f%(  r$c(URUSX#S.S9$)Nrr^rYrZr_s r%start_options_kline_socket3ThreadedWebsocketManager.start_options_kline_sockets( ''.$;(  r$r*c(URUSX#S.S9$)Nr)rvrwrYrZ)r>rFrvrws r%start_options_depth_socket3ThreadedWebsocketManager.start_options_depth_socket+s(''.$5(  r$c*URUSX#US.S9$)Nr)rvrwrgrYrZ)r>rFrvrwrgs r%start_futures_depth_socket3ThreadedWebsocketManager.start_futures_depth_socket4s*''.$lS(  r$)r@r<) NNNcomFNNNr,rDr,r-r.r/);rrrrrrrrr4rPAbstractEventLoopr3r@rDrrVr[r r5r`rrirr6rcrfrjrmrrrurxr|rrrrrrrrrrrrrrrrrrrrrrrrrr# __classcell__)rAs@r%r8r8s"&$(4837%)48!.#.SM."$sCx.1 .  .  .!c3h0.c].w001...2 # S#X  sm  0 $"&    }  3-   *33       &33$/$5$5&2&<&<    "  $    (6:     /2     8 S S  h   %0$5$5      "    x  QT  8 S S  H  =A   *- 59  $/$5$5        "   $/$5$5      "   %0$5$5      "   %0$5$5      "   ?J>O>O   0;    # RU   c  x $s) PS    +/9  %0$5$5    c  "    ( s  ( s  x C  H   X #  ( s  X s s  H c c    *- @C     *-  33       =A   *- 69   &&          r$r8)rPrJenumrtypingrrrrrbinance.ws.constantsr binance.ws.keepalive_websocketr !binance.ws.reconnecting_websocketr binance.ws.threaded_streamr binance.async_clientr binance.enumsrrbinance.helpersrrrr'r8rr$r%rsX 662=C9-%&$Tn"n"b%t 1t r$