# 导入QMT对接核心库from xtquant import xtdataimport time# 初始化QMT客户端def qmt_client_init(): try: xtdata.download_sector_data() print("QMT客户端初始化成功") except Exception as e: print(f"初始化失败:{str(e)}") exit()# 行情回调函数(Level2行情更新时自动触发)def quote_callback(data): current_code = data["stock_code"] print(f"当前标的:{current_code},Level2行情更新") # 调取Level2逐笔成交数据 l2_data = xtdata.get_market_data_ex(stock_code=current_code, period="1m", level=2) print("Level2逐笔成交数据:") print(l2_data)# 启动Level2行情订阅def start_l2_subscribe(): qmt_client_init() try: # 订阅Level2行情(level=2指定为Level2,可替换为自己要订阅的标的) xtdata.subscribe_quote(stock_code="600519.SH", period="1m", callback=quote_callback, level=2) print("Level2行情订阅成功,等待数据推送(按Ctrl+C停止)...") while True: time.sleep(1) except KeyboardInterrupt: print("\n用户终止程序") finally: # 取消订阅,释放资源 xtdata.unsubscribe_quote(stock_code="600519.SH", period="1m", level=2) print("已取消Level2行情订阅")if __name__ == "__main__": start_l2_subscribe()