From 7fe40c7f6b810c0315022a1fbf5af5c6a7daab47 Mon Sep 17 00:00:00 2001 From: oscarz Date: Tue, 1 Jul 2025 10:45:31 +0800 Subject: [PATCH] modify scripts --- iafd/src/fetch.py | 26 +++++++++++++------------- 1 file changed, 13 insertions(+), 13 deletions(-) diff --git a/iafd/src/fetch.py b/iafd/src/fetch.py index e6940e5..d1b5ec3 100644 --- a/iafd/src/fetch.py +++ b/iafd/src/fetch.py @@ -30,9 +30,9 @@ def fetch_performers_by_astro(): # 写入演员数据表 perfomer_id = db_tools.insert_performer_index(name=row['person'], href=row.get('href', '').lower(), from_astro_list=1) if perfomer_id: - logging.debug(f'insert performer index to db. performer_id:{perfomer_id}, name: {row['person']}, href:{row['href']}') + logging.debug(f"insert performer index to db. performer_id:{perfomer_id}, name: {row['person']}, href:{row['href']}") else: - logging.warning(f'insert performer index failed. name: {row['person']}, href:{row['href']}') + logging.warning(f"insert performer index failed. name: {row['person']}, href:{row['href']}") else: logging.warning(f'fetch astro error. {url} ...') @@ -60,9 +60,9 @@ def fetch_performers_by_birth(): # 写入演员数据表 perfomer_id = db_tools.insert_performer_index(name=row['person'], href=row.get('href', '').lower(), from_birth_list=1) if perfomer_id: - logging.debug(f'insert performer index to db. performer_id:{perfomer_id}, name: {row['person']}, href:{row['href']}') + logging.debug(f"insert performer index to db. performer_id:{perfomer_id}, name: {row['person']}, href:{row['href']}") else: - logging.warning(f'insert performer index failed. name: {row['person']}, href:{row['href']}') + logging.warning(f"insert performer index failed. name: {row['person']}, href:{row['href']}") else: logging.warning(f'fetch astro error. {url} ...') elif status_code and status_code == 404: @@ -85,7 +85,7 @@ def fetch_ethic_list(): for row in list_data : dist_id = db_tools.insert_or_update_ethnic({'name': row['name'], 'href': row.get('href', '')}) if dist_id: - logging.debug(f'insert one record into ethnic table. id:{dist_id}, name: {row['name']}, href:{row.get('href', '')}') + logging.debug(f"insert one record into ethnic table. id:{dist_id}, name: {row['name']}, href:{row.get('href', '')}") else: logging.warning(f'fetch ethnic error. {url} ...') elif status_code and status_code == 404: @@ -118,9 +118,9 @@ def fetch_performers_by_ethnic(): perfomer_id = db_tools.insert_performer_index(name=row['person'], href=row.get('href', '').lower(), from_ethnic_list=1) if perfomer_id: count += 1 - logging.debug(f'insert performer index to db. performer_id:{perfomer_id}, name: {row['person']}, href:{row['href']}') + logging.debug("'insert performer index to db. performer_id:{perfomer_id}, name: {row['person']}, href:{row['href']}") else: - logging.warning(f'insert performer index failed. name: {row['person']}, href:{row['href']}') + logging.warning("'insert performer index failed. name: {row['person']}, href:{row['href']}") else: logging.warning(f'fetch astro error. {next_url} ...') elif status_code and status_code == 404: @@ -148,7 +148,7 @@ def fetch_distributors_list(): dis_url = scraper.distributors_base_url + row['href'] dist_id = db_tools.insert_or_update_distributor({'name': row['name'], 'href': dis_url}) if dist_id: - logging.debug(f'insert one record into distributors table. id:{dist_id}, name: {row['name']}, href:{dis_url}') + logging.debug(f"insert one record into distributors table. id:{dist_id}, name: {row['name']}, href:{dis_url}") else: logging.warning(f'fetch astro error. {url} ...') elif status_code and status_code == 404: @@ -168,7 +168,7 @@ def fetch_studios_list(): stu_url = scraper.studios_base_url + row['href'] stu_id = db_tools.insert_or_update_studio({'name': row['name'], 'href': stu_url}) if stu_id: - logging.debug(f'insert one record into studios table. id:{stu_id}, name: {row['name']}, href:{stu_url}') + logging.debug(f"insert one record into studios table. id:{stu_id}, name: {row['name']}, href:{stu_url}") else: logging.warning(f'fetch astro error. {url} ...') elif status_code and status_code == 404: @@ -194,9 +194,9 @@ def fetch_movies_by_dist(): for movie in list_data: tmp_id = db_tools.insert_movie_index(title=movie['title'], href=movie['href'], release_year=utils.to_number(movie['year']), from_dist_list=1) if tmp_id: - logging.debug(f'insert one movie index to db. movie_id: {tmp_id}, title: {movie['title']}, href: {movie['href']}') + logging.debug(f"insert one movie index to db. movie_id: {tmp_id}, title: {movie['title']}, href: {movie['href']}") else: - logging.warning(f'insert movie index failed. title: {movie['title']}, href: {movie['href']}') + logging.warning(f"insert movie index failed. title: {movie['title']}, href: {movie['href']}") else : logging.warning(f'parse_page_movie error. url: {url}') elif status_code and status_code == 404: @@ -224,9 +224,9 @@ def fetch_movies_by_stu(): for movie in list_data: tmp_id = db_tools.insert_movie_index(title=movie['title'], href=movie['href'], release_year=utils.to_number(movie['year']), from_stu_list=1) if tmp_id: - logging.debug(f'insert one movie index to db. movie_id: {tmp_id}, title: {movie['title']}, href: {movie['href']}') + logging.debug(f"insert one movie index to db. movie_id: {tmp_id}, title: {movie['title']}, href: {movie['href']}") else: - logging.warning(f'insert movie index failed. title: {movie['title']}, href: {movie['href']}') + logging.warning(f"insert movie index failed. title: {movie['title']}, href: {movie['href']}") else : logging.warning(f'parse_page_movie error. url: {url}') elif status_code and status_code == 404: