docker-mysql-replication-monitor-fluentbit/monitor.sh at master · Geocodio/docker-mysql-replication-monitor-fluentbit · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
#!/bin/bash
## Based on original script by Joel Chaney, joel.chaney@mongoosemetrics.com, 2012-02-03

function send_status {
    STATUS="$*"

    echo "Sending status $STATUS"
    echo $STATUS | nc $FLUENTBIT_HOSTNAME $FLUENTBIT_PORT
}

function safe_command {
  typeset cmnd="$*"
  typeset ret_code

  eval $cmnd
  ret_code=$?
  if [ $ret_code != 0 ]; then
    printf "Error : [%d] when executing command: '$cmnd'" $ret_code
    STATUS="{\"success\": false, \"message\": \"Command failed with exit code $ret_code\"}"

    send_status $STATUS

    exit $ret_code
  fi
}

function extract_value {
    FILENAME=$1
    VAR=$2
    grep -w $VAR $FILENAME | cut -d ':' -f '2-'| awk '{$1=$1};1'
}

SLAVE_STATUS=/tmp/sstatus

SLAVE="mysql -u $MYSQL_USERNAME -p'$MYSQL_PASSWORD' -h $MYSQL_HOSTNAME"

MYSQL_STATUS_COMMAND="$SLAVE -e 'SHOW SLAVE STATUS\G' > $SLAVE_STATUS"
safe_command $MYSQL_STATUS_COMMAND

STATUS_FILESIZE=$(stat -c%s "$SLAVE_STATUS")

if [[ $STATUS_FILESIZE -lt 5 ]]
then
    STATUS="{\"success\": false, \"message\": \"SHOW SLAVE STATUS returned no data\"}"
    send_status $STATUS

    exit 1
fi

Master_Binlog=$(extract_value $SLAVE_STATUS Master_Log_File )
Master_Host=$(extract_value $SLAVE_STATUS Master_Host)
Master_Port=$(extract_value $SLAVE_STATUS Master_Port)
Master_Log_File=$(extract_value $SLAVE_STATUS Master_Log_File)
Slave_IO_Running=$(extract_value $SLAVE_STATUS Slave_IO_Running)
Slave_SQL_Running=$(extract_value $SLAVE_STATUS Slave_SQL_Running)
Slave_ERROR=$(extract_value $SLAVE_STATUS Last_Error)
Seconds_Behind_Master=$(extract_value $SLAVE_STATUS Seconds_Behind_Master)
Last_IO_Error=$(extract_value $SLAVE_STATUS Last_IO_Error)

ERROR_COUNT=0
ERRORS=""
if [[ "$Master_Binlog" != "$Master_Log_File" ]]
then
    ERRORS="master binlog ($Master_Binlog) and Master_Log_File ($Master_Log_File) differ|$ERRORS"
    ERROR_COUNT=$(($ERROR_COUNT+1))
fi

if [[ $Seconds_Behind_Master -gt 1000 ]]
then
    ERRORS="The slave is lagging behind of master by $Seconds_Behind_Master seconds|$ERRORS"
    ERROR_COUNT=$(($ERROR_COUNT+1))
fi

if [[ $Seconds_Behind_Master == "NULL" ]]
then
    Seconds_Behind_Master=9999999
    ERRORS="The slave lag is NULL, indicating an error|$ERRORS"
    ERROR_COUNT=$(($ERROR_COUNT+1))
fi

if [[ "$Slave_IO_Running" == "No" ]]
then
    ERRORS="Replication is stopped|$ERRORS"
    ERROR_COUNT=$(($ERROR_COUNT+1))
fi

if [[ "$Slave_SQL_Running" == "No" ]]
then
    ERRORS="Replication (SQL) is stopped|$ERRORS"
    ERROR_COUNT=$(($ERROR_COUNT+1))
fi

# Right trim the | character
ERRORS="${ERRORS%%|}"
JSON_ERRORS=$(echo $ERRORS | jq -R 'split("|")')
if [[ $ERROR_COUNT -gt 0 ]]
then
    MESSAGE="$Slave_ERROR$Last_IO_Error"
    MESSAGE=$(echo $MESSAGE | jq -R .)
    STATUS="{\"success\": false, \"position_lag\": $Seconds_Behind_Master, \"error_count\": $ERROR_COUNT, \"errors\": $JSON_ERRORS, \"message\": $MESSAGE}"
else
    STATUS="{\"success\": true, \"position_lag\": $Seconds_Behind_Master, \"error_count\": 0}"
fi

send_status $STATUS