|
@@ -9,7 +9,7 @@ import requests
|
|
|
|
|
|
sys.path.append(os.getcwd())
|
|
|
from common.video_item import VideoItem
|
|
|
-from common import PiaoQuanPipeline, AliyunLogger, tunnel_proxies
|
|
|
+from common import PiaoQuanPipeline, AliyunLogger, tunnel_proxies, get_redirect_url
|
|
|
from common.mq import MQ
|
|
|
|
|
|
|
|
@@ -98,12 +98,14 @@ class Kxxfdwjspcheduling(object):
|
|
|
trace_id = self.platform + str(uuid.uuid1())
|
|
|
our_user = random.choice(self.user_list)
|
|
|
item = VideoItem()
|
|
|
+ video_url = get_redirect_url(video_obj["url"])
|
|
|
+
|
|
|
item.add_video_info("user_id", our_user["uid"])
|
|
|
item.add_video_info("user_name", our_user["nick_name"])
|
|
|
item.add_video_info("video_id", video_obj["id"])
|
|
|
item.add_video_info("video_title", video_obj["title"])
|
|
|
item.add_video_info("publish_time_stamp", int(time.time()))
|
|
|
- item.add_video_info("video_url", video_obj["url"])
|
|
|
+ item.add_video_info("video_url", video_url)
|
|
|
item.add_video_info("cover_url", video_obj["thumb"])
|
|
|
item.add_video_info("out_video_id", video_obj["id"])
|
|
|
item.add_video_info("platform", self.platform)
|