How to access isolated margin user data stream?

[CryptoFuturesAU]

Hi Oliver,

I can successfully connect to user data stream and margin user data stream using :
"example_userdata_stream.py" modifying the exchange to binance.com-margin to access cross margin data

which parts of the "example_userdata_stream.py" code do I modify to access isolated margin user data through the websocket stream?

Thank you

[oliver-zehentleitner]

There are 3 Userdata streams in the example for 3 different endpoints. com, je and us i think. it should be obvious to you if you read the names of the vars!

You can try to comment full lines with # to disable the code row and test if its still working.

[CryptoFuturesAU]

I'm sorry its not obvious to me of how to set this up, i'm new python and coding in general. PLEASE can you add an example of a isolated margin account line in the "example_userdata_stream.py". I'm sure i'm not alone and that more people would appreciate your guidance.

[oliver-zehentleitner]

Its not tested, hope it works!

from unicorn_binance_websocket_api.unicorn_binance_websocket_api_manager import BinanceWebSocketApiManager
import logging
import time
import threading
import os


# https://docs.python.org/3/library/logging.html#logging-levels
logging.basicConfig(level=logging.INFO,
                    filename=os.path.basename(__file__) + '.log',
                    format="{asctime} [{levelname:8}] {process} {thread} {module}: {message}",
                    style="{")

def print_stream_data_from_stream_buffer(binance_websocket_api_manager):
    while True:
        if binance_websocket_api_manager.is_manager_stopping():
            exit(0)
        oldest_stream_data_from_stream_buffer = binance_websocket_api_manager.pop_stream_data_from_stream_buffer()
        if oldest_stream_data_from_stream_buffer is False:
            time.sleep(0.01)
        else:
            print(oldest_stream_data_from_stream_buffer)

binance_api_key = ""
binance_api_secret = ""

# create instances of BinanceWebSocketApiManager
binance_websocket_api_manager = BinanceWebSocketApiManager(exchange="binance.com-margin", throw_exception_if_unrepairable=True)

# set api key and secret in api manager
binance_websocket_api_manager.set_private_api_config(binance_api_key, binance_api_secret)

# create the userData streams
user_data_stream_id = binance_websocket_api_manager.create_stream('arr', '!userData')

# start a worker process to move the received stream_data from the stream_buffer to a print function
worker_thread = threading.Thread(target=print_stream_data_from_stream_buffer, args=(binance_websocket_api_manager,))
worker_thread.start()

# monitor the streams
while True:
    binance_websocket_api_manager.print_stream_info(user_data_stream_id)
    time.sleep(1)

Good luck!

[CryptoFuturesAU]

I dont understand, is this supposed to work for ISOLATED margin accounts? I can only receive data from my CROSS margin account using this code. Nowhere is it obvious where to input the symbol pair for ISOLATED margin account needed.

[oliver-zehentleitner]

uh, ok, i did not understand your request.

isolated margin is new for me, did not know that.

https://binance-docs.github.io/apidocs/spot/en/#user-data-streams

New endpoints for listenKey management of isolated margin account:
    POST /sapi/v1/userDataStream/isolated
    PUT /sapi/v1/userDataStream/isolated
    DELETE /sapi/v1/userDataStream/isolated

The lib just offers spot and margin support. we have to update the code to add isolated support.

[oliver-zehentleitner]

Here is a pre release with support for isolated_margin:
https://github.com/oliver-zehentleitner/unicorn-binance-websocket-api/releases/tag/1.17.0

I am not able to test it! Would you test it and give me feedback?

You can install it with this command:
pip install https://github.com/oliver-zehentleitner/unicorn-binance-websocket-api/archive/1.17.0.tar.gz --upgrade

Use it with:
BinanceWebSocketApiManager(exchange="binance.com-isolated_margin")

[CryptoFuturesAU]

installed update 1.17.0:

with code

from unicorn_binance_websocket_api.unicorn_binance_websocket_api_manager import BinanceWebSocketApiManager
import logging
import time
import threading
import os
import keys


# https://docs.python.org/3/library/logging.html#logging-levels
logging.basicConfig(level=logging.INFO,
                    filename=os.path.basename(__file__) + '.log',
                    format="{asctime} [{levelname:8}] {process} {thread} {module}: {message}",
                    style="{")

def print_stream_data_from_stream_buffer(binance_websocket_api_manager):
    while True:
        if binance_websocket_api_manager.is_manager_stopping():
            exit(0)
        oldest_stream_data_from_stream_buffer = binance_websocket_api_manager.pop_stream_data_from_stream_buffer()
        if oldest_stream_data_from_stream_buffer is False:
            time.sleep(0.01)
        else:
            print(oldest_stream_data_from_stream_buffer)

binance_api_key = keys.api_key
binance_api_secret = keys.api_secret

# create instances of BinanceWebSocketApiManager
binance_websocket_api_manager = BinanceWebSocketApiManager(exchange="binance.com-isolated_margin", throw_exception_if_unrepairable=True)

# set api key and secret in api manager
binance_websocket_api_manager.set_private_api_config(keys.api_key, keys.api_secret)

# create the userData streams
user_data_stream_id = binance_websocket_api_manager.create_stream('arr', 'trxbtc')

# start a worker process to move the received stream_data from the stream_buffer to a print function
worker_thread = threading.Thread(target=print_stream_data_from_stream_buffer, args=(binance_websocket_api_manager,))
worker_thread.start()

i get error:

Exception in thread Thread-52:
Traceback (most recent call last):
  File "C:\ProgramData\Anaconda3\lib\threading.py", line 932, in _bootstrap_inner
    self.run()
  File "C:\ProgramData\Anaconda3\lib\threading.py", line 870, in run
    self._target(*self._args, **self._kwargs)
  File "C:\Users\asus\Documents\Personal\Corporate\Python\red_robin_isolatedmargin\websocket test.py", line 21, in print_stream_data_from_stream_buffer
    time.sleep(0.01)
NameError: name 'time' is not defined
Release unicorn-binance-websocket-api_1.16.9 is available, please consider updating! (Changelog: https://github.com/oliver-zehentleitner/unicorn-binance-websocket-api/blob/master/CHANGELOG.md)

[oliver-zehentleitner]

  File "C:\Users\asus\Documents\Personal\Corporate\Python\red_robin_isolatedmargin\websocket test.py", line 21, in print_stream_data_from_stream_buffer
    time.sleep(0.01)
NameError: name 'time' is not defined

This error is in your test.py not in the lib!

Its in line 21: time.sleep(0.01)

Even if you wrote it in the code you posted here, i guess you forgot the import time part?!

[CryptoFuturesAU]

I got the stream running using that same code a second time (not sure why) but the stream doesnt receive any updates of userdata.
In the api doc https://binance-docs.github.io/apidocs/spot/en/#listen-key-isolated-margin it states that symbol sent is mandatory. Where do i input the symbol in the code?
When i try this the websocket receives no data:

user_data_stream_id = binance_websocket_api_manager.create_stream('arr', '!userData')

When i try this the websocket receives no data either:

user_data_stream_id = binance_websocket_api_manager.create_stream('arr', 'trxbtc')

[oliver-zehentleitner]

Well, adding a symbol is different to all other userDataStreams. I dont know, how binance want the extra parameter, i will ask them in telegram.

[oliver-zehentleitner]

The answer:
You need to pass symbol when you create listenKey. Then you can use the key in the same manner as you do for other user stream

Thats different to the other userDataStreams, so it needs further code modifications...