cmoncrawl.middleware.synchronized

Functions

extract(records, pipeline[, concurrent_length])	Extracts the records using the pipeline, with at most concurrent_length records being processed at the same time.
query_and_extract(index_agg, pipeline[, ...])	Query the index and extracts the results using the pipeline