Commit 42420469 by 宋鹏博

修改监控阈值

parent 7d6f8b69
...@@ -44,11 +44,12 @@ def mk_error_message(error_editor, error_answer, message_id, url=wechaturl): ...@@ -44,11 +44,12 @@ def mk_error_message(error_editor, error_answer, message_id, url=wechaturl):
requests.post(url, json=data) requests.post(url, json=data)
def task_count(semantics_task_count, ideology_task_count, url=wechaturl): def task_count(semantics_task_count, ideology_task_count, validate_logic_task_count, knowledge_task_count,
url=wechaturl):
data = { data = {
"msgtype": "markdown", "msgtype": "markdown",
"markdown": { "markdown": {
"content": f"审校任务排队情况<font color=\"warning\">异常</font>,请相关同事注意。\n>语义任务:<font color=\"comment\">{semantics_task_count}</font>\n内容风险任务:<font color=\"comment\">{ideology_task_count}</font> " "content": f"审校任务排队情况<font color=\"warning\">异常</font>,请相关同事注意。\n>语义任务:<font color=\"comment\">{semantics_task_count}</font>\n内容风险任务:<font color=\"comment\">{ideology_task_count}</font>\n逻辑检查任务:<font color=\"comment\">{validate_logic_task_count}</font>\n知识性差错任务:<font color=\"comment\">{knowledge_task_count}</font> "
} }
} }
requests.post(url, json=data) requests.post(url, json=data)
...@@ -72,10 +73,15 @@ def ws_error(minute, error_answer_list=error_answer): ...@@ -72,10 +73,15 @@ def ws_error(minute, error_answer_list=error_answer):
def aireview_task(): def aireview_task():
semantics_task_count = DButils_aireview().select_sql( semantics_task_count = DButils_aireview().select_sql(
"select count(*) from aireview.semantics_task where status = 0;") "select count(*) from aireview.semantics_task where create_time >date(now()) and status = 0;")
ideology_task_count = DButils_aireview().select_sql("select count(*) from aireview.ideology_task where status = 0;") ideology_task_count = DButils_aireview().select_sql("select count(*) from aireview.ideology_task where "
if semantics_task_count[0][0] > 60000 or ideology_task_count[0][0] > 20000: "create_time >date(now()) and status = 0;")
task_count(semantics_task_count[0][0], ideology_task_count[0][0], url=aireview_task_url)
validate_logic_task_count = DButils_aireview().select_sql(
"select count(*) from aireview.validate_logic_task where create_time >date(now()) and status =0;")
knowledge_task_count = DButils_aireview().select_sql(
"select count(*) from aireview.knowledge_task kt2 where create_time >date(now()) and status =0;")
if semantics_task_count[0][0] > 60000 or ideology_task_count[0][0] > 20000 or validate_logic_task_count[0][0]>20000 or knowledge_task_count[0][0]>20000:
task_count(semantics_task_count[0][0], ideology_task_count[0][0],validate_logic_task_count[0][0],knowledge_task_count[0][0], url=aireview_task_url)
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment