更新 run_yggxxsp_scheduling.py

youlegaoxiaoxiaoshipin/youlegaoxiaoxiaoshipin_recommend/youlegaoxiaoxiaoshipin_scheduling.py

@@ -160,6 +160,14 @@ class YLGXXSPScheduling:
             # print(json.dumps(video_dict, ensure_ascii=False, indent=4))
             self.download_count += 1
             self.mq.send_msg(video_dict)
+            AliyunLogger.logging(
+                code="1000",
+                platform=self.platform,
+                mode=self.mode,
+                env=self.env,
+                data=video_dict,
+                message="成功发送 MQ 至 ETL",
+            )
 
 
 if __name__ == "__main__":