history_task.py

对于特定账号不处理发布

tasks/history_task.py

@@ -82,7 +82,7 @@ class historyContentIdTask(object):
         sql = f"""
         SELECT platform, play_count, like_count, video_oss_path, cover_oss_path, user_id
         FROM {self.article_crawler_video_table}
-        WHERE content_id = '{content_id}' and download_status = 2
+        WHERE content_id = '{content_id}' and download_status = {self.const.VIDEO_DOWNLOAD_SUCCESS_STATUS}
         ORDER BY score DESC;
         """
         res_tuple = await self.mysql_client.async_select(sql)