no message

Pyspark_job/dwt/dwt_asin_sync.py

@@ -203,6 +203,10 @@ class DwtAsinSync(Templates):
         self.df_save = self.df_save.withColumn('date_info', F.lit(self.date_info))
         self.df_save.show(10, truncate=False)
         print(f"self.df_save: {self.df_save.count()}")
+        users = ["fangxingjun", "chenyuanjie", "pengyanbing"]
+        title = f"dwd_asin_to_pg: {self.site_name}, {self.date_type}, {self.date_info}"
+        content = f"整合asin完成--等待导出到pg提供爬虫使用--self.df_save.count: {self.df_save.count()}"
+        CommonUtil().send_wx_msg(users=users, title=title, content=content)
 
     # def save_data(self):
     #     pass