from quant.utils import logger
from quant.const import BINANCE
from quant.asset import Asset, AssetSubscribe


# 资产信息回调函数，注意此处回调函数是 `async` 异步函数，回调参数为 `asset Asset` 对象，数据结构请查看下边的介绍。
async def on_event_asset_update(asset: Asset):
    logger.info("platform:", asset.platform)  # 打印资产数据的平台信息
    logger.info("account:", asset.account)  # 打印资产数据的账户信息
    logger.info("asset data dict:", asset.assets)  # 打印资产数据的资产详情
    logger.info("asset data str:", asset.data)  # 打印资产数据的资产详情
    logger.info("timestamp:", asset.timestamp)  # 打印资产数据更新时间戳
    logger.info("update:", asset.update)  # 打印资产数据是否有更新


# 订阅资产信息
account = "test@gmail.com"
AssetSubscribe(BINANCE, account, on_event_asset_update)

from quant.asset import Asset

Asset.platform  # 交易平台名称
Asset.account  # 交易账户
Asset.assets  # 资产详细信息
Asset.timestamp  # 资产更新时间戳(毫秒)
Asset.update  # 资产是否有更新
Asset.data  # 资产信息

{
    "BTC": {
        "free": "1.10000",
        "locked": "2.20000",
        "total": "3.30000"
    },
    "ETH": {
        "free": "1.10000",
        "locked": "2.20000",
        "total": "3.30000"
    }
}