Version 2.0.0: Support multi-pools avec isolation des erreurs
Fonctionnalités principales:
- Support de plusieurs pools ZFS simultanément (ZPOOLS array)
- Isolation des erreurs: échec d'un pool n'affecte pas les autres
- Logs séparés par pool avec rotation automatique (14 jours)
- Lockfiles indépendants par pool
- Configuration Sanoid générée automatiquement pour tous les pools
- Fichiers d'état séparés par pool
- Résumé de réplication détaillé
Configuration:
- Variable ZPOOLS: liste des pools à répliquer
- LOG_DIR: répertoire des logs (/var/log/zfs-nfs-replica/)
- LOG_RETENTION_DAYS: durée de rétention des logs (14 jours)
Changements techniques:
- Nouvelle fonction replicate_pool() pour réplication isolée
- Fonction init_logging() pour setup des logs et logrotate
- configure_sanoid() génère config dynamique pour tous les pools
- Logs avec contexte de pool (CURRENT_POOL)
Rétrocompatibilité:
- Compatible v1.x avec un seul pool: ZPOOLS=("zpool1")
This commit is contained in:
parent
464540696b
commit
5f00bf25ee
1 changed files with 253 additions and 162 deletions
|
|
@ -1,23 +1,26 @@
|
||||||
#!/bin/bash
|
#!/bin/bash
|
||||||
#
|
#
|
||||||
# Script de réplication ZFS automatique pour NFS HA
|
# Script de réplication ZFS automatique pour NFS HA (Multi-pools)
|
||||||
# À déployer sur acemagician et elitedesk
|
# À déployer sur acemagician et elitedesk
|
||||||
#
|
#
|
||||||
# Ce script :
|
# Ce script version 2.0 :
|
||||||
|
# - Supporte la réplication de plusieurs pools ZFS simultanément
|
||||||
# - Vérifie 3 fois que le LXC nfs-server est actif localement
|
# - Vérifie 3 fois que le LXC nfs-server est actif localement
|
||||||
# - Détermine le nœud distant automatiquement
|
# - Détermine le nœud distant automatiquement
|
||||||
# - Réplique le dataset ZFS vers le nœud passif
|
# - Réplique chaque pool ZFS vers le nœud passif avec isolation des erreurs
|
||||||
# - Utilise un verrou pour éviter les réplications concurrentes
|
# - Utilise un verrou par pool pour éviter les réplications concurrentes
|
||||||
# - Gère l'activation/désactivation de Sanoid selon le nœud actif
|
# - Gère l'activation/désactivation de Sanoid selon le nœud actif
|
||||||
|
# - Logs avec rotation automatique (2 semaines de rétention)
|
||||||
|
# - Fichiers d'état séparés par pool
|
||||||
#
|
#
|
||||||
# Auteur : BENE Maël
|
# Auteur : BENE Maël
|
||||||
# Version : 1.7.0
|
# Version : 2.0.0
|
||||||
#
|
#
|
||||||
|
|
||||||
set -euo pipefail
|
set -euo pipefail
|
||||||
|
|
||||||
# Configuration
|
# Configuration
|
||||||
SCRIPT_VERSION="1.7.0"
|
SCRIPT_VERSION="2.0.0"
|
||||||
REPO_URL="https://forgejo.tellserv.fr/Tellsanguis/zfs-sync-nfs-ha"
|
REPO_URL="https://forgejo.tellserv.fr/Tellsanguis/zfs-sync-nfs-ha"
|
||||||
SCRIPT_URL="${REPO_URL}/raw/branch/main/zfs-nfs-replica.sh"
|
SCRIPT_URL="${REPO_URL}/raw/branch/main/zfs-nfs-replica.sh"
|
||||||
SCRIPT_PATH="${BASH_SOURCE[0]}"
|
SCRIPT_PATH="${BASH_SOURCE[0]}"
|
||||||
|
|
@ -25,21 +28,63 @@ AUTO_UPDATE_ENABLED=true # Mettre à false pour désactiver l'auto-update
|
||||||
|
|
||||||
CTID=103
|
CTID=103
|
||||||
CONTAINER_NAME="nfs-server"
|
CONTAINER_NAME="nfs-server"
|
||||||
ZPOOL="zpool1" # Pool entier à répliquer (tous les datasets)
|
|
||||||
|
# Support multi-pools - Liste des pools à répliquer
|
||||||
|
# Ajouter ou retirer des pools selon vos besoins
|
||||||
|
ZPOOLS=("zpool1" "zpool2")
|
||||||
|
|
||||||
CHECK_DELAY=2 # Délai entre chaque vérification (secondes)
|
CHECK_DELAY=2 # Délai entre chaque vérification (secondes)
|
||||||
LOG_FACILITY="local0"
|
LOG_FACILITY="local0"
|
||||||
SSH_KEY="/root/.ssh/id_ed25519_zfs_replication"
|
SSH_KEY="/root/.ssh/id_ed25519_zfs_replication"
|
||||||
STATE_DIR="/var/lib/zfs-nfs-replica"
|
STATE_DIR="/var/lib/zfs-nfs-replica"
|
||||||
SIZES_FILE="${STATE_DIR}/last-sync-sizes.txt"
|
|
||||||
SIZE_TOLERANCE=20 # Tolérance de variation en pourcentage (±20%)
|
SIZE_TOLERANCE=20 # Tolérance de variation en pourcentage (±20%)
|
||||||
MIN_REMOTE_RATIO=50 # Le distant doit avoir au moins 50% de la taille du local
|
MIN_REMOTE_RATIO=50 # Le distant doit avoir au moins 50% de la taille du local
|
||||||
|
|
||||||
# Fonction de logging
|
# Configuration des logs (rotation 2 semaines)
|
||||||
|
LOG_DIR="/var/log/zfs-nfs-replica"
|
||||||
|
LOG_RETENTION_DAYS=14
|
||||||
|
|
||||||
|
# Initialiser le répertoire de logs
|
||||||
|
init_logging() {
|
||||||
|
mkdir -p "$LOG_DIR"
|
||||||
|
|
||||||
|
# Créer une configuration logrotate si elle n'existe pas
|
||||||
|
local logrotate_conf="/etc/logrotate.d/zfs-nfs-replica"
|
||||||
|
if [[ ! -f "$logrotate_conf" ]]; then
|
||||||
|
cat > "$logrotate_conf" <<EOF
|
||||||
|
${LOG_DIR}/*.log {
|
||||||
|
daily
|
||||||
|
rotate ${LOG_RETENTION_DAYS}
|
||||||
|
compress
|
||||||
|
delaycompress
|
||||||
|
missingok
|
||||||
|
notifempty
|
||||||
|
create 0640 root root
|
||||||
|
}
|
||||||
|
EOF
|
||||||
|
fi
|
||||||
|
}
|
||||||
|
|
||||||
|
# Fonction de logging améliorée
|
||||||
log() {
|
log() {
|
||||||
local level="$1"
|
local level="$1"
|
||||||
shift
|
shift
|
||||||
logger -t "zfs-nfs-replica" -p "${LOG_FACILITY}.${level}" "$@"
|
local pool="${CURRENT_POOL:-global}"
|
||||||
echo "[$(date '+%Y-%m-%d %H:%M:%S')] [$level] $@" >&2
|
local timestamp="$(date '+%Y-%m-%d %H:%M:%S')"
|
||||||
|
local message="[$timestamp] [$level] [$pool] $@"
|
||||||
|
|
||||||
|
# Log vers syslog
|
||||||
|
logger -t "zfs-nfs-replica" -p "${LOG_FACILITY}.${level}" "[$pool] $@"
|
||||||
|
|
||||||
|
# Log vers stderr
|
||||||
|
echo "$message" >&2
|
||||||
|
|
||||||
|
# Log vers fichier (si pool spécifié)
|
||||||
|
if [[ "$pool" != "global" ]]; then
|
||||||
|
echo "$message" >> "${LOG_DIR}/${pool}.log"
|
||||||
|
else
|
||||||
|
echo "$message" >> "${LOG_DIR}/general.log"
|
||||||
|
fi
|
||||||
}
|
}
|
||||||
|
|
||||||
# Fonction d'auto-update
|
# Fonction d'auto-update
|
||||||
|
|
@ -179,58 +224,54 @@ verify_lxc_is_active() {
|
||||||
# Configuration dynamique de Sanoid selon le rôle
|
# Configuration dynamique de Sanoid selon le rôle
|
||||||
configure_sanoid() {
|
configure_sanoid() {
|
||||||
local role="$1" # "active" ou "passive"
|
local role="$1" # "active" ou "passive"
|
||||||
|
local autosnap_value="yes"
|
||||||
|
|
||||||
if [[ "$role" == "active" ]]; then
|
if [[ "$role" == "passive" ]]; then
|
||||||
log "info" "Configuration de Sanoid en mode ACTIF (autosnap=yes, autoprune=yes)"
|
autosnap_value="no"
|
||||||
cat > /etc/sanoid/sanoid.conf <<'EOF'
|
|
||||||
[zpool1]
|
|
||||||
use_template = production
|
|
||||||
recursive = yes
|
|
||||||
|
|
||||||
[template_production]
|
|
||||||
hourly = 24
|
|
||||||
daily = 7
|
|
||||||
monthly = 3
|
|
||||||
yearly = 1
|
|
||||||
autosnap = yes
|
|
||||||
autoprune = yes
|
|
||||||
EOF
|
|
||||||
|
|
||||||
if systemctl is-enabled sanoid.timer &>/dev/null; then
|
|
||||||
if ! systemctl is-active sanoid.timer &>/dev/null; then
|
|
||||||
log "info" "Demarrage de Sanoid sur le noeud actif"
|
|
||||||
systemctl start sanoid.timer
|
|
||||||
fi
|
|
||||||
else
|
|
||||||
log "info" "Activation et demarrage de Sanoid sur le noeud actif"
|
|
||||||
systemctl enable --now sanoid.timer
|
|
||||||
fi
|
|
||||||
elif [[ "$role" == "passive" ]]; then
|
|
||||||
log "info" "Configuration de Sanoid en mode PASSIF (autosnap=no, autoprune=yes)"
|
log "info" "Configuration de Sanoid en mode PASSIF (autosnap=no, autoprune=yes)"
|
||||||
cat > /etc/sanoid/sanoid.conf <<'EOF'
|
else
|
||||||
[zpool1]
|
log "info" "Configuration de Sanoid en mode ACTIF (autosnap=yes, autoprune=yes)"
|
||||||
|
fi
|
||||||
|
|
||||||
|
# Générer la configuration pour tous les pools
|
||||||
|
cat > /etc/sanoid/sanoid.conf <<EOF
|
||||||
|
# Configuration automatique - Ne pas éditer manuellement
|
||||||
|
# Généré par zfs-nfs-replica.sh version ${SCRIPT_VERSION}
|
||||||
|
# Mode: ${role}
|
||||||
|
|
||||||
|
EOF
|
||||||
|
|
||||||
|
# Ajouter chaque pool à la configuration
|
||||||
|
for pool in "${ZPOOLS[@]}"; do
|
||||||
|
cat >> /etc/sanoid/sanoid.conf <<EOF
|
||||||
|
[${pool}]
|
||||||
use_template = production
|
use_template = production
|
||||||
recursive = yes
|
recursive = yes
|
||||||
|
|
||||||
|
EOF
|
||||||
|
done
|
||||||
|
|
||||||
|
# Ajouter le template
|
||||||
|
cat >> /etc/sanoid/sanoid.conf <<EOF
|
||||||
[template_production]
|
[template_production]
|
||||||
hourly = 24
|
hourly = 24
|
||||||
daily = 7
|
daily = 7
|
||||||
monthly = 3
|
monthly = 3
|
||||||
yearly = 1
|
yearly = 1
|
||||||
autosnap = no
|
autosnap = ${autosnap_value}
|
||||||
autoprune = yes
|
autoprune = yes
|
||||||
EOF
|
EOF
|
||||||
|
|
||||||
|
# Activer et démarrer Sanoid si nécessaire
|
||||||
if systemctl is-enabled sanoid.timer &>/dev/null; then
|
if systemctl is-enabled sanoid.timer &>/dev/null; then
|
||||||
if ! systemctl is-active sanoid.timer &>/dev/null; then
|
if ! systemctl is-active sanoid.timer &>/dev/null; then
|
||||||
log "info" "Demarrage de Sanoid sur le noeud passif"
|
log "info" "Demarrage de Sanoid sur le noeud ${role}"
|
||||||
systemctl start sanoid.timer
|
systemctl start sanoid.timer
|
||||||
fi
|
fi
|
||||||
else
|
else
|
||||||
log "info" "Activation et demarrage de Sanoid sur le noeud passif"
|
log "info" "Activation et demarrage de Sanoid sur le noeud ${role}"
|
||||||
systemctl enable --now sanoid.timer
|
systemctl enable --now sanoid.timer
|
||||||
fi
|
fi
|
||||||
fi
|
|
||||||
}
|
}
|
||||||
|
|
||||||
# Vérification de l'existence de snapshots en commun
|
# Vérification de l'existence de snapshots en commun
|
||||||
|
|
@ -291,8 +332,9 @@ get_dataset_sizes() {
|
||||||
# Sauvegarde des tailles de datasets après sync réussie
|
# Sauvegarde des tailles de datasets après sync réussie
|
||||||
save_dataset_sizes() {
|
save_dataset_sizes() {
|
||||||
local pool="$1"
|
local pool="$1"
|
||||||
|
local sizes_file="${STATE_DIR}/last-sync-sizes-${pool}.txt"
|
||||||
|
|
||||||
log "info" "Sauvegarde des tailles de datasets dans ${SIZES_FILE}"
|
log "info" "Sauvegarde des tailles de datasets dans ${sizes_file}"
|
||||||
|
|
||||||
# Créer le répertoire si nécessaire
|
# Créer le répertoire si nécessaire
|
||||||
mkdir -p "$STATE_DIR"
|
mkdir -p "$STATE_DIR"
|
||||||
|
|
@ -301,7 +343,7 @@ save_dataset_sizes() {
|
||||||
{
|
{
|
||||||
echo "timestamp=$(date '+%Y-%m-%d_%H:%M:%S')"
|
echo "timestamp=$(date '+%Y-%m-%d_%H:%M:%S')"
|
||||||
get_dataset_sizes "local" "$pool" | awk '{print $1"="$2}'
|
get_dataset_sizes "local" "$pool" | awk '{print $1"="$2}'
|
||||||
} > "$SIZES_FILE"
|
} > "$sizes_file"
|
||||||
|
|
||||||
log "info" "✓ Tailles sauvegardées"
|
log "info" "✓ Tailles sauvegardées"
|
||||||
}
|
}
|
||||||
|
|
@ -310,6 +352,7 @@ save_dataset_sizes() {
|
||||||
check_size_safety() {
|
check_size_safety() {
|
||||||
local remote_ip="$1"
|
local remote_ip="$1"
|
||||||
local pool="$2"
|
local pool="$2"
|
||||||
|
local sizes_file="${STATE_DIR}/last-sync-sizes-${pool}.txt"
|
||||||
|
|
||||||
log "info" "=== Vérifications de sécurité avant --force-delete ==="
|
log "info" "=== Vérifications de sécurité avant --force-delete ==="
|
||||||
|
|
||||||
|
|
@ -327,7 +370,7 @@ check_size_safety() {
|
||||||
|
|
||||||
# Vérifier si un historique existe (indique que ce nœud a déjà été actif)
|
# Vérifier si un historique existe (indique que ce nœud a déjà été actif)
|
||||||
local has_history=false
|
local has_history=false
|
||||||
if [[ -f "$SIZES_FILE" ]]; then
|
if [[ -f "$sizes_file" ]]; then
|
||||||
has_history=true
|
has_history=true
|
||||||
fi
|
fi
|
||||||
|
|
||||||
|
|
@ -397,13 +440,13 @@ check_size_safety() {
|
||||||
log "info" "Vérification #2: Comparaison avec l'historique des tailles"
|
log "info" "Vérification #2: Comparaison avec l'historique des tailles"
|
||||||
|
|
||||||
local previous_timestamp
|
local previous_timestamp
|
||||||
previous_timestamp=$(grep "^timestamp=" "$SIZES_FILE" | cut -d= -f2)
|
previous_timestamp=$(grep "^timestamp=" "$sizes_file" | cut -d= -f2)
|
||||||
log "info" "Dernière synchronisation réussie: ${previous_timestamp}"
|
log "info" "Dernière synchronisation réussie: ${previous_timestamp}"
|
||||||
|
|
||||||
local dataset size_remote size_previous diff_percent
|
local dataset size_remote size_previous diff_percent
|
||||||
while IFS=$'\t' read -r dataset size_remote; do
|
while IFS=$'\t' read -r dataset size_remote; do
|
||||||
# Récupérer la taille précédente
|
# Récupérer la taille précédente
|
||||||
size_previous=$(grep "^${dataset}=" "$SIZES_FILE" | cut -d= -f2)
|
size_previous=$(grep "^${dataset}=" "$sizes_file" | cut -d= -f2)
|
||||||
|
|
||||||
if [[ -n "$size_previous" ]] && [[ "$size_previous" -gt 0 ]]; then
|
if [[ -n "$size_previous" ]] && [[ "$size_previous" -gt 0 ]]; then
|
||||||
# Calculer la différence en pourcentage
|
# Calculer la différence en pourcentage
|
||||||
|
|
@ -433,9 +476,138 @@ check_size_safety() {
|
||||||
return 0
|
return 0
|
||||||
}
|
}
|
||||||
|
|
||||||
|
# Fonction de réplication d'un pool
|
||||||
|
replicate_pool() {
|
||||||
|
local pool="$1"
|
||||||
|
local remote_ip="$2"
|
||||||
|
local remote_name="$3"
|
||||||
|
|
||||||
|
export CURRENT_POOL="$pool"
|
||||||
|
log "info" "=========================================="
|
||||||
|
log "info" "Début de la réplication du pool: ${pool}"
|
||||||
|
log "info" "=========================================="
|
||||||
|
|
||||||
|
# Vérification de l'existence du pool
|
||||||
|
if ! zpool list "$pool" &>/dev/null; then
|
||||||
|
log "error" "Le pool ${pool} n'existe pas sur ce nœud - IGNORÉ"
|
||||||
|
return 1
|
||||||
|
fi
|
||||||
|
|
||||||
|
# Verrou pour éviter les réplications concurrentes de ce pool
|
||||||
|
local lockfile="/var/run/zfs-replica-${pool}.lock"
|
||||||
|
local lockfd=201
|
||||||
|
|
||||||
|
# Tentative d'acquisition du verrou (non-bloquant)
|
||||||
|
eval "exec ${lockfd}>${lockfile}"
|
||||||
|
if ! flock -n ${lockfd}; then
|
||||||
|
log "info" "Une réplication de ${pool} est déjà en cours - IGNORÉ"
|
||||||
|
return 0
|
||||||
|
fi
|
||||||
|
|
||||||
|
log "info" "Verrou acquis pour ${pool}"
|
||||||
|
|
||||||
|
# Vérification que le pool existe sur le nœud distant
|
||||||
|
if ! ssh -i "$SSH_KEY" "root@${remote_ip}" "zpool list ${pool}" &>/dev/null; then
|
||||||
|
log "error" "Le pool ${pool} n'existe pas sur ${remote_name}"
|
||||||
|
flock -u ${lockfd}
|
||||||
|
return 1
|
||||||
|
fi
|
||||||
|
|
||||||
|
# Vérification des snapshots en commun et choix de la stratégie
|
||||||
|
log "info" "Début de la réplication récursive: ${pool} → ${remote_name} (${remote_ip}):${pool}"
|
||||||
|
|
||||||
|
# Syncoid utilise les options SSH via la variable d'environnement SSH
|
||||||
|
export SSH="ssh -i ${SSH_KEY}"
|
||||||
|
|
||||||
|
local syncoid_opts
|
||||||
|
# Déterminer si c'est une première synchronisation
|
||||||
|
if check_common_snapshots "$remote_ip" "$pool"; then
|
||||||
|
# Snapshots en commun : réplication incrémentale normale
|
||||||
|
log "info" "Mode: Réplication incrémentale (snapshots en commun détectés)"
|
||||||
|
syncoid_opts="--recursive --no-sync-snap"
|
||||||
|
else
|
||||||
|
# Pas de snapshots en commun : première synchronisation avec --force-delete
|
||||||
|
log "warning" "Mode: Première synchronisation détectée"
|
||||||
|
log "warning" "Utilisation de --force-delete pour écraser les datasets incompatibles"
|
||||||
|
|
||||||
|
# SÉCURITÉ : Vérifier les tailles avant d'autoriser --force-delete
|
||||||
|
if ! check_size_safety "$remote_ip" "$pool"; then
|
||||||
|
log "error" "╔════════════════════════════════════════════════════════════════╗"
|
||||||
|
log "error" "║ ARRÊT DE SÉCURITÉ pour ${pool} ║"
|
||||||
|
log "error" "║ Les vérifications de sécurité ont échoué. ║"
|
||||||
|
log "error" "║ --force-delete REFUSÉ pour éviter une perte de données. ║"
|
||||||
|
log "error" "╚════════════════════════════════════════════════════════════════╝"
|
||||||
|
flock -u ${lockfd}
|
||||||
|
return 1
|
||||||
|
fi
|
||||||
|
|
||||||
|
syncoid_opts="--recursive --force-delete"
|
||||||
|
fi
|
||||||
|
|
||||||
|
# Lister les datasets de premier niveau sous le pool
|
||||||
|
local first_level_datasets
|
||||||
|
first_level_datasets=$(zfs list -H -o name -r "$pool" -t filesystem,volume -d 1 | grep -v "^${pool}$")
|
||||||
|
|
||||||
|
if [[ -z "$first_level_datasets" ]]; then
|
||||||
|
log "error" "Aucun dataset trouvé sous ${pool}"
|
||||||
|
flock -u ${lockfd}
|
||||||
|
return 1
|
||||||
|
fi
|
||||||
|
|
||||||
|
log "info" "Datasets à répliquer:"
|
||||||
|
while read -r dataset; do
|
||||||
|
log "info" " - ${dataset}"
|
||||||
|
done <<< "$first_level_datasets"
|
||||||
|
|
||||||
|
# Lancer la réplication pour chaque dataset de premier niveau
|
||||||
|
local replication_failed=0
|
||||||
|
local datasets_processed=0
|
||||||
|
|
||||||
|
while read -r dataset; do
|
||||||
|
datasets_processed=$((datasets_processed + 1))
|
||||||
|
log "info" "=== Réplication de ${dataset} (récursif) ==="
|
||||||
|
|
||||||
|
if syncoid $syncoid_opts "$dataset" "root@${remote_ip}:${dataset}" < /dev/null; then
|
||||||
|
log "info" "✓ ${dataset} répliqué avec succès"
|
||||||
|
else
|
||||||
|
log "error" "✗ Échec de la réplication de ${dataset}"
|
||||||
|
replication_failed=1
|
||||||
|
fi
|
||||||
|
done <<< "$first_level_datasets"
|
||||||
|
|
||||||
|
log "info" "Nombre de datasets traités: ${datasets_processed}"
|
||||||
|
|
||||||
|
# Libérer le verrou
|
||||||
|
flock -u ${lockfd}
|
||||||
|
|
||||||
|
if [[ $replication_failed -eq 0 ]]; then
|
||||||
|
log "info" "✓ Réplication récursive réussie vers ${remote_name} (${remote_ip})"
|
||||||
|
log "info" " Tous les datasets de ${pool} ont été synchronisés"
|
||||||
|
|
||||||
|
# Sauvegarder les tailles après sync réussie
|
||||||
|
save_dataset_sizes "$pool"
|
||||||
|
|
||||||
|
return 0
|
||||||
|
else
|
||||||
|
log "error" "✗ Échec de la réplication de ${pool} vers ${remote_name} (${remote_ip})"
|
||||||
|
return 1
|
||||||
|
fi
|
||||||
|
}
|
||||||
|
|
||||||
|
################################################################################
|
||||||
|
# SCRIPT PRINCIPAL
|
||||||
|
################################################################################
|
||||||
|
|
||||||
|
# Initialiser le système de logs
|
||||||
|
init_logging
|
||||||
|
|
||||||
# Détermination du nœud local et distant
|
# Détermination du nœud local et distant
|
||||||
LOCAL_NODE=$(hostname)
|
LOCAL_NODE=$(hostname)
|
||||||
log "info" "Démarrage du script sur le nœud: ${LOCAL_NODE}"
|
export CURRENT_POOL="global"
|
||||||
|
log "info" "=========================================="
|
||||||
|
log "info" "Démarrage du script version ${SCRIPT_VERSION}"
|
||||||
|
log "info" "Nœud: ${LOCAL_NODE}"
|
||||||
|
log "info" "=========================================="
|
||||||
|
|
||||||
# Vérifier les mises à jour (avant toute opération)
|
# Vérifier les mises à jour (avant toute opération)
|
||||||
auto_update "$@"
|
auto_update "$@"
|
||||||
|
|
@ -457,6 +629,7 @@ case "$LOCAL_NODE" in
|
||||||
esac
|
esac
|
||||||
|
|
||||||
log "info" "Nœud distant configuré: ${REMOTE_NODE_NAME} (${REMOTE_NODE_IP})"
|
log "info" "Nœud distant configuré: ${REMOTE_NODE_NAME} (${REMOTE_NODE_IP})"
|
||||||
|
log "info" "Pools configurés: ${ZPOOLS[*]}"
|
||||||
|
|
||||||
# Triple vérification de sécurité
|
# Triple vérification de sécurité
|
||||||
if ! verify_lxc_is_active; then
|
if ! verify_lxc_is_active; then
|
||||||
|
|
@ -469,35 +642,6 @@ fi
|
||||||
# Le LXC est actif ici : configurer Sanoid en mode actif
|
# Le LXC est actif ici : configurer Sanoid en mode actif
|
||||||
configure_sanoid "active"
|
configure_sanoid "active"
|
||||||
|
|
||||||
# Vérification de l'existence du pool
|
|
||||||
if ! zpool list "$ZPOOL" &>/dev/null; then
|
|
||||||
log "error" "Le pool ${ZPOOL} n'existe pas sur ce nœud"
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
|
|
||||||
# Verrou pour éviter les réplications concurrentes
|
|
||||||
LOCKFILE="/var/run/zfs-replica-${ZPOOL}.lock"
|
|
||||||
LOCKFD=200
|
|
||||||
|
|
||||||
# Fonction de nettoyage
|
|
||||||
cleanup() {
|
|
||||||
if [[ -n "${LOCK_ACQUIRED:-}" ]]; then
|
|
||||||
log "info" "Libération du verrou"
|
|
||||||
flock -u $LOCKFD
|
|
||||||
fi
|
|
||||||
}
|
|
||||||
trap cleanup EXIT
|
|
||||||
|
|
||||||
# Tentative d'acquisition du verrou (non-bloquant)
|
|
||||||
eval "exec $LOCKFD>$LOCKFILE"
|
|
||||||
if ! flock -n $LOCKFD; then
|
|
||||||
log "info" "Une réplication est déjà en cours. Abandon."
|
|
||||||
exit 0
|
|
||||||
fi
|
|
||||||
LOCK_ACQUIRED=1
|
|
||||||
|
|
||||||
log "info" "Verrou acquis. Début de la réplication."
|
|
||||||
|
|
||||||
# Vérification de la connectivité SSH vers le nœud distant
|
# Vérification de la connectivité SSH vers le nœud distant
|
||||||
if ! ssh -i "$SSH_KEY" -o ConnectTimeout=5 -o BatchMode=yes "root@${REMOTE_NODE_IP}" "echo OK" &>/dev/null; then
|
if ! ssh -i "$SSH_KEY" -o ConnectTimeout=5 -o BatchMode=yes "root@${REMOTE_NODE_IP}" "echo OK" &>/dev/null; then
|
||||||
log "error" "Impossible de se connecter à ${REMOTE_NODE_NAME} (${REMOTE_NODE_IP}) via SSH"
|
log "error" "Impossible de se connecter à ${REMOTE_NODE_NAME} (${REMOTE_NODE_IP}) via SSH"
|
||||||
|
|
@ -506,92 +650,39 @@ fi
|
||||||
|
|
||||||
log "info" "Connexion SSH vers ${REMOTE_NODE_NAME} (${REMOTE_NODE_IP}) vérifiée"
|
log "info" "Connexion SSH vers ${REMOTE_NODE_NAME} (${REMOTE_NODE_IP}) vérifiée"
|
||||||
|
|
||||||
# Vérification que le pool existe sur le nœud distant
|
# Compteurs globaux
|
||||||
if ! ssh -i "$SSH_KEY" "root@${REMOTE_NODE_IP}" "zpool list ${ZPOOL}" &>/dev/null; then
|
POOLS_TOTAL=${#ZPOOLS[@]}
|
||||||
log "error" "Le pool ${ZPOOL} n'existe pas sur ${REMOTE_NODE_NAME}"
|
POOLS_SUCCESS=0
|
||||||
exit 1
|
POOLS_FAILED=0
|
||||||
fi
|
POOLS_SKIPPED=0
|
||||||
|
|
||||||
# Vérification des snapshots en commun et choix de la stratégie de réplication
|
log "info" "=========================================="
|
||||||
log "info" "Début de la réplication récursive: ${ZPOOL} → ${REMOTE_NODE_NAME} (${REMOTE_NODE_IP}):${ZPOOL}"
|
log "info" "Début de la réplication de ${POOLS_TOTAL} pool(s)"
|
||||||
|
log "info" "=========================================="
|
||||||
|
|
||||||
# Syncoid utilise les options SSH via la variable d'environnement SSH
|
# Réplication de chaque pool
|
||||||
export SSH="ssh -i ${SSH_KEY}"
|
for pool in "${ZPOOLS[@]}"; do
|
||||||
|
if replicate_pool "$pool" "$REMOTE_NODE_IP" "$REMOTE_NODE_NAME"; then
|
||||||
# Déterminer si c'est une première synchronisation
|
POOLS_SUCCESS=$((POOLS_SUCCESS + 1))
|
||||||
if check_common_snapshots "$REMOTE_NODE_IP" "$ZPOOL"; then
|
|
||||||
# Snapshots en commun : réplication incrémentale normale
|
|
||||||
log "info" "Mode: Réplication incrémentale (snapshots en commun détectés)"
|
|
||||||
SYNCOID_OPTS="--recursive --no-sync-snap"
|
|
||||||
else
|
else
|
||||||
# Pas de snapshots en commun : première synchronisation avec --force-delete
|
POOLS_FAILED=$((POOLS_FAILED + 1))
|
||||||
log "warning" "Mode: Première synchronisation détectée"
|
|
||||||
log "warning" "Utilisation de --force-delete pour écraser les datasets incompatibles"
|
|
||||||
|
|
||||||
# SÉCURITÉ : Vérifier les tailles avant d'autoriser --force-delete
|
|
||||||
if ! check_size_safety "$REMOTE_NODE_IP" "$ZPOOL"; then
|
|
||||||
log "error" "╔════════════════════════════════════════════════════════════════╗"
|
|
||||||
log "error" "║ ARRÊT DE SÉCURITÉ ║"
|
|
||||||
log "error" "║ Les vérifications de sécurité ont échoué. ║"
|
|
||||||
log "error" "║ --force-delete REFUSÉ pour éviter une perte de données. ║"
|
|
||||||
log "error" "║ ║"
|
|
||||||
log "error" "║ Actions possibles : ║"
|
|
||||||
log "error" "║ 1. Vérifier manuellement les tailles des datasets ║"
|
|
||||||
log "error" "║ 2. Si changement de disque : supprimer ${SIZES_FILE} ║"
|
|
||||||
log "error" "║ 3. Vérifier que le bon nœud est actif (LXC sur le bon nœud) ║"
|
|
||||||
log "error" "╚════════════════════════════════════════════════════════════════╝"
|
|
||||||
exit 1
|
|
||||||
fi
|
fi
|
||||||
|
done
|
||||||
|
|
||||||
log "info" "Note: Première synchronisation - syncoid va créer un snapshot initial"
|
# Résumé final
|
||||||
log "info" " Les blocs de données existants seront réutilisés (pas de transfert complet)"
|
export CURRENT_POOL="global"
|
||||||
# Pour la première sync: pas de --no-sync-snap (on veut que syncoid crée un snapshot)
|
log "info" "=========================================="
|
||||||
# mais on garde --force-delete pour écraser les datasets vides/incompatibles
|
log "info" "RÉSUMÉ DE LA RÉPLICATION"
|
||||||
SYNCOID_OPTS="--recursive --force-delete"
|
log "info" "=========================================="
|
||||||
fi
|
log "info" "Pools traités: ${POOLS_TOTAL}"
|
||||||
|
log "info" " ✓ Succès: ${POOLS_SUCCESS}"
|
||||||
# Lister les datasets de premier niveau sous le pool
|
log "info" " ✗ Échecs: ${POOLS_FAILED}"
|
||||||
# (on ne réplique pas le pool racine lui-même, seulement ses enfants directs)
|
log "info" "=========================================="
|
||||||
FIRST_LEVEL_DATASETS=$(zfs list -H -o name -r "$ZPOOL" -t filesystem,volume -d 1 | grep -v "^${ZPOOL}$")
|
|
||||||
|
|
||||||
if [[ -z "$FIRST_LEVEL_DATASETS" ]]; then
|
|
||||||
log "error" "Aucun dataset trouvé sous ${ZPOOL}"
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
|
|
||||||
log "info" "Datasets à répliquer:"
|
|
||||||
while read -r dataset; do
|
|
||||||
log "info" " - ${dataset}"
|
|
||||||
done <<< "$FIRST_LEVEL_DATASETS"
|
|
||||||
|
|
||||||
# Lancer la réplication pour chaque dataset de premier niveau
|
|
||||||
# Chaque réplication est récursive, donc elle inclut tous les datasets enfants
|
|
||||||
REPLICATION_FAILED=0
|
|
||||||
DATASETS_PROCESSED=0
|
|
||||||
|
|
||||||
while read -r dataset; do
|
|
||||||
DATASETS_PROCESSED=$((DATASETS_PROCESSED + 1))
|
|
||||||
log "info" "=== Réplication de ${dataset} (récursif) ==="
|
|
||||||
|
|
||||||
if syncoid $SYNCOID_OPTS "$dataset" "root@${REMOTE_NODE_IP}:${dataset}" < /dev/null; then
|
|
||||||
log "info" "✓ ${dataset} répliqué avec succès"
|
|
||||||
else
|
|
||||||
log "error" "✗ Échec de la réplication de ${dataset}"
|
|
||||||
REPLICATION_FAILED=1
|
|
||||||
fi
|
|
||||||
done <<< "$FIRST_LEVEL_DATASETS"
|
|
||||||
|
|
||||||
log "info" "Nombre de datasets traités: ${DATASETS_PROCESSED}"
|
|
||||||
|
|
||||||
if [[ $REPLICATION_FAILED -eq 0 ]]; then
|
|
||||||
log "info" "✓ Réplication récursive réussie vers ${REMOTE_NODE_NAME} (${REMOTE_NODE_IP})"
|
|
||||||
log "info" " Tous les datasets de ${ZPOOL} ont été synchronisés"
|
|
||||||
|
|
||||||
# Sauvegarder les tailles après sync réussie
|
|
||||||
save_dataset_sizes "$ZPOOL"
|
|
||||||
|
|
||||||
|
if [[ $POOLS_FAILED -eq 0 ]]; then
|
||||||
|
log "info" "✓ Toutes les réplications ont réussi"
|
||||||
exit 0
|
exit 0
|
||||||
else
|
else
|
||||||
log "error" "✗ Échec de la réplication vers ${REMOTE_NODE_NAME} (${REMOTE_NODE_IP})"
|
log "error" "✗ ${POOLS_FAILED} pool(s) ont échoué"
|
||||||
exit 1
|
exit 1
|
||||||
fi
|
fi
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue