场景说明

本指南专为 Kylin V10（SP3·Halberd，aarch64） 设计，支持一键安全批量卸载 Ambari/Bigtop 及其依赖。适合 环境重置、集群重装、测试回收。脚本支持多节点并发，卸载后确保系统无历史残留。

一、支持范围

类别	说明
操作系统	Kylin V10（SP3·Halberd），兼容 aarch64
包管理器	yum/dnf 自动识别（脚本已做容错），不依赖 APT
卸载内容	Ambari Server/Agent、MariaDB/MySQL、JDK、MySQL Connector、 Nginx、本地 YUM 源、常见大数据组件残留（HDFS/HBase/Hive/Kafka/YARN/Tez/ZooKeeper/Ozone/Spark/Flink…）
适用场景	建议与本站 ONEKEY 安装方案配套，复用原始 hosts.txt， 支持多节点集群卸载、环境回滚、二次安装前清场与验收测试

二、卸载脚本完整内容 必读

注意

下方为 Kylin V10 专用 一键卸载脚本。复制前请确认 hosts.txt（用户名 密码 IP）配置无误；脚本会并发批处理， 对生产环境务必谨慎。已适配 yum/dnf、公钥、sudo 与 systemd 差异。

#!/bin/bash
# SPDX-License-Identifier: LicenseRef-JaneTTR-Proprietary
# 版权所有 (c) 2025 JaneTTR
# 项目名称：ambari-env
# 文件：install_ambari_cluster.sh
# 版本：1.0.0
# 联系方式：[email protected]
#
# 许可说明（付费/专有代码）：
# - 本文件仅限个人学习与研究使用；
# - 未经版权所有者书面授权，禁止任何商业用途；
# - 禁止再分发本文件或其修改版本；
# - 禁止通过反编译、反向工程等方式试图绕过授权验证。
#
# 商业授权：
# 如需将本文件或其编译后的代码用于商业用途，必须获得版权所有者的书面授权。
# 请通过上述联系方式进行洽谈。
#
# 免责声明：
# 本文件按“现状”提供，不附带任何形式的担保，包括但不限于适销性、
# 特定用途适用性或无侵权的担保。因使用本文件造成的任何直接或间接损失，
# 版权所有者不承担任何责任。
#
# 如有任何疑问，请联系版权所有者。

set -euo pipefail

#=============================
#  统一配置：组件/路径/开关
#=============================

# 统一维护“组件关键字”（用于清理路径匹配、/run /tmp 清理等）
# 你以后加组件，就在这里加一个词即可（建议用小写）
COMPONENTS=(
  ambari bigtop
  hadoop hdfs yarn mapred hive hbase hcat tez kms
  zookeeper kafka ranger solr
  spark flink zeppelin
  atlas trino doris
  nightingale categraf
  ozone celeborn
  cloudbeaver
  hudi paimon phoenix dolphin
  ams ambari-qa knox hue alluxio impala livy superset
)

# 仅用于进程兜底匹配，避免使用过于宽泛的 java 关键字
PROCESS_KEYWORDS=(
  ambari ambari-server ambari-agent ambari-metrics
  bigtop hadoop hdfs yarn mapred hive hbase hcat tez kms
  zookeeper kafka ranger solr spark flink zeppelin
  atlas trino doris nightingale categraf ozone celeborn
  cloudbeaver hudi paimon phoenix dolphin ams knox hue
  alluxio impala livy superset n9e
)

# 统一维护“systemctl 服务名”（不带 .service）
SERVICE_UNITS=(
  ambari-server ambari-agent
  hadoop-hdfs-namenode hadoop-hdfs-datanode hadoop-yarn-resourcemanager hadoop-yarn-nodemanager
  zookeeper ranger-admin ranger-usersync
  kafka solr zeppelin spark flink ozone
  mariadb mysql
  nightingale categraf atlas hudi paimon trino knox hue superset alluxio
)

# 统一维护“需要删除的用户/组”（用户名=组名的场景）
# ⚠️ 你原来包含 hadoop，这里我保留（行为不变）。如果你想保护 hadoop，告诉我我给你加白名单/开关。
CLEANUP_USERS=(
  ambari-qa ams hbase hcat hdfs hive kafka kms mapred ranger solr sqoop tez yarn zookeeper
  zeppelin flink spark hadoop doris nightingale categraf ozone celeborn
)

# 仅清理这些根目录下“直接子项”为组件名前缀的路径，避免在 /usr /etc /var 中做模糊全盘扫描
SAFE_PREFIX_ROOTS=(/opt /etc /var/lib /var/log /var/cache /data /data1 /data2)

# 这些路径是卸载大数据组件时允许整段删除的已知目录
SAFE_LITERAL_PATHS=(
  /usr/bigtop
  /data/kafka-logs
  /data/hadoop
  /kafka-logs
  /hadoop
  /ozone
  /celeborn
)

# 开关：
# DRY_RUN=1 只打印不执行
# SKIP_DB=1 跳过数据库初始化
# DB_ROOT_PASSWORD=root 设置数据库 root 密码（默认 root）
# FORCE_KILL_PATTERNS=1 才启用按关键字兜底杀进程（默认关闭，避免误杀当前脚本相关进程）
# NUKE_TMP=1 全清 /tmp（高风险）
# CLEAN_OLD_TMP=1 才会按天数清理 /tmp 中的旧文件（默认关闭，避免误删无关临时文件）
# TMP_TTL_DAYS=2 /tmp 普通文件/目录清理的“保留天数”
TMP_TTL_DAYS="${TMP_TTL_DAYS:-2}"

#=============================
#  环境与日志
#=============================
LOGFILE="/tmp/ambari_cleanup_kylin.log"
exec > >(tee -a "$LOGFILE") 2>&1

TARGET="${TARGET:-localhost}"

log_info ()  { echo "$(date '+%F %T') [Info]  $*"; }
log_warn ()  { echo "$(date '+%F %T') [Warn]  $*"; }
log_error () { echo "$(date '+%F %T') [Error] $*" >&2; }

#=============================
#  小工具：把 COMPONENTS 生成 regex（posix-extended）
#=============================
# 输出形如：.*(a|b|c).* 的 regex（并对 '-' 做转义，避免正则歧义）
build_components_regex() {
  local joined=""
  local x
  for x in "${COMPONENTS[@]}"; do
    x="${x//-/\\-}"
    if [ -z "$joined" ]; then
      joined="$x"
    else
      joined="${joined}|$x"
    fi
  done
  echo ".*(${joined}).*"
}

run_cmd() {
  local DRY="${DRY_RUN:-0}"
  if [ "$DRY" = "1" ]; then
    echo "+ $*"
  else
    eval "$@"
  fi
}

cleanup_prefixed_children() {
  local root=$1
  local prefix

  [ -d "$root" ] || return 0

  for prefix in "${COMPONENTS[@]}" kafka-logs; do
    run_cmd "sudo find '$root' -mindepth 1 -maxdepth 1 \
      \\( -name '${prefix}' -o -name '${prefix}-*' -o -name '${prefix}_*' -o -name '${prefix}.*' -o -name '${prefix}[0-9]*' \\) \
      -exec rm -rf {} + 2>/dev/null || true"
  done
}

cleanup_runtime_entries() {
  local root=$1
  local prefix

  [ -d "$root" ] || return 0

  for prefix in "${COMPONENTS[@]}" kafka-logs; do
    run_cmd "sudo find '$root' -mindepth 1 -maxdepth 2 \
      \\( -name '${prefix}' -o -name '${prefix}-*' -o -name '${prefix}_*' -o -name '${prefix}.*' \
         -o -name '*${prefix}*.pid' -o -name '*${prefix}*.sock' -o -name '*${prefix}*.port' \\) \
      -exec rm -rf {} + 2>/dev/null || true"
  done
}

#=============================
#  OS 检测（要求 RedHat 家族）
#=============================
require_redhat_like() {
  if command -v rpm >/dev/null 2>&1 && [ -f /etc/os-release ]; then
    . /etc/os-release || true
    if echo "${ID_LIKE:-}${ID:-}" | grep -Ei 'rhel|redhat|centos|kylin|openeuler|rocky|almalinux' >/dev/null; then
      return 0
    fi
  fi
  log_error "检测到当前不是 RedHat 家族系统（本脚本适配 Kylin/RedHat 系）。"
  exit 1
}

