INNER CODE UNIT · Python

__on_message

nkaz001/sample-trading-bot · tradingbot/binancefutures.py:37

    async def __on_message(self, message):
        message = json.loads(message)
        logging.debug(message)
        data = message['data']
        evt = data['e']
        if evt == 'listenKeyExpired':
            logging.warning('Listen key is expired.')
            await self.ws.close()
        elif evt == 'ACCOUNT_UPDATE':
            account = data['a']
            positions = account['P']
            for position in positions:
                position_side = position['ps']
                if 'BOTH' == position_side:
                    if position['s'].upper() == self.symbol.upper():
                        self.running_qty = position['pa']
        elif evt == 'ORDER_TRADE_UPDATE':
            # timestamp = data['E']

View source record →