diff --git a/SnowflakeTraffic.sh b/SnowflakeTraffic.sh index 0cc93e4..261b71b 100644 --- a/SnowflakeTraffic.sh +++ b/SnowflakeTraffic.sh @@ -8,7 +8,6 @@ END_DATE="${2:-}" # Validierung der Datumseingaben validate_date() { local date="$1" - [[ -z "$date" ]] && return 0 if [[ ! "$date" =~ ^[0-9]{4}-[0-9]{2}-[0-9]{2}$ ]]; then echo "Fehler: Ungültiges Datumsformat für '$date' (erwartet: YYYY-MM-DD)" >&2 exit 1 @@ -18,81 +17,60 @@ validate_date() { validate_date "$START_DATE" validate_date "$END_DATE" +# Extrahiere und konvertiere Docker Logs mit awk docker logs snowflake-proxy 2>&1 | awk -v start_date="$START_DATE" -v end_date="$END_DATE" ' -function human_readable(kb, units, size, i) { - split("KB MB GB TB PB", units) +function human_readable(kb) { + units = split("KB MB GB TB PB", unit_array) size = kb - for (i = 1; size >= 1024 && i <= length(units); i++) { - size = size / 1024 + for (i = 1; size >= 1024 && i < units; i++) { + size /= 1024 } - return sprintf("%.2f %s", size, units[i]) + return sprintf("%.2f %s", size, unit_array[i]) } -function date_to_epoch(date_str, parts) { - if (split(date_str, parts, /[-\/]/) != 3) return -1 - if (parts[1] < 1970 || parts[2] < 1 || parts[2] > 12 || parts[3] < 1 || parts[3] > 31) return -1 - return mktime(parts[1] " " parts[2] " " parts[3] " 00 00 00") +function date_to_epoch(date_str) { + if (split(date_str, parts, /[-\/]/) != 3 || parts[1] < 1970 || + parts[2] < 1 || parts[2] > 12 || parts[3] < 1 || parts[3] > 31) + return -1 + return mktime(parts[1]" "parts[2]" "parts[3]" 00 00 00") } BEGIN { - if (start_date != "" && date_to_epoch(start_date) == -1) { - print "Ungültiges Startdatum Format" > "/dev/stderr" + if (start_date != "" && date_to_epoch(start_date) == -1 || + end_date != "" && date_to_epoch(end_date) == -1) exit 1 - } - if (end_date != "" && date_to_epoch(end_date) == -1) { - print "Ungültiges Enddatum Format" > "/dev/stderr" - exit 1 - } } - { - include_line = 0 # Zurücksetzen bei jeder neuen Zeile - + include_line = 0 + # Datumserkennung und Formatierung if (match($0, /([0-9]{4}[-\/][0-9]{2}[-\/][0-9]{2})/, date_match)) { current_date = date_match[1] gsub(/[\/]/, "-", current_date) # Standardisiert auf YYYY-MM-DD - - if (!first_date) first_date = current_date + + first_date = first_date == "" ? current_date : first_date last_date = current_date - + current_epoch = date_to_epoch(current_date) - if (current_epoch == -1) next # Ungültiges Datum überspringen - - include_line = 1 - - if (start_date != "") { - start_epoch = date_to_epoch(start_date) - if (current_epoch < start_epoch) include_line = 0 - } - - if (end_date != "" && include_line) { - end_epoch = date_to_epoch(end_date) - if (current_epoch > end_epoch) include_line = 0 - } + if (current_epoch != -1 && ( + start_date == "" || date_to_epoch(start_date) <= current_epoch) && + (end_date == "" || end_date >= current_epoch)) + include_line = 1 } } - include_line && /Traffic Relayed ↓ [0-9]+ KB .*↑ [0-9]+ KB/ { - # Sicherere Extraktion der Werte mit regulären Ausdrücken if (match($0, /↓ ([0-9]+) KB.*↑ ([0-9]+) KB/, traffic)) { down += traffic[1] up += traffic[2] } } - END { - printf "Statistik-Zeitraum:\n" - printf "Erster Eintrag: %s\n", first_date - printf "Letzter Eintrag: %s\n", last_date - + printf "Statistik-Zeitraum:\nErster Eintrag: %s\nLetzter Eintrag: %s\n", first_date, last_date if (start_date != "" || end_date != "") { - printf "Gefilterter Bereich: %s bis %s\n\n", - (start_date != "" ? start_date : "Anfang"), - (end_date != "" ? end_date : "Ende") + printf "\nGefilterter Bereich: %s bis %s\n", + start_date == "" ? "Anfang" : start_date, + end_date == "" ? "Ende" : end_date } - - printf "\nGesamte Datenmengen:\n" - printf "Download: %d KB (%s)\n", down, human_readable(down) - printf "Upload: %d KB (%s)\n", up, human_readable(up) -}' \ No newline at end of file + printf "\nGesamte Datenmengen:\nDownload: %d KB (%s)\nUpload: %d KB (%s)\n", down, human_readable(down), up, human_readable(up) +} +' \ No newline at end of file