Pipeline.py class MongoDBPiphppeline: def __init__(self,conn,database): self.conn = conn self.database = database