import os import sys, traceback import json def run_script(): out.println("Partitioner JS Started!"); out.println("NumReducers: " + str(numReducers)) doc = None try: doc = json.loads(iValue) except Exception as err: message = "\n\nEXCEPTION INFO:" exc_type, exc_value, exc_traceback = sys.exc_info() tb_list = traceback.format_tb(exc_traceback, 6) errmessage = str(exc_value) stacktrace = "Error: %s \nTraceback:" % (exc_type.__name__) for stk in tb_list: stacktrace += stk for rec in err.args: message += "\nMessage: " + str(rec) message += "\nStack: " + str(stacktrace) out.println("Error Parsing Log: " + message) date = str(doc["Defaults"]["DateTime"]["value"]) day = int(date[8:10]) reducerNum = 0 out.println(date) out.println(str(day)) if day < 10: reducerNum = 0 elif day > 10 and day <= 20: reducerNum = 1 % numReducers else: reducerNum = 2 % numReducers out.println("Partitioner JS Finished!") partitionNum = reducerNum if __name__ == '__main__': run_script()