add succesd Mail - add all Tables to Feedback

mysql_timestamp_check.py

@@ -1,7 +1,9 @@
 #!/usr/bin/env python3
+# -*- coding: utf-8 -*-
 import mysql.connector
 import datetime
 import smtplib
+import ssl
 from email.mime.text import MIMEText
 from email.mime.multipart import MIMEMultipart
 import argparse
@@ -12,7 +14,7 @@ from dotenv import load_dotenv
 
 def get_tables_from_db(connection):
     """
-    Holt die Liste der zu überprüfenden Tabellen, die 'RAW.' im Namen enthalten
+    Holt die Liste der zu überprüfenden Tabellen, die 'history.' im Namen enthalten
 
     Returns:
         list: Liste der Tabellennamen
@@ -25,14 +27,14 @@ def get_tables_from_db(connection):
         tables = []
 
         for (table,) in cursor.fetchall():
-            if 'RAW.' in table:
+            if 'history.' in table:
                 # Tabellennamen mit Backticks versehen
                 tables.append(f"Kunden.`{table}`")
 
         cursor.close()
 
         if not tables:
-            print("Warnung: Keine Tabellen gefunden, die 'RAW.' enthalten.")
+            print("Warnung: Keine Tabellen gefunden, die 'history.' enthalten.")
         else:
             print(f"Gefundene zu überprüfende Tabellen: {', '.join(tables)}")
 
@@ -46,7 +48,9 @@ def check_timestamp(connection, tables, timestamp_column, email_config, test_mod
     """
     Überprüft, ob der letzte Zeitstempel in jeder angegebenen Tabelle von gestern ist.
     Sendet eine E-Mail mit den Namen der Tabellen, die nicht aktuell sind oder
-    gibt die Nachricht auf der Konsole aus, wenn test_mode=True.
+    eine Bestätigungsmail, wenn alle Tabellen aktuell sind. Im Erfolgsfall wird
+    auch die Liste der geprüften Tabellen mit aufgeführt.
+    Im Testmodus wird nur auf der Konsole ausgegeben.
     """
     cursor = connection.cursor()
 
@@ -81,36 +85,46 @@ def check_timestamp(connection, tables, timestamp_column, email_config, test_mod
 
         except mysql.connector.Error as err:
             print(f"Fehler beim Überprüfen der Tabelle {table}: {err}")
-            outdated_tables.append(f"{table} (Fehler: {err}")
+            outdated_tables.append(f"{table} (Fehler: {err})")
 
     # Cursor schließen
     cursor.close()
 
-    # Wenn es nicht aktuelle Tabellen gibt, sende eine E-Mail oder gib Meldung aus
+    # E-Mail Inhalt und Betreff anpassen, je nachdem ob es fehlerhafte Tabellen gibt oder nicht
     if outdated_tables:
-        if test_mode:
-            print("\n--- TEST MODUS: E-Mail würde gesendet werden ---")
-            print(f"Betreff: Warnung: Nicht aktuelle Tabellen in Datenbank {database}")
-            print("Inhalt:")
-            print("Hallo,")
-            print(
-                f"\ndie folgenden Tabellen in der Datenbank '{database}' haben keinen aktuellen Zeitstempel von gestern:")
-            for table in outdated_tables:
-                print(f"- {table}")
-            print("\nBitte überprüfen Sie diese Tabellen.")
-            print("\nDies ist eine automatisch generierte Nachricht.")
-            print("--- ENDE TEST MODUS ---\n")
-        else:
-            send_email(outdated_tables, database, email_config)
-        return False
+        subject = f"Warnung: Nicht aktuelle Tabellen in Datenbank {database}"
+        body_intro = (
+            f"Hallo,\n\n"
+            f"die folgenden Tabellen in der Datenbank '{database}' haben keinen aktuellen Zeitstempel von gestern:\n"
+        )
+        body_tables = "\n".join(f"- {table}" for table in outdated_tables)
+        body_footer = "\n\nBitte überprüfen Sie diese Tabellen.\n\nDies ist eine automatisch generierte Nachricht."
     else:
-        print("Alle Tabellen sind aktuell.")
-        return True
+        subject = f"Bestätigung: Alle Tabellen in Datenbank {database} sind aktuell"
+        body_intro = (
+            f"Hallo,\n\n"
+            f"alle zu überprüfenden Tabellen in der Datenbank '{database}' enthalten aktuelle Zeitstempel von gestern.\n\n"
+            "Folgende Tabellen wurden überprüft:\n"
+        )
+        body_tables = "\n".join(f"- {table}" for table in tables)
+        body_footer = "\n\nDies ist eine automatisch generierte Nachricht."
+
+    # Wenn Testmodus aktiviert, Ausgabe auf Konsole
+    if test_mode:
+        print("\n--- TEST MODUS: E-Mail würde gesendet werden ---")
+        print(f"Betreff: {subject}")
+        print("Inhalt:")
+        print(body_intro + body_tables + body_footer)
+        print("--- ENDE TEST MODUS ---\n")
+    else:
+        send_email(subject, body_intro, body_tables, body_footer, email_config)
+
+    return not outdated_tables
 
 
-def send_email(outdated_tables, database, email_config):
+def send_email(subject, body_intro, body_tables, body_footer, email_config):
     """
-    Sendet eine E-Mail mit der Liste der nicht aktuellen Tabellen.
+    Sendet eine E-Mail mit dem angegebenen Betreff und Inhalt.
     """
     sender_email = email_config["sender"]
     receiver_email = email_config["receiver"]
@@ -123,27 +137,19 @@ def send_email(outdated_tables, database, email_config):
     message = MIMEMultipart()
     message["From"] = sender_email
     message["To"] = receiver_email
-    message["Subject"] = f"Warnung: Nicht aktuelle Tabellen in Datenbank {database}"
-
-    # E-Mail-Inhalt
-    body = f"""
-    Hallo,
-
-    die folgenden Tabellen in der Datenbank '{database}' haben keinen aktuellen Zeitstempel von gestern:
-
-    {chr(10).join('- ' + table for table in outdated_tables)}
-
-    Bitte überprüfen Sie diese Tabellen.
-
-    Dies ist eine automatisch generierte Nachricht.
-    """
+    message["Subject"] = subject
 
+    # E-Mail-Inhalt zusammenfügen
+    body = f"{body_intro}{chr(10) if body_tables else ''}{body_tables}{body_footer}"
     message.attach(MIMEText(body, "plain"))
 
     try:
-        # Verbindung zum SMTP-Server herstellen
+        # Verbindung zum SMTP-Server herstellen mit TLS
+        context = ssl.create_default_context()
         server = smtplib.SMTP(smtp_server, smtp_port)
-        server.starttls()  # TLS-Verschlüsselung aktivieren
+        server.ehlo()
+        server.starttls(context=context)
+        server.ehlo()
 
         # Anmelden (falls erforderlich)
         if smtp_password:
@@ -198,8 +204,7 @@ def main():
 
     # Prüfe, ob erforderliche DB-Parameter vorhanden sind
     if not user or not password or not database:
-        print(
-            "Fehler: MySQL-Benutzer, Passwort und Datenbankname müssen entweder in der .env-Datei oder als Parameter angegeben werden!")
+        print("Fehler: MySQL-Benutzer, Passwort und Datenbankname müssen entweder in der .env-Datei oder als Parameter angegeben werden!")
         sys.exit(1)
 
     # Verbindung zur Datenbank herstellen
@@ -230,12 +235,11 @@ def main():
     # Wenn nicht im Testmodus, prüfe ob E-Mail-Parameter angegeben wurden
     if not test_mode:
         if not email_config["sender"] or not email_config["receiver"]:
-            print(
-                "Fehler: E-Mail-Absender und -Empfänger müssen entweder in der .env-Datei oder als Parameter angegeben werden!")
+            print("Fehler: E-Mail-Absender und -Empfänger müssen entweder in der .env-Datei oder als Parameter angegeben werden!")
             connection.close()
             sys.exit(1)
 
-    # Tabellen aus der Datenbanktabelle holen
+    # Tabellen aus der Datenbank holen
     tables = get_tables_from_db(connection)
 
     if not tables:
@@ -247,7 +251,7 @@ def main():
     timestamp_column = args.timestamp_column
     print(f"Überprüfe Zeitstempel in Spalte: {timestamp_column}")
 
-    # Timestamp-Überprüfung durchführen
+    # Timestamp-Überprüfung durchführen und entsprechende E-Mail senden
     check_timestamp(
         connection,
         tables,

run_timestamp_check.sh

@@ -10,13 +10,56 @@ SCRIPT_DIR="$( cd "$( dirname "${BASH_SOURCE[0]}" )" &> /dev/null && pwd )"
 # Log-Datei
 LOG_FILE="${SCRIPT_DIR}/timestamp_check_$(date +%Y-%m-%d).log"
 
-# Python-Umgebung aktivieren (falls eine virtuelle Umgebung verwendet wird)
-# Auskommentieren, wenn keine virtuelle Umgebung verwendet wird
-# source "${SCRIPT_DIR}/venv/bin/activate"
+# Pushover-Konfiguration
+# Diese Werte sollten in einer separaten Konfigurationsdatei gesetzt oder
+# als Umgebungsvariablen bereitgestellt werden
+PUSHOVER_USER_KEY="uo2sf2pmrtjvt8auu786fviabimimr"  # Dein User Key
+PUSHOVER_API_TOKEN="awe7dpqsh73muuk12qwa4pk5eie99y"  # Dein API Token/Application Key
+
+# Funktion zum Senden von Pushover-Benachrichtigungen
+send_pushover() {
+    local title="$1"
+    local message="$2"
+    local priority="${3:-0}"  # 0 ist normale Priorität, 1 ist hoch, 2 ist Notfall
+
+    # Überprüfen, ob CURL installiert ist
+    if ! command -v curl &> /dev/null; then
+        echo "WARNUNG: curl ist nicht installiert. Pushover-Benachrichtigung kann nicht gesendet werden." | tee -a "$LOG_FILE"
+        return 1
+    fi
+
+    # Überprüfen, ob Pushover-Schlüssel konfiguriert sind
+    if [[ "$PUSHOVER_USER_KEY" == "dein-user-key" || "$PUSHOVER_API_TOKEN" == "dein-api-token" ]]; then
+        echo "WARNUNG: Pushover-Schlüssel sind nicht konfiguriert. Benachrichtigung nicht gesendet." | tee -a "$LOG_FILE"
+        return 1
+    fi
+
+    # Senden der Pushover-Benachrichtigung
+    curl -s \
+        --form-string "token=$PUSHOVER_API_TOKEN" \
+        --form-string "user=$PUSHOVER_USER_KEY" \
+        --form-string "title=$title" \
+        --form-string "message=$message" \
+        --form-string "priority=$priority" \
+        https://api.pushover.net/1/messages.json >/dev/null
+
+    local result=$?
+    if [ $result -eq 0 ]; then
+        echo "Pushover-Benachrichtigung gesendet: $title" | tee -a "$LOG_FILE"
+    else
+        echo "Fehler beim Senden der Pushover-Benachrichtigung (Fehlercode: $result)" | tee -a "$LOG_FILE"
+    fi
+
+    return $result
+}
 
 # Start des Skripts loggen
 echo "$(date +"%Y-%m-%d %H:%M:%S") - Starte MySQL Timestamp Check" | tee -a "$LOG_FILE"
 
+# Python-Umgebung aktivieren (falls eine virtuelle Umgebung verwendet wird)
+# Auskommentieren, wenn keine virtuelle Umgebung verwendet wird
+# source "${SCRIPT_DIR}/venv/bin/activate"
+
 # Zum Skriptverzeichnis wechseln
 cd "$SCRIPT_DIR"
 
@@ -26,10 +69,7 @@ cd "$SCRIPT_DIR"
 # --timestamp-column=spaltenname: falls andere Spalte als add_date verwendet werden soll
 
 # Normale Ausführung
-python mysql_timestamp_check.py 2>&1 | tee -a "$LOG_FILE"
-
-# Testmodus (auskommentiert)
-# python mysql_timestamp_check.py --test 2>&1 | tee -a "$LOG_FILE"
+python3 mysql_timestamp_check.py 2>&1 | tee -a "$LOG_FILE"
 
 # Exit-Code des Python-Skripts erhalten
 EXIT_CODE=${PIPESTATUS[0]}
@@ -37,10 +77,23 @@ EXIT_CODE=${PIPESTATUS[0]}
 # Ende des Skripts loggen
 echo "$(date +"%Y-%m-%d %H:%M:%S") - MySQL Timestamp Check beendet (Exit-Code: $EXIT_CODE)" | tee -a "$LOG_FILE"
 
-# E-Mail bei Fehler im Skript selbst (nicht bei fehlenden Daten, da das Python-Skript dies bereits handhabt)
-if [ $EXIT_CODE -ne 0 ] && [ $EXIT_CODE -ne 1 ]; then
-    # Hier kann optional eine E-Mail für Fehler im Skript selbst gesendet werden
-    echo "Fehler beim Ausführen des Timestamp-Check-Skripts. Bitte überprüfen Sie die Log-Datei $LOG_FILE" | tee -a "$LOG_FILE"
+# Benachrichtigung bei Fehlern im Skript selbst oder wenn Python wegen nicht aktueller Tabellen mit Exit-Code 1 beendet wurde
+if [ $EXIT_CODE -ne 0 ]; then
+    # Art des Fehlers ermitteln
+    if [ $EXIT_CODE -eq 1 ]; then
+        # Exit-Code 1 = Nicht aktuelle Tabellen gefunden (E-Mail wurde bereits vom Python-Skript gesendet)
+        PUSHOVER_TITLE="MySQL Timestamp Check: Nicht aktuelle Tabellen"
+        PUSHOVER_MESSAGE="Einige Tabellen haben keine Daten von gestern. Details wurden per E-Mail gesendet."
+        PUSHOVER_PRIORITY=1  # Höhere Priorität
+    else
+        # Andere Exit-Codes = Fehler im Skript selbst
+        PUSHOVER_TITLE="MySQL Timestamp Check: Fehler im Skript"
+        PUSHOVER_MESSAGE="Fehler beim Ausführen des Timestamp-Check-Skripts (Exit-Code: $EXIT_CODE). Bitte überprüfen Sie die Log-Datei."
+        PUSHOVER_PRIORITY=2  # Notfall-Priorität
+    fi
+
+    # Pushover-Benachrichtigung senden
+    send_pushover "$PUSHOVER_TITLE" "$PUSHOVER_MESSAGE" "$PUSHOVER_PRIORITY"
 fi
 
 exit $EXIT_CODE