#=============================
#  包管理工具选择
#=============================
PM=""
pm_detect() {
  if command -v dnf >/dev/null 2>&1; then
    PM="dnf"
  elif command -v yum >/dev/null 2>&1; then
    PM="yum"
  else
    log_error "未找到 dnf/yum，请确认是 Kylin/RedHat 系并安装包管理器。"
    exit 1
  fi
}
pm_install() { sudo "$PM" -y install "$@" --allowerasing || sudo "$PM" -y install "$@" || true; }
pm_remove()  { sudo "$PM" -y remove "$@" || true; }
pm_autoremove() { if [ "$PM" = "dnf" ]; then sudo dnf -y autoremove || true; fi; }
pm_makecache() { sudo "$PM" -y makecache || true; }
pm_update_metadata() {
  if [ "$PM" = "dnf" ]; then sudo dnf -y --refresh makecache || true; else sudo yum -y makecache fast || true; fi
}

#=============================
#  区域/语言（Kylin）
#=============================
ensure_locale_kylin() {
  pm_install glibc-langpack-zh glibc-langpack-en || true

  if command -v localectl >/dev/null 2>&1; then
    if ! sudo localectl set-locale LANG=zh_CN.UTF-8; then
      log_warn "[$TARGET] localectl 设置 LANG=zh_CN.UTF-8 失败，回退为直接写 /etc/locale.conf"
    fi
  fi

  if [ -w /etc/locale.conf ] || sudo test -w /etc/locale.conf; then
    printf '%s\n' 'LANG=zh_CN.UTF-8' | sudo tee /etc/locale.conf >/dev/null || true
  fi

  export LANG=zh_CN.UTF-8
  unset LC_ALL || true
}

#=============================
#  基础工具与 sshpass
#=============================
ensure_base_tools() {
  pm_update_metadata
  pm_install which coreutils findutils util-linux procps-ng psmisc lsof gawk grep sed tar gzip || true
}
ensure_sshpass() {
  if ! command -v sshpass >/dev/null 2>&1; then
    log_info "sshpass 未安装，开始安装…"
    pm_install sshpass
    if ! command -v sshpass >/dev/null 2>&1; then
      log_warn "仓库中找不到 sshpass，尝试启用可用的 Extra/Epol/PowerTools 仓库后再次安装…"
      sudo "$PM" config-manager --set-enabled epol 2>/dev/null || true
      sudo "$PM" config-manager --set-enabled powertools 2>/dev/null || true
      pm_makecache
      pm_install sshpass
    fi
  fi
}

#=============================
#  停服务 & 杀进程
#=============================
stop_services_and_kill() {
  log_info "[$TARGET] 停止服务与杀进程…"

  for svc in "${SERVICE_UNITS[@]}"; do
    if systemctl list-unit-files | awk '{print $1}' | grep -qx "${svc}.service"; then
      sudo systemctl stop "$svc" || true
      sudo systemctl disable "$svc" || true
    fi
  done

  if [ "${FORCE_KILL_PATTERNS:-0}" != "1" ]; then
    log_info "[$TARGET] 跳过按关键字兜底杀进程；如需启用请设置 FORCE_KILL_PATTERNS=1"
    return 0
  fi

  # 关键词兜底：默认关闭，仅在显式要求时启用
  local kill_keywords=("${PROCESS_KEYWORDS[@]}")
  local kw
  for kw in "${kill_keywords[@]}"; do
    mapfile -t kw_pids < <(ps -eo pid,cmd --no-headers | grep -F -- "$kw" | grep -v grep | awk '{print $1}')
    for pid in "${kw_pids[@]:-}"; do
      if [[ "$pid" =~ ^[0-9]+$ ]] && kill -0 "$pid" 2>/dev/null; then
        log_info "按关键词[$kw] 杀进程: $pid"
        kill -9 "$pid" || true
      fi
    done
  done
}

