sh 领事事件壳模板

Posted 2021-05-07

#!/bin/sh
    response=$(cat -)
    payload=$(echo $response | sed -e 's/^.*"Payload":"\([^"]*\)".*$/\1/')
    # action string "runme" == byte "cnVubWU=" , replace "runme" with your payload data

    if [ "$payload" == "cnVubWU=" ]; then
      sudo /bin/service stop mysql
    else
      logger skipping mysql stop, consul triggered by payload $payload
    fi

#!/bin/sh
#https://github.com/sequenceiq/docker-consul-watch-plugn/blob/master/consul-event-handler.sh

: ${LOGFILE:=/var/log/consul-watch/consul_handler.log}
: ${CONSUL_HOST:=127.0.0.1}
: ${CONSUL_HTTP_PORT:=8500}
: ${DEBUG:=1}

[[ "TRACE" ]] && set -x

debug(){
  [[ "$DEBUG" ]] && echo "[DEBUG] $(date) $*" >> $LOGFILE
}

error(){
  echo "[ERROR] $(date) $*" >> $LOGFILE
}

get_field() {
  declare json="$1"
  declare field="$2"

  echo "$json"|jq ".$field" -r
}

__envVars() {
  declare eventId=$1
  declare ltime=$2
  declare version=$3

  echo "EVENT_ID=$eventId \
    EVENT_LTIME=$ltime \
    EVENT_VERSION=$version \
    CONSUL_HOST=$CONSUL_HOST \
    CONSUL_HTTP_PORT=$CONSUL_HTTP_PORT \
    LOGFILE=$LOGFILE"
}

__executeScript() {
  declare envVars=$1
  declare eventSpecPayload=$2
  declare scriptFile=$(echo $eventSpecPayload | cut -d" " -f 1)

  debug "execute $scriptFile..."
  eval $envVars \
    PAYLOAD=\"$(echo $eventSpecPayload  | cut -d" " -f 2-)\" \
    $scriptFile
}

__downloadAndExecuteScript() {
  declare envVars=$1
  declare eventSpecPayload=$2
  declare url=$(echo $eventSpecPayload | cut -d" " -f 1)
  declare scriptfile="/tmp/consulevent-$RANDOM.sh"

  debug "execute script from $url url locally..."
  curl -Lko $scriptfile $url
  chmod +x $scripfile

  debug "execute downloaded script $scriptFile..."
  eval $envVars \
    PAYLOAD=\"$(echo $eventSpecPayload  | cut -d" " -f 2-)\" \
    $scriptFile
}
__updateState() {
  let tries=12
  while [ $tries != 0 ]; do
    tries=$((tries-1))
    curl -X PUT -d "$2" -f "http://$CONSUL_HOST:$CONSUL_HTTP_PORT/v1/kv/events/$1/$(__getHostName)"
    [[ $? == 0 ]] && break
    [[ $? != 0 ]] && [[ $tries != 0 ]] && sleep 5
  done
}
process_json() {
  while read json; do
    if [[ -z $json ]]; then
      debug "json is missing (processing)"
    fi

    event=$(get_field $json Name)
    id=$(get_field $json ID)
    payload=$(get_field $json Payload | base64 -d)
    ltime=$(get_field $json LTime)
    version=$(get_field $json Version)
    eventtype=$(echo $payload | cut -d" " -f 1)
    eventSpecPayload=$(echo $payload | cut -d" " -f 2-)
    cmdEnvVars=$(__envVars $id $ltime $version)

    debug "event=$event, id=$id, payload=$payload, eventtype=$eventtype, specPayload=$eventSpecPayload"
    if [[ -z $id ]]; then
      debug "eventid is missing, skip processing"
      continue
    fi

    __updateState $id 'ACCEPTED'

#    case "$eventtype" in
     # EXEC)
     #   __executeScript "$cmdEnvVars" "$eventSpecPayload" ;;
     # DOWNLOAD_AND_EXEC)
     #   __downloadAndExecuteScript "$cmdEnvVars" "$eventSpecPayload" ;;
     # EXEC_IN_CONTAINER)
     #   __executeScriptInContainer "$cmdEnvVars" "$eventSpecPayload" ;;
     # TRIGGER_PLUGN)
     #   __triggerPlugin "$cmdEnvVars" "$eventSpecPayload" ;;
     # TRIGGER_PLUGN_IN_CONTAINER)
     #   __triggerPluginInContainer "$cmdEnvVars" "$eventSpecPayload" ;;
#    esac

# DO THE JOB

    if [ $? -eq 0 ]; then
      debug "$eventtype finished successfully"
      __updateState $id 'FINISHED'
    else
      error "$eventtype failed to finish successfully"
      __updateState $id 'FAILED'
    fi
  done
}

main() {
  while read array; do
    [[ -n $array ]] && echo $array | jq .[] -c | process_json
  done
}

[[ "$0" == "$BASH_SOURCE" ]] && main "$@"