user_data_stream bug？ why cant catch the UserDataStreamEventsResponse model，actual_instance is None？

[algoqt]

    def on_user_data_stream_um(self,data):

        print(f"data type: {type(data)},{data}")


   async def subscribe_user_data_stream_um(self):
        connection = await self.get_um_connection()
        try:
            resp = await connection.start_user_data_stream()
            listen_key = resp.data().result.listen_key
            if not listen_key:
                raise ValueError("无法获取 listenKey: " + str(resp))
            print("listenKey:", listen_key)
            
            ws = self.um_client.websocket_streams
            connection = await ws.create_connection()
            stream = await ws.user_data(listen_key)

            stream.on("message", lambda data: self.on_user_data_stream_um(data))
            
            await asyncio.sleep(1000)
            
            await stream.unsubscribe()

        except Exception as e:
            logging.error(f"subscribe_user_data_stream_um() error: {e}")

the code above when create or cancel order , it dones catch the UserDataStreamEventsResponse model，actual_instance still None

this is the output:

data type: <class 'binance_sdk_derivatives_trading_usds_futures.websocket_streams.models.user_data_stream_events_response.UserDataStreamEventsResponse'>,oneof_schema_1_validator=None oneof_schema_2_validator=None oneof_schema_3_validator=None oneof_schema_4_validator=None oneof_schema_5_validator=None oneof_schema_6_validator=None oneof_schema_7_validator=None oneof_schema_8_validator=None oneof_schema_9_validator=None actual_instance=None one_of_schemas={'AccountUpdate', 'AccountConfigUpdate', 'GridUpdate', 'ConditionalOrderTriggerReject', 'OrderTradeUpdate', 'Listenkeyexpired', 'MarginCall', 'TradeLite', 'StrategyUpdate'} discriminator_value_class_map={}

[alplabin]

Hi @algoqt, which version of binance_sdk_derivatives_trading_usds_futures are you using?

[algoqt]

Hi @algoqt, which version of binance_sdk_derivatives_trading_usds_futures are you using?

i use python 3.10 and

binance-common 3.0.0
binance-sdk-derivatives-trading-usds-futures 1.4.0
binance-sdk-spot 2.1.0

[algoqt]

        um_configuration_ws_api = ConfigurationWebSocketAPI(
            api_key=api_key,
            api_secret=api_secret,
            stream_url=DERIVATIVES_TRADING_USDS_FUTURES_WS_API_PROD_URL,
        )
        um_configuration_ws_stream = ConfigurationWebSocketStreams(
            stream_url=DERIVATIVES_TRADING_USDS_FUTURES_WS_STREAMS_PROD_URL,
        )

        self.um_client = DerivativesTradingUsdsFutures(config_ws_api=um_configuration_ws_api
,config_ws_streams=um_configuration_ws_stream)

here is how i create the um_client .

or is there a example I can use for. in https://github.com/binance/binance-connector-python/tree/master/clients/derivatives_trading_usds_futures/examples/websocket_api/UserDataStreams , if there is a example then will be better。

use the noraml way ,works fine, so should be the sdk problem

            WS_URL = "wss://fstream.binance.com/ws"
            ws_url = f"{WS_URL}/{listen_key}"
            async for ws in websockets.connect(ws_url):
                try:
                    async for msg in ws:
                        data = json.loads(msg)
                        event_type = data.get("e")
                        if event_type == "ORDER_TRADE_UPDATE":
                            print("ORDER_TRADE_UPDATE:", json.dumps(data, indent=2))
                        elif event_type == "ACCOUNT_UPDATE":
                            print("ACCOUNT_UPDATE:", json.dumps(data, indent=2))
                        else:
                            print("other event:", data)
                except websockets.ConnectionClosed as e:
                    print(f"Connection closed: {e}")
                    break

[alplabin]

@algoqt Have you tried with the latest version of binance_sdk_derivatives_trading_usds_futures (v1.6.0)?

[algoqt]

