Simple Python script that ingests and analyzes parquet files of Uniswap "Swap" events, from Parquet files, aggregates them by day, and plots a bar chart of the total daily amount of Swaps

analysis.py

import pandas as pd
from pathlib import Path
import matplotlib.pyplot as plt

df = pd.concat(map(lambda parquet_file: pd.read_parquet(parquet_file, engine="pyarrow"), Path(r'./').rglob('**/pool_event_Swap.parquet')), ignore_index=True)

df['datetime'] = pd.to_datetime(df['timestamp'])

sumDf = df.groupby(df.datetime.dt.date)["contractAddress"].count()

sumDf.plot(kind = 'bar',
        x = 0,
        y = 1,
        color = 'blue',
        title='Total Daily Swaps on Uniswap',
        )

# show the plot
plt.show()