Class InstaPorcessClass

insta_monitering/insta_datafetcher.py:267–360

class InstaPorcessClass:
    def _dbProcessReader(self, user, tags, productId):
        value = True
        mon = pymongo.MongoClient(host=config.host, port=config.mongoPort)
        try:
            db = mon["insta_process"]
            collection = db["process"]
            temp = {}
            temp["user"] = user
            temp["tags"] = tags
            temp["productId"] = productId
            records = collection.find(temp).count()
            if records == 0:
                raise Exception
            value = True
        except Exception as err:
            print(f"exception : {err}\n")
            value = False
            print("error::dbProcessReader:>>", sys.exc_info()[1])
        finally:
            mon.close()
            return value

    def _processstart(self, user, tags, productId):
        mon = pymongo.MongoClient(host=config.host, port=config.mongoPort)
        try:
            db = mon["insta_process"]
            collection = db["process"]
            temp = {}
            temp["user"] = user
            temp["tags"] = tags
            temp["productId"] = productId
            collection.insert(temp)
        except Exception as err:
            print(f"execption : {err}\n")
            print("error::processstart>>", sys.exc_info()[1])
        finally:
            mon.close()

    def startprocess(self, user, tags, type, productId):
        try:
            self._processstart(user=user, tags=tags, productId=productId)
            while True:
                # therad = theradPorcess(user=user, tags=tags, type=type)
                # therad.start()
                hashtags(user=user, tags=tags, type=type, productId=productId)
                check = self._dbProcessReader(user=user, tags=tags, productId=productId)
                print(check)
                if check == False:
                    break
                time.sleep(300)
                # therad.join()
        except Exception as err:
            print(f"exception : {err}\n")
            print("error::startPoress::>>", sys.exc_info()[1])

    def deletProcess(self, user, tags, productId):
        mon = pymongo.MongoClient(host=config.host, port=config.mongoPort)