@algoqt Have you tried with the latest version of binance_sdk_derivatives_trading_usds_futures (v1.6.0)?

use v1.6.0 it has data receive, but its dict type, not UserDataStreamEventsResponse

result:

data type: <class 'dict'>,{'e': 'ORDER_TRADE_UPDATE', 'T': 1758093279728, 'E': 1758093279728, 'o': {'s': 'BTCUSDT', 'c': 'yedX6g6CoJtsMKzfXg17M1', 'S': 'SELL', 'o': 'LIMIT', 'f': 'GTC', 'q': '0.001', 'p': '119800', 'ap': '0', 'sp': '0', 'x': 'CANCELED', 'X': 'CANCELED', 'i': 772927379336, 'l': '0', 'z': '0', 'L': '0', 'n': '0', 'N': 'USDT', 'T': 1758093279728, 't': 0, 'b': '0', 'a': '0', 'm': False, 'R': True, 'wt': 'CONTRACT_PRICE', 'ot': 'LIMIT', 'ps': 'LONG', 'cp': False, 'rp': '0', 'pP': False, 'si': 0, 'ss': 0, 'V': 'EXPIRE_MAKER', 'pm': 'NONE', 'gtd': 0}}

i dont think the code bellow is correct for this situation

    if response_model.__pydantic_fields__.get("one_of_schemas"):
        parsed = payload

in

                     stream = data.get("stream")
                    subscription_id = data.get("subscriptionId")

                    key = stream or subscription_id
                    callbacks = connection.stream_callback_map.get(key) if key is not None else None

                    if callbacks:
                        try:
                            if stream:
                                response_model = connection.response_types.get(stream)
                                payload = data["data"] if response_model else data

                                for callback in callbacks:
                                    if response_model:
                                        if response_model.__pydantic_fields__.get("one_of_schemas"):
                                            parsed = payload
                                        elif isinstance(payload, list):
                                            parsed = [
                                                response_model.model_validate_json(json.dumps(item))
                                                for item in payload
                                            ]
                                        else:
                                            parsed = response_model.model_validate_json(json.dumps(payload))
                                        callback(parsed)
                                    else:
                                        callback(payload)
                            else:
                                response_model = connection.response_types.get(subscription_id)
                                payload = data["event"]

                                for callback in callbacks:
                                    if response_model:
                                        if isinstance(payload, list):
                                            parsed = [parse_user_event(item, response_model) for item in payload]
                                        else:
                                            parsed = parse_user_event(payload, response_model)
                                        callback(parsed)
                                    else:
                                        callback(payload)
                        except Exception as e:
                            raise ValueError(f"Error in callback for key {key}: {e}")

[algoqt]

i think i found the problem:
1 : for spot , the msg is {'subscriptionId': 0, 'event': .....} so go to the code :

                                response_model = connection.response_types.get(subscription_id)
                                payload = data["event"]

                                for callback in callbacks:
                                    if response_model:
                                        if isinstance(payload, list):
                                            parsed = [parse_user_event(item, response_model) for item in payload]
                                        else:
                                            parsed = parse_user_event(payload, response_model)
                                        callback(parsed)
                                    else:
                                        callback(payload)

2 but for futures, the msg is {"stream": “xxx”, "data":{....}} this will not go the parse_user_event part( the above code), so never a change to pick up UserDataStreamEventsResponse

3: an other problem , you use resolve_model_from_event() to parse enent in parse_user_event() function , but the event naming is

ORDER_TRADE_UPDATE ACCOUNT_UPDATE

there is _ in futures use stream data event , not so cool with the name without _ in UserDataStreamEventsResponse

one_of_schemas: Set[str] = {
    "AccountConfigUpdate",
    "AccountUpdate",
    "ConditionalOrderTriggerReject",
    "GridUpdate",
    "Listenkeyexpired",
    "MarginCall",
    "OrderTradeUpdate",
    "StrategyUpdate",
    "TradeLite",
}

hope this help