好看视频增加新规则

analysis/analysis.py

@@ -7,7 +7,7 @@ from pyecharts.charts import Line
 class Analysis(object):
     def __init__(self):
         self.platform_list = ["xiaoniangao", "gongzhonghao", "shipinhao", "douyin", "kuaishou", "fuqiwang",
-                              "haitunzhufu"]
+                              "haitunzhufu", "haokanshipin", "benshanzhufu", "zhongmiaoyinxin"]
         self.date_last = "2023-11-01"
         self.out_put = {}
 

haokanshipin/haokanshipin_author/hksp_author.py

@@ -212,17 +212,30 @@ class HaoKanVideoAccount(object):
             self.expire_flag = True
             return
         if pipeline.process_item():
-            self.mq.send_msg(mq_obj)
-            # print(mq_obj)
-            AliyunLogger.logging(
-                code="1002",
-                platform=self.platform,
-                mode=self.mode,
-                env=self.env,
-                message="成功发送至 ETL",
-                data=mq_obj,
-                trace_id=trace_id,
-            )
+            # 再增加一条特殊规则
+            if int(mq_obj['play_cnt']) > 300 and float(mq_obj['like_cnt']) / float(mq_obj['play_cnt']) >= 0.02:
+                self.mq.send_msg(mq_obj)
+                # print(mq_obj)
+                AliyunLogger.logging(
+                    code="1002",
+                    platform=self.platform,
+                    mode=self.mode,
+                    env=self.env,
+                    message="成功发送至 ETL",
+                    data=mq_obj,
+                    trace_id=trace_id,
+                )
+            else:
+                AliyunLogger.logging(
+                    code="2008",
+                    platform=self.platform,
+                    mode=self.mode,
+                    env=self.env,
+                    message="不满足特殊规则",
+                    data=mq_obj
+                )
+
+
 
     def schedule(self):
         """