json-singlepull-transform-pipeline.py

# Single PRTG sensor transform pipeline

# 1) Pull JSON records from a monitoring system
# 2) Map Sensors of Interest to new preferred format
# 3) Drop JSON records behind a web service for consuming applications to pick up

import json
import sys
# import request   ... will be added to test urllib vs. request library
import urllib2
from pprint import pprint

# Retrieve and print static sensor

print('Test static single-sensor pipeline')
print('\nNative json response:\n')
macrosensor = json.load(urllib2.urlopen('https://serviceURL'))
print macrosensor
sensor = macrosensor['sensordata']

# Result contained the dictionary we wanted inside of another dictionary.  This extracts the dictionary we want.

print('\nExtract sensor dictionary\n')
print(sensor)


# Modify sensor to new format

dashboard_sensor = {
    'applicationIdentifier': sensor['probename'],
    'applicationCodes': [
        sensor['uptime'],
        sensor['downtime'],
        sensor['updownsince']
    ],
    'name': sensor['parentdevicename'],
    'status': 'PASS' if sensor['statustext'] == 'Up' else 'ERROR',
    'messages': [
        sensor['sensortype'],
    ]
}

# End of sensor processing


# Transformed sensor posting-Local feedback and file drop

print('\nSensor reformatted for new dashboard:\n')
pprint(dashboard_sensor)

filetag = dashboard_sensor['applicationIdentifier']

with open('%s.json' %filetag, 'wb') as json_data:
    json_data.write(json.dumps(dashboard_sensor))

print('\nPosted json file:')
print(filetag)


# -30-