Method read_mongo

sdk/python/feast/infra/ray_initializer.py:246–250

Read from a MongoDB collection.

(self, uri: str, database: str, collection: str, **kwargs)

        return ray.data.read_webdataset(path, **kwargs)

    def read_mongo(self, uri: str, database: str, collection: str, **kwargs) -> Any:
        """Read from a MongoDB collection."""
        return ray.data.read_mongo(
            uri=uri, database=database, collection=collection, **kwargs
        )

    def read_sql(self, sql: str, connection_url: str, **kwargs) -> Any:
        """Read from a SQL database.  Builds the connection factory from connection_url."""