(self)
| 107 | self.new_results = [] # 保存过滤后的结果 |
| 108 | |
| 109 | def init_md5_list(self): |
| 110 | query = {"github_scheduler_id": self.scheduler_id} |
| 111 | results = list(utils.conn_db("github_hash").find(query, {"hash_md5": 1})) |
| 112 | for result in results: |
| 113 | if result["hash_md5"] not in self.hash_md5_list: |
| 114 | self.hash_md5_list.append(result["hash_md5"]) |
| 115 | |
| 116 | def save_mongo(self): |
| 117 | cnt = 0 |