JSONL vs Parquet: Wybor odpowiedniego formatu danych

import pyarrow.parquet as pq
import pandas as pd

# Zapisz DataFrame do Parquet
df = pd.DataFrame({
    'id': [1, 2, 3],
    'name': ['Alice', 'Bob', 'Charlie'],
    'role': ['engineer', 'designer', 'manager'],
    'salary': [95000, 88000, 105000]
})
df.to_parquet('employees.parquet')

# Odczytaj konkretne kolumny (zaleta kolumnowa)
df = pq.read_table('employees.parquet', columns=['name', 'salary']).to_pandas()

import json
import pandas as pd
import pyarrow as pa
import pyarrow.parquet as pq
from pathlib import Path
from datetime import datetime

def jsonl_to_parquet(jsonl_dir: str, parquet_dir: str):
    """Konwertuj zgromadzone pliki JSONL na partycjonowany Parquet."""
    records = []
    for jsonl_file in Path(jsonl_dir).glob('*.jsonl'):
        with open(jsonl_file, 'r') as f:
            for line in f:
                line = line.strip()
                if line:
                    records.append(json.loads(line))

    if not records:
        return

    df = pd.DataFrame(records)
    # Dodaj kolumne partycji
    df['date'] = datetime.now().strftime('%Y-%m-%d')

    table = pa.Table.from_pandas(df)
    pq.write_to_dataset(
        table,
        root_path=parquet_dir,
        partition_cols=['date'],
        compression='zstd'
    )
    print(f'Przekonwertowano {len(records)} rekordow do Parquet')

jsonl_to_parquet('raw_events/', 'data_lake/')