automatic backup disk on/off
This commit is contained in:
12
roles/_handlers/handlers/main.yaml
Normal file
12
roles/_handlers/handlers/main.yaml
Normal file
@@ -0,0 +1,12 @@
|
||||
- name: reload systemd
|
||||
command: systemctl daemon-reload
|
||||
|
||||
|
||||
- name: Restart NGINX
|
||||
service:
|
||||
name: nginx
|
||||
state: restarted
|
||||
|
||||
|
||||
- name: Run APT update
|
||||
command: apt update -y
|
||||
9
roles/backup_server/files/backup-disk-off.timer
Normal file
9
roles/backup_server/files/backup-disk-off.timer
Normal file
@@ -0,0 +1,9 @@
|
||||
[Unit]
|
||||
Description="Check Backup mounts and turn Disk off if apropriate"
|
||||
|
||||
[Timer]
|
||||
OnCalendar=*:0/15
|
||||
Unit=backup-disk-onoff@off.service
|
||||
|
||||
[Install]
|
||||
WantedBy=network.target
|
||||
@@ -1,5 +1,24 @@
|
||||
#!/usr/bin/env python3
|
||||
import subprocess
|
||||
import json
|
||||
import sys
|
||||
import paho.mqtt.client as mqtt
|
||||
import time
|
||||
|
||||
def send_mqtt_message(topic, payload):
|
||||
client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2) # Use the latest API version
|
||||
client.connect("mqtt.chaos", 1883, 60)
|
||||
client.publish(topic, payload)
|
||||
client.disconnect()
|
||||
|
||||
def get_args(name='default', first='on'):
|
||||
return first
|
||||
|
||||
mode = get_args(*sys.argv)
|
||||
print(f"Mode is: {mode}")
|
||||
if mode not in ["on", "off"]:
|
||||
print("Error: mode must be either 'on' or 'off'")
|
||||
sys.exit(1)
|
||||
|
||||
# Run the systemctl command and capture the output
|
||||
try:
|
||||
@@ -21,7 +40,7 @@ except json.JSONDecodeError as e:
|
||||
print(f"Error parsing JSON: {e}")
|
||||
exit(1)
|
||||
|
||||
# Filter units that are loaded, active, and sub: running
|
||||
# Filter units that are loaded, active, and sub: running, and start with 'backup-'
|
||||
running_units = []
|
||||
for unit in units:
|
||||
if (
|
||||
@@ -36,3 +55,46 @@ for unit in units:
|
||||
print("Units with load: loaded, active: active, sub: running:")
|
||||
for unit in running_units:
|
||||
print(f" - {unit['unit']}: {unit['description']}")
|
||||
|
||||
# Send MQTT message based on mode
|
||||
if mode == "on" or (mode == "off" and running_units):
|
||||
# Send ON MQTT message
|
||||
print(f"Turning backup Disk ON")
|
||||
send_mqtt_message("switch_backup/switch/switch_backup_power/command", "on")
|
||||
time.sleep(15)
|
||||
# ON case: Send ON message after waiting 5 seconds and running vgchange -ay backup if needed
|
||||
if mode == "on":
|
||||
# Check if 'backup' VG is active
|
||||
try:
|
||||
result = subprocess.run(
|
||||
["vgdisplay", "-cA"],
|
||||
stdout=subprocess.PIPE,
|
||||
stderr=subprocess.PIPE,
|
||||
text=True,
|
||||
check=True
|
||||
)
|
||||
vgdisplay_output = result.stdout.strip().split("\n")
|
||||
print(f"vgdisplay: {vgdisplay_output}")
|
||||
backup_present = any(line.split(":")[0].strip() == "backup" for line in vgdisplay_output)
|
||||
print(f"backup VG active? {backup_present}")
|
||||
if not backup_present:
|
||||
try:
|
||||
print(f"Activating VG backup")
|
||||
subprocess.run(["vgchange", "-ay", "backup"], check=True)
|
||||
except subprocess.CalledProcessError as e:
|
||||
print(f"Error executing vgchange: {e.stderr}")
|
||||
exit(1)
|
||||
except subprocess.CalledProcessError as e:
|
||||
print(f"Error executing vgdisplay: {e.stderr}")
|
||||
exit(1)
|
||||
else:
|
||||
# OFF case: Only execute if nothing is mounted
|
||||
if not running_units:
|
||||
print(f"Turning backup Disk OFF")
|
||||
subprocess.run(["sync"], check=True)
|
||||
try:
|
||||
subprocess.run(["vgchange", "-an", "backup"], check=True)
|
||||
except subprocess.CalledProcessError as e:
|
||||
print(f"Error executing vgchange: {e.stderr}")
|
||||
exit(1)
|
||||
send_mqtt_message("switch_backup/switch/switch_backup_power/command", "off")
|
||||
11
roles/backup_server/files/backup-disk-onoff@.service
Normal file
11
roles/backup_server/files/backup-disk-onoff@.service
Normal file
@@ -0,0 +1,11 @@
|
||||
[Unit]
|
||||
Description=Backup Disk %I
|
||||
After=network.target
|
||||
|
||||
[Service]
|
||||
Type=oneshot
|
||||
ExecStart=/usr/local/bin/backup-disk-onoff.py %I
|
||||
RemainAfterExit=yes
|
||||
|
||||
[Install]
|
||||
WantedBy=timers.target
|
||||
2
roles/backup_server/meta/main.yaml
Normal file
2
roles/backup_server/meta/main.yaml
Normal file
@@ -0,0 +1,2 @@
|
||||
dependencies:
|
||||
- _handlers
|
||||
@@ -1,3 +1,9 @@
|
||||
- name: Additional packages
|
||||
apt:
|
||||
state: present
|
||||
name:
|
||||
- python3-paho-mqtt
|
||||
|
||||
|
||||
- name: Generate Automounts
|
||||
include_role:
|
||||
@@ -12,7 +18,8 @@
|
||||
Type: btrfs
|
||||
Options: defaults,compress=lzo,space_cache=v2
|
||||
Unit:
|
||||
After: network.target
|
||||
After: network.target backup-disk-onoff@on.service
|
||||
Requires: backup-disk-onoff@on.service
|
||||
Install:
|
||||
WantedBy: network.target
|
||||
catena_automount:
|
||||
@@ -35,28 +42,33 @@
|
||||
loop_var: mount_point
|
||||
|
||||
|
||||
|
||||
# [Unit]
|
||||
# Description=Automount /backup/yori
|
||||
# After=network.target
|
||||
|
||||
# [Automount]
|
||||
# Where=/backup/yori
|
||||
# TimeoutIdleSec=30
|
||||
|
||||
# [Install]
|
||||
# WantedBy=network.target
|
||||
# [Unit]
|
||||
# Description=Mount /backup/yori
|
||||
# After=network.target
|
||||
# #Requires=backup-yori.automount
|
||||
# #After=backup-yori.automount
|
||||
|
||||
# [Mount]
|
||||
# What=/dev/backup/yori
|
||||
# Where=/backup/yori
|
||||
# Type=btrfs
|
||||
# Options=defaults,compress=lzo,space_cache=v2
|
||||
|
||||
# [Install]
|
||||
# WantedBy=network.target
|
||||
- name: BackupDisk On/Off service
|
||||
block:
|
||||
- name: Copy Script
|
||||
copy:
|
||||
src: backup-disk-onoff.py
|
||||
dest: /usr/local/bin/backup-disk-onoff.py
|
||||
mode: 0755
|
||||
owner: root
|
||||
group: root
|
||||
- name: Install Unit file
|
||||
notify: reload systemd
|
||||
copy:
|
||||
src: backup-disk-onoff@.service
|
||||
dest: /etc/systemd/system/backup-disk-onoff@.service
|
||||
owner: root
|
||||
group: root
|
||||
- name: Create a timer to turn OFF the Disk
|
||||
notify: reload systemd
|
||||
copy:
|
||||
src: backup-disk-off.timer
|
||||
dest: /etc/systemd/system/backup-disk-off.timer
|
||||
owner: root
|
||||
group: root
|
||||
- name: Enable timer and start it
|
||||
ansible.builtin.systemd_service:
|
||||
name: backup-disk-off.timer
|
||||
enabled: true
|
||||
state: started
|
||||
|
||||
|
||||
Reference in New Issue
Block a user