2024-06-06

上线了新etl， 目的是解决封面下载失败的问题

etl修改了oss地址

applications/functions/async_etl.py

@@ -14,12 +14,12 @@ import requests
 from fake_useragent import FakeUserAgent
 
 
-async def upload_to_oss(local_video_path):
+async def upload_to_oss(local_video_path, type_):
     """
     把视频上传到 oss
     :return:
     """
-    oss_video_key = str(uuid4())
+    oss_video_key = "long_articles/{}".format(type_) + str(uuid4())
     access_key_id = "LTAIP6x1l3DXfSxm"
     access_key_secret = "KbTaM9ars4OX3PMS6Xm7rtxGr1FLon"
     endpoint = "oss-cn-hangzhou.aliyuncs.com"
@@ -221,10 +221,12 @@ class AsyncETL(object):
         # upload to oss
         oss_video = await upload_to_oss(
             local_video_path=file_path,
+            type_="video"
         )
         if cover_path:
             oss_cover = await upload_to_oss(
-                    local_video_path=cover_path
+                local_video_path=cover_path,
+                type_="image"
                 )
         else:
             oss_cover = None