mixle.data.sources.mongo_source module

MongoDB connector – a collection query into a DataSource.

Optional: requires pymongo (pip install mixle[mongo]). The _id field is dropped; supply a Schema to coerce the loosely-typed BSON documents.

read_mongo(uri, database, collection, query=None, columns=None, *, structure=EXCHANGEABLE, schema=None)[source]

Read documents matching query from database.collection at uri into a lazy DataSource.

Parameters:

  • uri (str)

  • database (str)

  • collection (str)

  • query (dict | None)

  • columns (list[str] | None)

  • structure (SampleStructure)

  • schema (Schema | None)

Return type:

LazySource