监控

eda/smart_rank/spark_streaming_monitor.py

@@ -19,7 +19,7 @@ while True:
                 batch_time = batch['batchTime']
                 GMT_FORMAT = '%Y-%m-%dT%H:%M:%S.000GMT'
                 batch_time_beijing = datetime.datetime.strptime(batch_time, GMT_FORMAT) + datetime.timedelta(hours=8)
-                send_email("画像增量更新堆积时间", "堆积时刻：" + str(batch_time_beijing) + "堆积时长:" + str(batch['totalDelay']))
+                send_email("画像增量更新堆积时间", "堆积时刻：" + str(batch_time_beijing) + "堆积时长:" + str(batch['totalDelay']), "")
                 is_email = 1
             f.write('%s\n' % batch)
     time.sleep(1800)