updatePublishedMsgDaily.py

updateMinigramInfoDaily.py

@@ -275,6 +275,7 @@ class DailyDataManager(object):
             function="update_minigram_detail",
             message="获取前三天的 rootSourceId, 一共有 {} 条记录".format(len(source_id_list))
         )
+        fail_count = 0
         for item in tqdm(source_id_list):
             s_id = item[0]
             try:
@@ -310,8 +311,17 @@ class DailyDataManager(object):
                     task=TASK_NAME,
                     function="update_minigram_detail",
                     status="fail",
-                    message="更新单条数据失败， 报错信息是 {}".format(e)
+                    message="更新单条数据失败， 报错信息是 {}".format(e),
+                    data={"error_msg": traceback.format_exc()}
                 )
+                fail_count += 1
+        if fail_count:
+            bot(
+                title="{} fail because of lam db error".format(TASK_NAME),
+                detail={
+                    "fail_count":  fail_count
+                }
+            )
 
 
 def updateArticlesJob(biz_date=None):