no message

Pyspark_job/dwd/dwd_nsr_bsr_keepa_asin.py

@@ -156,6 +156,11 @@ class DwdNsrBsrKeepaAsin(Templates):
         # self.df_save.groupBy("date_info").count().orderBy("count", ascending=False).show(truncate=False)
         # self.df_save.groupBy("asin_cate_flag").count().orderBy("count", ascending=False).show(truncate=False)
         # exit()
+        print("self.df_save.count:", self.df_save.count())
+        users = ["fangxingjun", "chenyuanjie", "pengyanbing"]
+        title = f"日asin整合: {self.site_name}, {self.date_type}, {self.date_info}"
+        content = f"整合asin完成--等待导出到pg提供爬虫使用--数量: {self.df_save.count()}"
+        CommonUtil().send_wx_msg(users=users, title=title, content=content)
 
 
     # def save_data(self):