|
@@ -385,10 +385,10 @@ class BaseDataMonitor():
|
|
|
sentMsgToDD(_msg,ACCESS_TOKEN_DATAWORKS)
|
|
|
# sendEmail(smtp_host,smtp_username,smtp_password,self.recieviers,_msg)
|
|
|
|
|
|
- if total_count_to_dump>2000:
|
|
|
- _msg = "公告去重报警,待去重数量:%s"%(str(total_count_to_dump))
|
|
|
- sentMsgToDD(_msg,ACCESS_TOKEN_DATAWORKS)
|
|
|
- # sendEmail(smtp_host,smtp_username,smtp_password,self.recieviers,_msg)
|
|
|
+ # if total_count_to_dump>2000:
|
|
|
+ # _msg = "公告去重报警,待去重数量:%s"%(str(total_count_to_dump))
|
|
|
+ # sentMsgToDD(_msg,ACCESS_TOKEN_DATAWORKS)
|
|
|
+ # # sendEmail(smtp_host,smtp_username,smtp_password,self.recieviers,_msg)
|
|
|
|
|
|
#成品表监控
|
|
|
query = BoolQuery(must_queries=[
|
|
@@ -419,7 +419,7 @@ class BaseDataMonitor():
|
|
|
SearchQuery(query,None,True),
|
|
|
columns_to_get=ColumnsToGet(return_type=ColumnReturnType.NONE))
|
|
|
|
|
|
- if total_count>=200:
|
|
|
+ if total_count>=1000:
|
|
|
_msg = "数据流报警:待去重公告数为:%d"%(total_count)
|
|
|
sentMsgToDD(_msg,ACCESS_TOKEN_DATAWORKS)
|
|
|
# sendEmail(smtp_host,smtp_username,smtp_password,self.recieviers,_msg)
|