corr_intersplunk.py

import splunk.Intersplunk 
import exec_anaconda
try:
    exec_anaconda.exec_anaconda()
except Exception as e:
    import cexc
    cexc.abort(e)
    sys.exit(1)

import sys
import csv
import pandas as pd

items = []
# read results
results = splunk.Intersplunk.readResults()
# normal dictionary, not ordered
d = [dict(r) for r in results]
df = pd.DataFrame(d, dtype='float')
c = df.corr()

output = c.to_dict('records')

for i, col in enumerate(c.columns):
  output[i]['field'] = col

splunk.Intersplunk.outputResults(output)

not so good because i had to loop back through to undo the ordered dictionary that splunk provides... there is probably a better way !