guard.py 文件源码

def __make_pots_thread(self):

        db_session = Session()

        while not self._exit_flag:
            if self.evil_task_queue.empty():
                time.sleep(5)
            evil_ip = self.evil_task_queue.get()
            logger.info("Get An Evil IP: {0}".format(evil_ip))

            for ip in evil_ip:

                # ????attacker ip???????????
                qs = db_session.query(KokkuriSSHPot).filter(KokkuriSSHPot.attacker_ip == ip).first()
                if qs:
                    continue

                container_name = "{0}_honeypot".format(ip.replace(".", "_"))
                container_id, ssh_port = self.docker_pot.create_container(container_name)

                qs = KokkuriSSHPot(
                    container_name=container_name, container_id=container_id,
                    pot_ip=server_config.HONEYPOT_IP, attacker_ip=ip, ssh_port=ssh_port, status=1
                )

                db_session.add(qs)
                db_session.commit()