health.py 文件源码

def run(self):
        data = cluster_data.ClusterData.find_one(self.cluster.model_id)
        cluster_name = data.global_vars.get("cluster", self.cluster.name)
        cluster_name = shlex.quote(cluster_name)

        cluster_servers = {item._id: item for item in self.cluster.server_list}
        mons = [
            cluster_servers[item["server_id"]]
            for item in self.cluster.configuration.state
            if item["role"] == "mons"]
        if not mons:
            return

        version_result = await self.execute_cmd(
            "ceph --cluster {0} health --format json".format(cluster_name),
            random.choice(mons))

        self.manage_errors(
            "Cannot execute ceph health command on %s (%s): %s",
            "Not all hosts have working ceph command",
            version_result.errors
        )
        self.manage_health(version_result)