update

find_source/crawler/services/sync_data.py

@@ -30,7 +30,7 @@ class SyncData(BasicSearch):
     def _init(self):
         threading.Thread(target=self.sync_data, name='SyncData').start()
 
-    def sync_data_keywords(self):
+    def sync_keywords(self):
         """同步关键词数据"""
         logger.info(f'[数据同步 - 关键词]开始加载')
         words = self.keywords_table()
@@ -48,7 +48,7 @@ class SyncData(BasicSearch):
         self.scheduler.add_query(self.keyword_groups, lst, level=self.keyword_weight)
         logger.info(f'[数据同步 - 关键词]{len(words)}条')
 
-    def sync_data_orgs(self):
+    def sync_orgs(self):
         """同步组织单位数据"""
         logger.info(f'[数据同步 - 组织列表]开始加载')
         items = self.orgs_table()
@@ -79,7 +79,7 @@ class SyncData(BasicSearch):
             )
         logger.info(f'[数据同步 - 组织列表]{len(items)}个')
 
-    def sync_data_urls(self):
+    def sync_seed_urls(self):
         """同步网址数据"""
         logger.info(f'[数据同步 - 种子列表]开始加载')
         items = self.seed_urls_table()
@@ -107,7 +107,7 @@ class SyncData(BasicSearch):
             )
         logger.info(f'[数据同步 - 种子列表]{len(items)}条')
 
-    def sync_data_competing_goods(self):
+    def sync_competing_goods(self):
         """同步竞品urls"""
         logger.info(f'[数据同步 - 竞品列表]开始加载')
         items = self.competing_goods_table()
@@ -183,10 +183,10 @@ class SyncData(BasicSearch):
             try:
                 self.sync_collector()
                 self.sync_validator()
-                self.sync_data_competing_goods()
-                self.sync_data_keywords()
-                self.sync_data_urls()
-                self.sync_data_orgs()
+                self.sync_competing_goods()
+                self.sync_keywords()
+                self.sync_seed_urls()
+                self.sync_orgs()
             except Exception as e:
                 logger.exception(e)
             self.loops_interval(self._interval)