From f18132058ce6bb3cf97cf4cec4456cfea49e36e6 Mon Sep 17 00:00:00 2001 From: "Autumn.home" Date: Thu, 11 Jul 2024 19:16:53 +0800 Subject: [PATCH] =?UTF-8?q?fix=20=E6=89=AB=E6=8F=8F=E4=BB=BB=E5=8A=A1?= =?UTF-8?q?=E5=BF=BD=E7=95=A5=E8=8A=82=E7=82=B9=E6=97=B6=E9=97=B4=E5=B7=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- api/node.py | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/api/node.py b/api/node.py index 97ce083..df8dc53 100644 --- a/api/node.py +++ b/api/node.py @@ -138,17 +138,17 @@ async def get_redis_online_data(redis_con): name = key.split(":")[1] hash_data = await redis.hgetall(key) if hash_data.get('state') == '1': - update_time_str = hash_data.get('updateTime') - if update_time_str: - update_time = datetime.strptime(update_time_str, '%Y-%m-%d %H:%M:%S') - time_difference = ( - datetime.strptime(get_now_time(), "%Y-%m-%d %H:%M:%S") - update_time).total_seconds() - logger.info(f'节点时间差：{time_difference}, {get_now_time()}, {update_time}') - if time_difference > NODE_TIMEOUT: - await asyncio.create_task(update_redis_data(redis, key)) - hash_data['state'] = '3' - else: - result.append(name) + # update_time_str = hash_data.get('updateTime') + # if update_time_str: + # update_time = datetime.strptime(update_time_str, '%Y-%m-%d %H:%M:%S') + # time_difference = ( + # datetime.strptime(get_now_time(), "%Y-%m-%d %H:%M:%S") - update_time).total_seconds() + # logger.info(f'节点时间差：{time_difference}, {get_now_time()}, {update_time}') + # if time_difference > NODE_TIMEOUT: + # await asyncio.create_task(update_redis_data(redis, key)) + # hash_data['state'] = '3' + # else: + result.append(name) return result