merge_into_uncleaned_parquet
Documentation for eth_defi.hyperliquid.vault_data_export.merge_into_uncleaned_parquet function.
- merge_into_uncleaned_parquet(db, parquet_path)
Merge Hyperliquid daily prices into the uncleaned Parquet file.
Writes Hypercore raw data in the same format as the EVM vault scanner, so the standard cleaning pipeline (
process_raw_vault_scan_data()) can process all vaults together.Reads the existing Parquet, removes any prior Hypercore rows (chain == 9999), appends fresh Hyperliquid daily price rows, and writes back. Idempotent: running twice produces the same result.
If the Parquet file does not exist, creates a new one.
- Parameters
db (eth_defi.hyperliquid.daily_metrics.HyperliquidDailyMetricsDatabase) – The Hyperliquid daily metrics database.
parquet_path (pathlib.Path) – Path to the uncleaned Parquet file (typically
vault-prices-1h.parquet).
- Returns
The combined DataFrame.
- Return type