Normalize messy JSONL into dict-only, deduplicated, BigQuery-friendly JSONL with discard logs.
Project description
jsonl-normalizer
A fast, fault-tolerant tool that normalizes messy JSONL files into clean, dict-only, BigQuery-friendly JSONL. Supports discard logging, SHA-256 deduplication, and mixed-type top-level lines (dicts, lists, strings, numbers).
🚀 Features
-
Normalize any JSONL file
- Accepts dicts, lists, numbers, strings, malformed lines
- Extracts dicts from lists
- Logs non-dict elements instead of failing
-
BigQuery-friendly output
Ensures one JSON object per line. -
Robust error handling
- Malformed JSON → logged
- Non-dict top-level values → logged
- Mixed lists → dicts kept, junk discarded
-
Optional SHA-256 deduplication
Canonical JSON hashing removes duplicate objects across large files. -
Zero dependencies
Pure standard library. Fast and lightweight.
📦 Installation
pip install jsonl-normalizer
Development install:
pip install -e .
🖥️ CLI Usage
Normalize a JSONL file:
jsonl-normalize input.jsonl
Produces:
normalized.jsonl # clean dict-only output
discarded.jsonl # log of malformed or discarded items
Enable deduplication:
jsonl-normalize input.jsonl --dedupe
Specify custom output:
jsonl-normalize input.jsonl --output clean.jsonl --discarded junk.jsonl
📄 Example
Input (mixed.jsonl)
{"a": 1, "b": 2}
[{"a": 2}, [7]]
"just a string"
Output: normalized.jsonl
{"a": 1, "b": 2}
{"a": 2}
Output: discarded.jsonl
{"line": 2, "index": 1, "type": "list", "value": [7], "reason": "non-dict element in list"}
{"line": 3, "type": "str", "value": "just a string", "reason": "top-level value is not dict or list"}
🧪 Library Usage
from pathlib import Path
from jsonl_normalizer import normalize_jsonl
stats = normalize_jsonl(
input_path=Path("input.jsonl"),
output_path=Path("normalized.jsonl"),
discarded_path=Path("discarded.jsonl"),
dedupe=True,
)
print(stats)
❓ Why jsonl-normalizer?
Real-world JSONL is messy:
- LLMs sometimes output arrays or malformed JSON
- Excel corrupts JSON strings
- Some APIs return non-dict top-level structures
- Data lakes accumulate junk
- BigQuery requires strict dict-per-line JSONL
- ETL pipelines often fail on partial corruption
jsonl-normalizer fixes these problems by:
- Normalizing structure
- Logging all junk transparently
- Keeping valid dicts only
- Providing dedupe mode
- Producing reliable, warehouse-ready JSONL
🧹 Deduplication
When --dedupe is enabled:
- Each object is canonicalized (sorted keys, compact JSON)
- Hashed using SHA-256
- Duplicates are skipped automatically
Example output:
Normalized records seen: 200
Unique records written: 173
Duplicates skipped: 27
Discarded items logged: 12 → discarded.jsonl
🧪 Testing
pip install -e .
pip install pytest
pytest
🤝 Contributing
Pull requests are welcome. Please ensure:
- Tests pass
- Code follows PEP 8
- Changes remain backward compatible
📄 License
MIT License. See LICENSE for details.
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file jsonl_normalizer-0.1.1.tar.gz.
File metadata
- Download URL: jsonl_normalizer-0.1.1.tar.gz
- Upload date:
- Size: 8.0 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/6.2.0 CPython/3.13.9
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
ab06f388891ea7be930a9dfc94454ea1f097244952731fefef6486cba1839ca7
|
|
| MD5 |
a3c0532d7583b4a1dee3cd0d0d84ad3b
|
|
| BLAKE2b-256 |
3db576fafa630bff392ffe7362066b8e59b4dad9469e4683391d60e904abdccc
|
File details
Details for the file jsonl_normalizer-0.1.1-py3-none-any.whl.
File metadata
- Download URL: jsonl_normalizer-0.1.1-py3-none-any.whl
- Upload date:
- Size: 7.9 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/6.2.0 CPython/3.13.9
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
7433361e1a789e68027734f72f227367546d0ad1468479d6d3976a6b826b7e50
|
|
| MD5 |
50671432622abab220d221ccabc3d174
|
|
| BLAKE2b-256 |
f880a7189e2288f6c02d3935baed342b9a38ae037869eb32fb264ac5ca46a3f1
|