#=============================
#  卸载 Ambari/Bigtop 相关包（RPM）
#=============================
remove_ambari_bigtop_rpms() {
  log_info "[$TARGET] 卸载 ambari/bigtop 仓库相关 RPM 包…"

  mapfile -t rpms < <(
    rpm -qa 2>/dev/null \
      | awk 'BEGIN{IGNORECASE=1}
        {
          name=$0
          if (name ~ /(ambari|bigtop)/) { print $0; next }
          if (name ~ /3_2_0/) { print $0; next }
        }' \
      | sort -u \
      || true
  )

  if [ "${#rpms[@]}" -gt 0 ]; then
    log_info "[$TARGET] 将卸载以下 ambari/bigtop/3_2_0 相关包：${rpms[*]}"
    pm_remove "${rpms[@]}" || true
    pm_autoremove
  else
    log_info "[$TARGET] 未找到 ambari/bigtop/3_2_0 相关的已安装包"
  fi
}

#=============================
#  清理文件/目录/用户/DB/日志
#=============================
cleanup_files_users_db() {
  log_info "[$TARGET] 清理残留文件与目录…"
  local d
  for d in "${SAFE_PREFIX_ROOTS[@]}"; do
    cleanup_prefixed_children "$d"
  done

  for d in "${SAFE_LITERAL_PATHS[@]}"; do
    run_cmd "sudo rm -rf '$d' 2>/dev/null || true"
  done

  #=============================
  #  /run(/var/run) 清理：只删匹配组件关键字的残留 pid/socket/目录
  #=============================
  log_info "[$TARGET] 清理 /run(/var/run) 下的大数据残留 pid/socket…"
  local run_dirs=(/run /var/run)
  local rd
  for rd in "${run_dirs[@]}"; do
    cleanup_runtime_entries "$rd"
  done

  #=============================
  #  /tmp 清理：默认只清理组件相关临时文件
  #=============================
  log_info "[$TARGET] 清理 /tmp 下的大数据临时文件…"
  cleanup_runtime_entries /tmp

  if [ "${CLEAN_OLD_TMP:-0}" = "1" ]; then
    log_warn "[$TARGET] CLEAN_OLD_TMP=1：按保留天数清理 /tmp 中的旧文件"
    run_cmd "sudo find /tmp -mindepth 1 -maxdepth 2 -not -type s -mtime +${TMP_TTL_DAYS} -exec rm -rf {} + 2>/dev/null || true"
  fi

  if [ "${NUKE_TMP:-0}" = "1" ]; then
    log_warn "[$TARGET] NUKE_TMP=1：即将清空 /tmp（高风险）"
    run_cmd "sudo rm -rf /tmp/* /tmp/.[!.]* /tmp/..?* 2>/dev/null || true"
  fi

  log_info "[$TARGET] 清理大数据相关用户/组/家目录…"
  local u
  for u in "${CLEANUP_USERS[@]}"; do
    run_cmd "sudo pkill -u '$u' 2>/dev/null || true"
    run_cmd "sudo userdel -r '$u' 2>/dev/null || true"
    run_cmd "sudo groupdel '$u' 2>/dev/null || true"
    run_cmd "sudo rm -rf /home/'$u' 2>/dev/null || true"
  done

  log_info "[$TARGET] 清理常见日志路径下的组件残留…"
  cleanup_prefixed_children /var/log

  log_info "[$TARGET] 清理并重建数据库（如安装了 MariaDB/MySQL）…"

  if [ "${SKIP_DB:-0}" = "1" ]; then
    log_info "[$TARGET] 跳过数据库初始化（SKIP_DB=1）"
    return 0
  fi

  local svc="" flavor="" initcmd="" mariadb_init_bin="" mysql_server_bin="" db_client_bin=""
  local db_root_password="${DB_ROOT_PASSWORD:-root}"

  for mariadb_init_bin in \
    "$(command -v mariadb-install-db 2>/dev/null || true)" \
    /usr/bin/mariadb-install-db \
    /usr/libexec/mariadb-install-db \
    "$(command -v mysql_install_db 2>/dev/null || true)" \
    /usr/bin/mysql_install_db; do
    [ -n "$mariadb_init_bin" ] || continue
    [ -x "$mariadb_init_bin" ] || continue
    break
  done

  for mysql_server_bin in \
    "$(command -v mariadbd 2>/dev/null || true)" \
    /usr/sbin/mariadbd \
    /usr/libexec/mariadbd \
    "$(command -v mysqld 2>/dev/null || true)" \
    /usr/sbin/mysqld \
    /usr/libexec/mysqld; do
    [ -n "$mysql_server_bin" ] || continue
    [ -x "$mysql_server_bin" ] || continue
    break
  done

  for db_client_bin in \
    "$(command -v mariadb 2>/dev/null || true)" \
    /usr/bin/mariadb \
    "$(command -v mysql 2>/dev/null || true)" \
    /usr/bin/mysql; do
    [ -n "$db_client_bin" ] || continue
    [ -x "$db_client_bin" ] || continue
    break
  done

  if systemctl list-unit-files --type=service 2>/dev/null | grep -q '^mariadb\.service'; then
    svc="mariadb"; flavor="mariadb"
  elif systemctl list-unit-files --type=service 2>/dev/null | grep -q '^mysqld\.service'; then
    svc="mysqld"
    if [ -n "$mariadb_init_bin" ] \
      || rpm -qa 2>/dev/null | egrep -qi '^(MariaDB|mariadb)-server' \
      || { [ -n "$mysql_server_bin" ] && "$mysql_server_bin" --version 2>&1 | grep -qi 'mariadb'; }; then
      flavor="mariadb"
    else
      flavor="mysql"
    fi
  elif [ -n "$mariadb_init_bin" ]; then
    flavor="mariadb"; svc="${svc:-mariadb}"
  elif [ -n "$mysql_server_bin" ]; then
    if "$mysql_server_bin" --version 2>&1 | grep -qi 'mariadb'; then
      flavor="mariadb"; svc="${svc:-mariadb}"
    else
      flavor="mysql"; svc="${svc:-mysqld}"
    fi
  elif rpm -qa 2>/dev/null | egrep -qi '^(MariaDB|mariadb)-server'; then
    flavor="mariadb"; svc="${svc:-mariadb}"
  elif rpm -qa 2>/dev/null | egrep -qi '^mysql-community-server'; then
    flavor="mysql"; svc="${svc:-mysqld}"
  fi

  if [ -n "$mysql_server_bin" ]; then
    if "$mysql_server_bin" --version 2>&1 | grep -qi 'mariadb'; then
      flavor="mariadb"
      svc="${svc:-mariadb}"
    fi
  fi

  if [ -z "$flavor" ]; then
    log_info "[$TARGET] 未检测到 MariaDB/MySQL，跳过数据库初始化。"
    return 0
  fi

  if [ "$flavor" = "mariadb" ]; then
    if [ -z "$mariadb_init_bin" ] || [ ! -x "$mariadb_init_bin" ]; then
      log_warn "[$TARGET] 未找到可用的 MariaDB 初始化命令（mariadb-install-db/mysql_install_db）"
      return 1
    fi

    case "$(basename "$mariadb_init_bin")" in
      mariadb-install-db)
        initcmd="'$mariadb_init_bin' --user=mysql --basedir=/usr --datadir=/var/lib/mysql --skip-test-db"
        ;;
      mysql_install_db)
        initcmd="'$mariadb_init_bin' --user=mysql --datadir=/var/lib/mysql"
        ;;
      *)
        log_warn "[$TARGET] 不支持的 MariaDB 初始化命令：$mariadb_init_bin"
        return 1
        ;;
    esac

    [ -n "${MARIADB_EXTRA_INIT_FLAGS:-}" ] && initcmd="$initcmd ${MARIADB_EXTRA_INIT_FLAGS}"
    svc="${svc:-mariadb}"
  else
    if [ -z "$mysql_server_bin" ] || [ ! -x "$mysql_server_bin" ]; then
      log_warn "[$TARGET] 未找到可用的 MySQL 服务端命令（mysqld/mariadbd）"
      return 1
    fi
    initcmd="'$mysql_server_bin' --initialize-insecure --user=mysql --datadir=/var/lib/mysql"
    [ -n "${MYSQL_EXTRA_INIT_FLAGS:-}" ] && initcmd="$initcmd ${MYSQL_EXTRA_INIT_FLAGS}"
    svc="${svc:-mysqld}"
  fi

  run_cmd "sudo systemctl stop '$svc' 2>/dev/null || true"
  run_cmd "sudo rm -rf /var/lib/mysql/*"
  run_cmd "sudo install -d -o mysql -g mysql /var/lib/mysql"

  log_info "[$TARGET] 运行初始化命令：$initcmd"
  if ! run_cmd "sudo bash -lc \"$initcmd\""; then
    log_warn "数据库初始化失败：$initcmd"
    return 1
  fi

  run_cmd "sudo systemctl enable '$svc' 2>/dev/null || true"
  if ! run_cmd "sudo systemctl restart '$svc'"; then
    log_warn "重启 $svc 失败，请检查 journalctl -u $svc"
    return 1
  fi

  if [ -n "$db_client_bin" ] && [ -x "$db_client_bin" ]; then
    local db_admin_cmd=""
    local mariadb_root_sql=""
    local mysql_root_sql=""

    log_info "[$TARGET] 重置数据库 root 账号密码与授权…"

    if [ "${DRY_RUN:-0}" = "1" ]; then
      echo "+ 探测数据库 root 登录方式并重置 root 密码/授权"
    else
      if sudo "$db_client_bin" --protocol=socket -uroot -e "SELECT 1" >/dev/null 2>&1; then
        db_admin_cmd="sudo '$db_client_bin' --protocol=socket -uroot"
      elif sudo "$db_client_bin" --protocol=socket -uroot -p"${db_root_password}" -e "SELECT 1" >/dev/null 2>&1; then
        db_admin_cmd="sudo '$db_client_bin' --protocol=socket -uroot -p'${db_root_password}'"
      fi

      if [ -z "$db_admin_cmd" ]; then
        log_warn "[$TARGET] 无法确定 root 的可用登录方式，跳过 root 密码重置"
      else
        mariadb_root_sql="ALTER USER 'root'@'localhost' IDENTIFIED VIA mysql_native_password USING PASSWORD('${db_root_password}'); CREATE USER IF NOT EXISTS 'root'@'%' IDENTIFIED BY '${db_root_password}'; ALTER USER 'root'@'%' IDENTIFIED BY '${db_root_password}'; GRANT ALL PRIVILEGES ON *.* TO 'root'@'%' WITH GRANT OPTION; FLUSH PRIVILEGES;"
        mysql_root_sql="ALTER USER 'root'@'localhost' IDENTIFIED BY '${db_root_password}'; CREATE USER IF NOT EXISTS 'root'@'%' IDENTIFIED BY '${db_root_password}'; ALTER USER 'root'@'%' IDENTIFIED BY '${db_root_password}'; GRANT ALL PRIVILEGES ON *.* TO 'root'@'%' WITH GRANT OPTION; FLUSH PRIVILEGES;"

        if [ "$flavor" = "mariadb" ]; then
          if ! run_cmd "$db_admin_cmd -e \"$mariadb_root_sql\" >/dev/null 2>&1"; then
            if ! run_cmd "$db_admin_cmd -e \"$mysql_root_sql\" >/dev/null 2>&1"; then
              log_warn "[$TARGET] root 密码/授权重置失败，请手动检查 MariaDB 认证方式"
            fi
          fi
        else
          if ! run_cmd "$db_admin_cmd -e \"$mysql_root_sql\" >/dev/null 2>&1"; then
            log_warn "[$TARGET] root 密码/授权重置失败，请手动检查 MySQL 认证方式"
          fi
        fi
      fi
    fi
  else
    log_warn "[$TARGET] 未找到 mariadb/mysql 客户端，跳过 root 密码重置"
  fi

  log_info "[$TARGET] 数据库初始化完成（flavor=$flavor, service=$svc）"
}

