t^jp dZddlZddlZddlmZddlmZedZedZdZdZ e d krDe d e d ee e e e d dSdS) zP Extract latest order book data from database and save as JSON for the 3D city. N)Path)datetimezT/home/ubuntu/.hermes/workspace/projects/ORDER_FLOW_GRAPH/data/binance_multi_asset.dbzE/home/ubuntu/.hermes/workspace/projects/ORDER_FLOW_GRAPH/outputs/datac  tjtd}t|_|}|d|f|}|std|dS|\}}|d|f| }| i}i}|D]!\} } } | d} | dkr| || <| d kr| || <"td |d t|d t|d |||||dS#t$r } td|d | Yd} ~ dSd} ~ wwxYw)z5Get the latest order book snapshot from the database.g@)timeoutz SELECT id, timestamp FROM order_book_snapshots WHERE symbol = ? ORDER BY id DESC LIMIT 1 u⚠️ No snapshot found for Nz SELECT price, volume, side FROM order_book_levels WHERE snapshot_id = ? ORDER BY price .2fbidasku✅ z: z bids, z asks)symbol timestampbidsasks snapshot_idu"❌ Error fetching order book for )sqlite3connectDATABASEstr text_factorycursorexecuteupperfetchoneprintfetchallcloselen Exception)r connrsnapshotrr levelsr r pricevolumeside price_keyes U/home/ubuntu/.hermes/workspace/projects/ORDER_FLOW_GRAPH/scripts/extract_orderbook.pyget_latest_order_bookr&s7x555  llnn     ??$$  ;6;; < < <4!) Y  ^    "" #) ) ) E64 Iu}}"(Y"(Y AVAAs4yyAATAAABBBllnn"&      @6@@Q@@AAAtttttsB E B8E E3E..E3c:gd}|D]}t|}|rvtd|dz }t|d5}t j||ddddn #1swxYwYt d|j|rB|d r:t|d  }t d |d |rB|d r:t|d  }t d |d dS)z0Extract and save order book data for all assets.)XAUTUSDTBTCUSDTETHUSDT orderbook_z.jsonw)indentNu💾 Saved to r z Total bid volume: rr z Total ask volume: ) r& OUTPUT_DIRloweropenjsondumprnamesumvalues)symbolsr data output_filef total_bid_vol total_ask_vols r%mainr=Is000G??$V,,  7$'IFLLNN'I'I'IIKk3'' -1 $!,,,, - - - - - - - - - - - - - - - 5;#355 6 6 6  ?DL ?V 3 3 5 566M =-=== > > >  ?DL ?V 3 3 5 566M =-=== > > >%??s A//A3 6A3 __main__u,📊 Extracting real-time order book data...u🗄️ Database: u,✅ Done! Order book data ready for 3D city.) __doc__rr2pathlibrrrr/r&r=__name__rr%rDs  4f g g TY Z Z 999v???0 z E 8999 E * * *+++ EGGGDFFF EGGG E 899999 rC