def reducer_init_output(self):
        """ establish connection to MongoDB """
        try:
            self.mongo = MongoGeo(db=DB, collection=COLLECTION, timeout=MONGO_TIMEOUT)
        except ServerSelectionTimeoutError:
            # failed to connect to running MongoDB instance
            self.mongo = None