diff options
Diffstat (limited to 'skate/cmd')
| -rw-r--r-- | skate/cmd/skate-map/main.go | 32 |
1 files changed, 31 insertions, 1 deletions
diff --git a/skate/cmd/skate-map/main.go b/skate/cmd/skate-map/main.go index 5b69993..259e1aa 100644 --- a/skate/cmd/skate-map/main.go +++ b/skate/cmd/skate-map/main.go @@ -1,5 +1,35 @@ // skate-map runs a given map function over input data. We mostly want to -// extract a key from a json document. +// extract a key from a json document. For simple cases, you can use `jq` and +// other tools. Some key derivations require a bit more. +// +// An example with mostly unix tools. We want to extract the DOI and sort by +// it; we also want to do this fast, hence parallel, LC_ALL, etc. +// +// $ zstdcat -T0 file.zst | (1) +// LC_ALL=C tr -d '\t' | (2) * +// parallel -j 16 --block 10M --pipe (3) * +// "jq -rc 'select(.biblio.doi != null) | (4) * +// [.biblio.doi, (.|tostring)] | @tsv'" | (5) * +// LC_ALL=C sed 's/\\\\/\\/g' | (6) * +// LC_ALL=C awk -F $'\t' -v OFS='\t' '$1=tolower($1)' | (7) * +// skate-to-doi -B -S -f 1 | (8) * +// LC_ALL=C sort -S 30% --parallel 6 -k1,1 | (9) +// zstd -c -T0 > skate.out +// +// (1) zstd is fast! "~4x faster than zlib" (https://is.gd/HT1DUs) +// (2) we use tab as column separator and we want clean this up before (could +// be skipped, if we limit number of splits) +// (3) we pass the data to jq, with a bit larger buffer (default is 1MB) +// (4) we want no "null" output +// (5) tostring prints input as string, because we need to carry the document forward +// (6) but we need some cleanup, too +// (7) we normalize the DOI to lowercase +// (8) a custom filter to normalize a DOI in a specific column +// (9) sorting by DOI +// +// This is reasonably fast, but some cleanup is ugly. We also want more complex +// keys, e.g. more normalizations, etc. We'd like to encapsulate (2) to (8). + package main import ( |