#=============================
#  远端执行（通过 sshpass）
#=============================
run_remote() {
  local user=$1 ip=$2 pass=$3
  sshpass -p "$pass" ssh -o StrictHostKeyChecking=no \
                         -o UserKnownHostsFile=/dev/null \
                         -o ConnectTimeout=8 \
                         "$user@$ip" \
                         "TARGET=$ip DRY_RUN=${DRY_RUN:-0} SKIP_DB=${SKIP_DB:-0} RESET_DB=${RESET_DB:-0} FORCE_KILL_PATTERNS=${FORCE_KILL_PATTERNS:-0} CLEAN_OLD_TMP=${CLEAN_OLD_TMP:-0} NUKE_TMP=${NUKE_TMP:-0} TMP_TTL_DAYS=${TMP_TTL_DAYS} bash -s remote" < "$0"
}

#=============================
#  本地主流程
#=============================
main() {
  require_redhat_like
  pm_detect
  ensure_base_tools
  ensure_locale_kylin
  ensure_sshpass

  mapfile -t local_ips < <(hostname -I 2>/dev/null | tr ' ' '\n' || true)
  local_ips+=(127.0.0.1)

  if [ ! -f "./hosts.txt" ]; then
    log_error "hosts.txt 不存在（每行格式：user password ip）"
    exit 1
  fi

  while IFS= read -r line || [ -n "$line" ]; do
    line="$(echo "$line" | tr -d '\r')"
    [[ -z "$line" || "$line" =~ ^# ]] && continue
    read -r user pass ip <<< "$(echo "$line" | xargs)"
    TARGET="$ip"
    log_info "=== 开始处理 $TARGET ==="

    if printf '%s\n' "${local_ips[@]}" | grep -Fxq "$ip"; then
      stop_services_and_kill
      remove_ambari_bigtop_rpms
      cleanup_files_users_db
      ensure_locale_kylin
    else
      run_remote "$user" "$ip" "$pass"
    fi

    log_info "=== $TARGET 处理完毕 ==="
  done < "./hosts.txt"

  log_info "所有节点清理完成，详见 $LOGFILE"
}

#=============================
#  远端主流程
#=============================
remote_main() {
  require_redhat_like
  pm_detect
  ensure_base_tools
  ensure_locale_kylin

  stop_services_and_kill
  remove_ambari_bigtop_rpms
  cleanup_files_users_db
  ensure_locale_kylin
}

#=============================
#  脚本入口
#=============================
if [[ "${1-}" == "remote" ]]; then
  remote_main
  exit 0
else
  main
  exit 0
fi

三、hosts.txt 格式说明

用户名	密码	IP地址
root	xxxxxx	192.168.3.1
root	xxxxxx	192.168.3.2
root	xxxxxx	192.168.3.3

笔记

Kylin V10 全节点需 网络互通、具备 sudo/root 权限。hosts.txt 可直接复用 ONEKEY 安装方案的同名文件。

四、使用方法

1、准备 hosts.txt

将所有目标主机账号、密码、IP 填入 hosts.txt 并与脚本置于同目录。

2、执行卸载脚本

chmod +x uninstall_ambari_cluster.sh
./uninstall_ambari_cluster.sh

日志默认写入 ambari_cleanup.log；失败节点会落盘到 failed_hosts.log。

3、核查结果（建议逐台）

1. 关键目录确认 /var/lib/ambari-*、/usr/bigtop、/var/lib/mysql/、/etc/ambari*、/var/log/ambari*
2. 数据卷按需复核 /data1、/data2、/data/hadoop、/data/kafka-logs、/hadoop/*
3. 服务状态 systemctl status ambari-server ambari-agent mariadb 应处于 inactive/disabled

可选：保留业务数据的做法

若节点上存在需保留的数据分区，请在脚本前部的 数据清理段 注释对应的 rm -rf 行，或在生产环境使用前先在测试环境验证路径白名单。

五、Kylin V10 差异项说明

一、包管理差异

1. Kylin 使用 yum/dnf，脚本已自动识别，不再包含 APT 分支。
2. Ambari/Bigtop 组件卸载通过 yum/dnf remove，正则命中 ambari|bigtop 包名，避免遗漏。

二、服务管理

1. 统一使用 systemctl stop/disable 处理 Ambari/MDB/Nginx 及常见大数据服务；
2. 对历史“非 systemd 启动脚本”进程，通过 关键词杀进程 兜底（java/hadoop/hdfs/kafka/...）。

三、数据与账号回收

1. 覆盖 用户/用户组 清理：ambari-qa、hdfs、yarn、hive、kafka、zookeeper、spark、flink、ranger…；
2. 数据目录按 关键词 与 常见路径 双清理，减少残留；
3. MariaDB 支持 数据重建（mariadb-install-db），用于集群重装前置。

警告

生产环境谨慎执行！脚本默认会清理多类数据路径与用户。如需保留业务数据/账号，请先调小清理范围再执行。

六、图示参考