# CSV to JSON conversion
python src/etl_pipeline.py --source data.csv --dest output.json

# JSON API to SQLite
python src/etl_pipeline.py --source https://api.example.com/v1/users --dest users.db --table users

# Full pipeline from config
python src/etl_pipeline.py --config examples/pipeline_config.json

# Nested JSON extraction
python src/etl_pipeline.py --source response.json --dest items.csv --records-path "data.items"

{
    "source": "https://api.example.com/v1/products",
    "destination": "products.db",
    "table": "products",
    "records_path": "data.results",
    "transforms": [
        {"type": "filter", "field": "status", "value": "active"},
        {"type": "rename", "mapping": {"product_name": "name", "product_id": "id"}},
        {"type": "map", "field": "price", "operation": "float"},
        {"type": "add_field", "field": "imported_at", "value": "$NOW"}
    ],
    "stats_file": "pipeline_stats.json"
}