Module preprocessor.mongodb_utils

Functions

def chunk_mongo_results(connection: str, database: str, collection: str, query: str, projection: str, sort: Optional[List] = None, limit: Optional[int] = None, chunk_size: int = 1000)

def retrieve_mongo_results(connection: str, database: str, collection: str, query: str, projection: str, sort: Optional[List] = None, limit: Optional[int] = None)