in src/main/python/s3mper.py [0:0]
def __send_alert(self, paths, detail={}):
if self.disable_alerts:
return
try:
body = {
"truncated": detail.get('truncated', False),
"paths": paths if len(paths) <= 10 else paths[0:9],
"recovered": detail.get('recovered', False),
"missingFiles": len(paths),
"stackTrace": traceback.extract_stack(),
"timestamp": "%s"%datetime.utcnow(),
"queryId": detail.get('',None),
"taskId": detail.get('',None),
"hostname": platform.node(),
"username": getpass.getuser(),
"queryType": "DSE Platform Lib",
"jobId": detail.get('jobId',None),
"attemptId": detail.get('attemptId',None),
"email": detail.get('email',None),
"dataovenId": detail.get('dataovenId',None),
"logFile": detail.get('logFile',None),
"inputFile": detail.get('inputFile',None),
"genieId": detail.get('genieId',None),
"epoch": self.__time_now()
}
message = RawMessage()
message.set_body(body)
conn = sqs.connect_to_region("us-east-1")
queue = conn.get_queue('s3mper-alert-queue')
queue.write(message)
except Exception as e:
print e