|
|
@@ -135,9 +135,10 @@ class ZFQZTJLRecommend(object):
|
|
|
trace_id = self.platform + str(uuid.uuid1())
|
|
|
our_user = random.choice(self.user_list)
|
|
|
item = VideoItem()
|
|
|
+ vid = video_obj['id']
|
|
|
+ mid = int(video_obj['user']['mid'])
|
|
|
+ print(f"vid={vid},mid={mid}")
|
|
|
try:
|
|
|
- mid = int(video_obj['user']['mid'])
|
|
|
- print(f"id:{mid}")
|
|
|
user_name = video_obj['user']['nick']
|
|
|
avatar_url = video_obj['user']['hurl']
|
|
|
sql = Sql()
|
|
|
@@ -208,7 +209,7 @@ class ZFQZTJLRecommend(object):
|
|
|
self.download_cnt += 1
|
|
|
self.mq.send_msg(mq_obj)
|
|
|
self.aliyun_log.logging(code="1002", message="成功发送至 ETL", data=mq_obj)
|
|
|
- video_view(video_obj["id"], video_obj['user']['mid'])
|
|
|
+ video_view(vid, mid)
|
|
|
self.aliyun_log.logging(code="1010", message="触发曝光", data=mq_obj)
|
|
|
if self.download_cnt >= int(
|
|
|
self.rule_dict.get("videos_cnt", {}).get("min", 200)
|
supeng