3 MR_HOSTPORT="$_MR_HOSTPORT"
5 LOGSTASH_URL="$_LOGSTASH_URL"
7 if ! jq --version > /dev/null 2&>1 ; then
9 apt-get install -y jq curl
13 echo "$MR_HOSTPORT $MR_TOPIC $LOGSTASH_URL"
16 # if dmaap returns single JSON structure
17 DATA=$(curl -s -H "Accept: application/json" -X GET http://${MR_HOSTPORT}/events/${MR_TOPIC}/elk-plotter/elk-plotter?timeout=60000)
18 DATA=$(echo $DATA| sed -e 's/\\"/"/g' -e 's/"{/{/g' -e 's/}"/}/g')
19 echo "Getting data: $DATA"
21 #VESEVENT=$(echo $DATA |jq -r '((.event.commonEventHeader.lastEpochMicrosec)|tostring) + "," + ((.event.measurementsForVfScalingFields.vNicUsageArray[0].receivedTotalPacketsDelta) | tostring)')
22 #curl -i -XPUT 'http://127.0.0.1:8080/onenumber/onenumebr' -d "${VESEVENT}"
24 # dmaap returns json array
25 # echo "Reading source: $.event.commonEventHeader.reportingEntityName"
26 source=$(echo $DATA |jq -r '.[] | ((.event.commonEventHeader.reportingEntityName) | tostring)')
27 echo "Source name: $source"
28 if [ "$source" == "GS_LITE MC" ]
30 DATA=$(echo $DATA |jq -r --arg source "$source" '.[] | $source+","+((.event.measurementsForVfScalingFields.additionalFields[1].value) | tostring)+ ","+ ((.event.measurementsForVfScalingFields.additionalFields[2].value) | tostring)')
31 #EVENTS=$(echo $DATA |jq -r '.event.measurementFields.additionalFields.SgNBRequestRate')
32 #for EVENT in $EVENTS; do
33 elif [ "$source" == "AC xAPP" ]
35 DATA=$(echo $DATA |jq -r --arg source "$source" '.[] | $source+","+((.event.measurementsForVfScalingFields.additionalFields[0].value) | tostring)')
37 DATA="No supportive reporting entity provided"
39 echo "Injecting VES event: $DATA"
40 curl -i -XPUT "${LOGSTASH_URL}" -d "${DATA}"