Pipeline.pyclass MongoDBPiphppeline:def __init__(self,conn,database):self.conn = connself.database = database@classmeth