Bläddra i källkod

调整推荐和用户数据整体执行频率

zhangliang 1 månad sedan
förälder
incheckning
3c4e19d94b
1 ändrade filer med 5 tillägg och 0 borttagningar
  1. 5 0
      spider/crawler_author/zhongqingkandian_author.py

+ 5 - 0
spider/crawler_author/zhongqingkandian_author.py

@@ -338,6 +338,11 @@ class ZhongQingKanDianAuthor:
                         FeishuUtils.update_values("U5dXsSlPOhiNNCtEfgqcm1iYnpf", "v8S6nL", "A2:Z2", values)
                         FeishuUtils.update_values("U5dXsSlPOhiNNCtEfgqcm1iYnpf", "v8S6nL", "A2:Z2", values)
             self.download_cnt += 1
             self.download_cnt += 1
             self.mq.send_msg(mq_obj)
             self.mq.send_msg(mq_obj)
+            self.aliyun_log.logging(
+                code="2009",
+                message=f"成功发送视频到etl",
+                data={"video_obj": video_obj}
+            )
             # 保存视频ID
             # 保存视频ID
             self.redis_ops.save_video_id(video_obj['channel_content_id'])
             self.redis_ops.save_video_id(video_obj['channel_content_id'])
             if self.download_cnt >= self.rule_dict.get("videos_cnt", {}).get("min", 300) and self.zqkd_user_list:
             if self.download_cnt >= self.rule_dict.get("videos_cnt", {}).get("min", 300) and self.zqkd_user_list: