match -- if else

applications/etl_function/__init__.py

@@ -131,7 +131,8 @@ async def download_video(file_path, platform, video_url, download_type="video"):
                             await f.write(chunk)
 
             else:
-                print(response.status)
+                print("下载失败")
+                return False
     return file_path
 
 

tasks/newContentIdTask.py

@@ -520,6 +520,17 @@ class NewContentIdTask(object):
                         platform=params['platform'],
                         video_url=params['video_url']
                     )
+                    if not file_path:
+                        update_sql = f"""
+                                            UPDATE {self.article_crawler_video_table}
+                                            SET download_status = %s
+                                            WHERE id = %s;
+                                            """
+                        await self.mysql_client.async_insert(
+                            sql=update_sql,
+                            params=(VIDEO_DOWNLOAD_FAIL_STATUS, params['id'])
+                        )
+                        return False
                     # download cover
                     cover_path = await download_cover(
                         file_path=local_cover_path,