deploy.sh for automated deployment of flows via NiFi Registry scripted hook

deploy.sh

#!/bin/bash

LOG="/hadoopfs/fs1/automation/nifi-cli.log"

echo $@ >> $LOG

EVENT=$1
BUCKET=$2
FLOW=$3
VERSION=$4
AUTHOR=$5
COMMENT="${@:6}"

# We want to do something only when a new version of a flow is being versioned
if [[ "$EVENT" == "CREATE_FLOW_VERSION" ]]; then

  # We want to deploy in production only when the comment contains the keyword "PRODREADY"
  if [[ "$COMMENT" == *"PRODREADY"* ]]; then

    PG=`grep $FLOW /hadoopfs/fs1/automation/mapping.tsv | awk '{print $2}'`
    # echo "Process Group - " $PG >> $LOG
    PCP=`grep $FLOW /hadoopfs/fs1/automation/mapping.tsv | awk '{print $3}'`
    # echo "Parameter Context Provider - " $PCP >> $LOG

    # Upgrade the flow to the latest version
    /opt/cloudera/parcels/CFM/TOOLKIT/bin/cli.sh nifi pg-change-version --processGroupId $PG  >> $LOG

    # Refresh everything with the Parameter Context Provider
    /opt/cloudera/parcels/CFM/TOOLKIT/bin/cli.sh nifi fetch-params --paramProviderId $PCP --applyParameters --sensitiveParamPattern "sens_.*" >> $LOG

    # Start associated controller services in the process group
    /opt/cloudera/parcels/CFM/TOOLKIT/bin/cli.sh nifi pg-enable-services --processGroupId $PG >> $LOG

    # Start the process group
    /opt/cloudera/parcels/CFM/TOOLKIT/bin/cli.sh nifi pg-start --processGroupId $PG >> $LOG

  fi
fi