close_group_replication_bootstrap_group(conn_master_dict)
group_replication_status = get_group_replication_status(conn_master_dict)
if (group_replication_status[0]['MEMBER_STATE'] == 'ONLINE'):
print("master added in mgr and run successfully")
return True
except:
raise
print("############start master mgr error################")
exit(1)
def start_mgr_on_slave(conn_slave_dict,repl_user,repl_password):
try:
set_super_read_only_off(conn_slave_dict)
reset_master(conn_slave_dict)
connect_to_group(conn_slave_dict,repl_user,repl_password)
start_group_replication(conn_slave_dict)
# wait for 10
time.sleep(10)
# then check mgr status
group_replication_status = get_group_replication_status(conn_slave_dict)
if (group_replication_status[0]['MEMBER_STATE'] == 'ONLINE'):
print("slave added in mgr and run successfully")
if (group_replication_status[0]['MEMBER_STATE'] == 'RECOVERING'):
print("slave is recovering")
except:
print("############start slave mgr error################")
exit(1)
def auto_mgr(conn_master,conn_slave_1,conn_slave_2,repl_user,repl_password):
install_group_replication_plugin(conn_master)
master_replication_status = get_group_replication_status(conn_master)
if not (master_replication_status[0]['MEMBER_STATE'] == 'ONLINE'):
start_mgr_on_master(conn_master,repl_user,repl_password)
slave1_replication_status = get_group_replication_status(conn_slave_1)
if not (slave1_replication_status[0]['MEMBER_STATE'] == 'ONLINE'):
install_group_replication_plugin(conn_slave_1)
start_mgr_on_slave(conn_slave_1, repl_user, repl_user)
slave2_replication_status = get_group_replication_status(conn_slave_2)
if not (slave2_replication_status[0]['MEMBER_STATE'] == 'ONLINE'):
install_group_replication_plugin(conn_slave_2)
start_mgr_on_slave(conn_slave_2, repl_user, repl_user)
check_replication_group_members(conn_master)
if __name__ == '__main__':
conn_master = {'host': '127.0.0.1', 'port': 7001, 'user': 'root', 'password': 'root', 'db': 'mysql', 'charset': 'utf8mb4'}
conn_slave_1 = {'host': '127.0.0.1', 'port': 7002, 'user': 'root', 'password': 'root', 'db': 'mysql', 'charset': 'utf8mb4'}
conn_slave_2 = {'host': '127.0.0.1', 'port': 7003, 'user': 'root', 'password': 'root', 'db': 'mysql', 'charset': 'utf8mb4'}