18 lines
378 B
Python
18 lines
378 B
Python
import polars as pl
|
|
|
|
df = pl.read_parquet('data/warehouse/transactions.parquet')
|
|
print("Data loaded from Parquet file:")
|
|
print(df)
|
|
|
|
relevant_data = df.sql('''
|
|
SELECT
|
|
transaction_date,
|
|
sum(transaction_amount) as total
|
|
FROM self
|
|
GROUP BY transaction_date
|
|
ORDER BY transaction_date DESC
|
|
'''
|
|
)
|
|
print("Data after SQL query:")
|
|
print(relevant_data)
|