From 54bbc3ff573a77ef91112f35b0b5be5967d82509 Mon Sep 17 00:00:00 2001 From: midoks Date: Mon, 7 Aug 2023 22:39:24 +0800 Subject: [PATCH] Update index.py --- plugins/mariadb/index.py | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/plugins/mariadb/index.py b/plugins/mariadb/index.py index c803e3272..8627a91c1 100755 --- a/plugins/mariadb/index.py +++ b/plugins/mariadb/index.py @@ -2543,14 +2543,21 @@ def doFullSyncUser(version=''): def doFullSyncSSH(version=''): args = getArgs() - data = checkArgs(args, ['db']) + data = checkArgs(args, ['db', 'sign']) if not data[0]: return data[1] db = pMysqlDb() + sync_db = args['db'] + sync_sign = args['sign'] + id_rsa_conn = pSqliteDb('slave_id_rsa') - data = id_rsa_conn.field('ip,port,db_user,id_rsa').find() + if sync_sign != '': + data = id_rsa_conn.field('ip,port,db_user,id_rsa').where( + 'ip=?', (sync_sign,)).find() + else: + data = id_rsa_conn.field('ip,port,db_user,id_rsa').find() SSH_PRIVATE_KEY = "/tmp/mysql_sync_id_rsa.txt" id_rsa = data['id_rsa'].replace('\\n', '\n') @@ -2573,7 +2580,6 @@ def doFullSyncSSH(version=''): return 'fail' try: - # ssh.load_system_host_keys() mw.execShell("chmod 600 " + SSH_PRIVATE_KEY) key = paramiko.RSAKey.from_private_key_file(SSH_PRIVATE_KEY) ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())