From add93aadd87a53dc960b1e0d2fdb6ed4cb4e2d30 Mon Sep 17 00:00:00 2001 From: lixin Date: Fri, 10 Nov 2023 10:58:42 +0800 Subject: [PATCH] =?UTF-8?q?agent=E4=BB=BB=E5=8A=A1=E4=B8=8B=E5=8F=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- views/migration.py | 28 ++++++++++++++++++++++++++++ 1 file changed, 28 insertions(+) diff --git a/views/migration.py b/views/migration.py index 7b2f4ed..985a1bf 100644 --- a/views/migration.py +++ b/views/migration.py @@ -8,6 +8,32 @@ from logger import * from flask import * from client_requests import * from sysmig_agent.utils import * +from interaction import splice_url + + +migration_log = Logger('/var/tmp/uos-migration/migration.log', logging.DEBUG, logging.DEBUG) + +def send_task_to_agent(data, url, ip): + """ + 向agent下发任务 + :param data: + :param url: + :param ip: + :return: + """ + log_info = "post " + url + ":" + str(data) + migration_log.info(log_info) + info = splice_url(data, url, ip) + if info.status_code == 200: + migration_log.info(info.text) + elif info is None or info.status_code == 404: + sql = "update agent_info set agent_online_status=1 where agent_ip ='%s';" % ip + DBHelper().execute(sql) + migration_log.error("%s:请求失败,agent端没有启动" % ip) + elif info.status_code != 404 and info.status_code != 200: + sql = "update agent_info set agent_online_status=1 where agent_ip ='%s';" % ip + DBHelper().execute(sql) + migration_log.error("%s:请求失败，错误状态码为%s" % (ip, info.status_code)) def get_agent_ip(data, sql, url): @@ -35,6 +61,8 @@ def check_info(data): :param data: :return: """ + sql = "select agent_ip from agent_info where agent_online_status = 0;" + get_agent_ip(data, sql, '/check_info') return 'success' -- 2.20.1