写一段代码监控hdfs namenode主从状态是否切换

以下是一个简单的 Python 脚本，可以监控 HDFS 的 NameNode 主从状态是否切换：

import subprocess
import time

while True:
    try:
        status_output = subprocess.check_output("hdfs haadmin -getServiceState nn1", shell=True)
        status = status_output.decode().strip()
        if status == "active":
            print("NameNode 1 is active")
        elif status == "standby":
            print("NameNode 1 is standby")
            switch_output = subprocess.check_output("hdfs haadmin -failover nn1 nn2", shell=True)
            print(switch_output.decode().strip())
    except subprocess.CalledProcessError as e:
        print(e.output.decode().strip())
    time.sleep(10)

该脚本会每隔 10 秒检查一次 NameNode 1 的状态。如果状态为 "standby"，则会自动执行故障切换操作，将主节点切换到 NameNode 2 上。请注意，您需要根据您的环境修改命令和参数，以使其适用于您的环境。