cov.py

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

# Import this to get our "chunked" handler
from cexc import BaseChunkHandler

import pandas as pd

class Handler(BaseChunkHandler):
    def handler(self, metadata, data):
        """Get covariance matrix from a pandas dataframe"""
        df = pd.DataFrame(data, dtype='float').cov()
        df['(field)'] = df.columns

        output = df.to_dict(orient='records')

        # return the data
        return({}, output)

if __name__ == "__main__":
    Handler().run()