인메모리 OLAP SQL 엔진 DuckDB 기초와 파일 직접 질의

import duckdb

# 메모리 모드 연결
con = duckdb.connect()

# 와일드카드로 수십 개 Parquet 파일에 즉각적인 OLAP 집계 쿼리 실행
sql = """
    SELECT 
        strftime('%Y-%m', order_time) AS order_month,
        category,
        COUNT(DISTINCT customer_id) AS buyers,
        ROUND(SUM(price * quantity), 0) AS gmv,
        ROUND(AVG(price * quantity), 0) AS aov
    FROM read_parquet('lake/orders_202*.parquet')
    WHERE status = 'PAID'
    GROUP BY 1, 2
    ORDER BY 1 DESC, gmv DESC
    LIMIT 5;
"""

df_result = con.execute(sql).df()
print("🦆 [DuckDB Direct Query 결과]")
print(df_result)