|
@@ -808,19 +808,38 @@ class XiGuaAuthor:
|
|
|
trace_id=trace_id,
|
|
|
message="成功发送 MQ 至 ETL",
|
|
|
)
|
|
|
+ return True
|
|
|
else:
|
|
|
- if float(video_dict['like_cnt']) / float(video_dict['play_cnt']) >= 0.04:
|
|
|
- self.mq.send_msg(video_dict)
|
|
|
- self.download_count += 1
|
|
|
- AliyunLogger.logging(
|
|
|
- code="1002",
|
|
|
- platform=self.platform,
|
|
|
- mode=self.mode,
|
|
|
- env=self.env,
|
|
|
- data=video_dict,
|
|
|
- trace_id=trace_id,
|
|
|
- message="成功发送 MQ 至 ETL",
|
|
|
+ AliyunLogger.logging(
|
|
|
+ code="2008",
|
|
|
+ platform=self.platform,
|
|
|
+ mode=self.mode,
|
|
|
+ env=self.env,
|
|
|
+ message="不满足特殊规则, 播放量",
|
|
|
+ data=video_dict
|
|
|
+ )
|
|
|
+ if float(video_dict['like_cnt']) / float(video_dict['play_cnt']) >= 0.04:
|
|
|
+ self.mq.send_msg(video_dict)
|
|
|
+ self.download_count += 1
|
|
|
+ AliyunLogger.logging(
|
|
|
+ code="1002",
|
|
|
+ platform=self.platform,
|
|
|
+ mode=self.mode,
|
|
|
+ env=self.env,
|
|
|
+ data=video_dict,
|
|
|
+ trace_id=trace_id,
|
|
|
+ message="成功发送 MQ 至 ETL",
|
|
|
)
|
|
|
+ return True
|
|
|
+ else:
|
|
|
+ AliyunLogger.logging(
|
|
|
+ code="2008",
|
|
|
+ platform=self.platform,
|
|
|
+ mode=self.mode,
|
|
|
+ env=self.env,
|
|
|
+ message="不满足特殊规则, 点赞量/播放量",
|
|
|
+ data=video_dict
|
|
|
+ )
|
|
|
return True
|
|
|
|
|
|
def get_video_info(self, item_id, trace_id):
|