ywyw2020
diff --git a/‎feapder/core/scheduler.py‎
Lines changed: 1 addition & 5 deletions b/‎feapder/core/scheduler.py‎
Lines changed: 1 addition & 5 deletions
diff --git a/‎feapder/core/spiders/air_spider.py‎
Lines changed: 1 addition & 1 deletion b/‎feapder/core/spiders/air_spider.py‎
Lines changed: 1 addition & 1 deletion
@@ -122,8 +122,7 @@ def __init__(
             setattr(setting, "SPIDER_THREAD_COUNT", thread_count)
         self._thread_count = setting.SPIDER_THREAD_COUNT
 
-        self._spider_name = redis_key
-        self._project_name = redis_key.split(":")[0]
+        self._spider_name = self.name
         self._task_table = task_table
 
         self._tab_spider_status = setting.TAB_SPIDER_STATUS.format(redis_key=redis_key)
@@ -137,9 +136,6 @@ def __init__(
         self._stop_heartbeat = False  # 是否停止心跳
         self._redisdb = RedisDB()
 
-        self._project_total_state_table = "{}_total_state".format(self._project_name)
-        self._is_exist_project_total_state_table = False
-
         # Request 缓存设置
         Request.cached_redis_key = redis_key
         Request.cached_expire_time = setting.RESPONSE_CACHED_EXPIRE_TIME
 
@@ -41,7 +41,7 @@ def __init__(self, thread_count=None):
 
         self._memory_db = MemoryDB()
         self._parser_controls = []
-        self._item_buffer = ItemBuffer(redis_key="air_spider")
+        self._item_buffer = ItemBuffer(redis_key=self.name)
         self._request_buffer = AirSpiderRequestBuffer(
             db=self._memory_db, dedup_name=self.name
         )
Original file line number	Diff line number	Diff line change
`@@ -41,7 +41,7 @@ def __init__(self, thread_count=None):`
`41`	`41`
`42`	`42`	`self._memory_db = MemoryDB()`
`43`	`43`	`self._parser_controls = []`
`44`		`- self._item_buffer = ItemBuffer(redis_key="air_spider")`
	`44`	`+ self._item_buffer = ItemBuffer(redis_key=self.name)`
`45`	`45`	`self._request_buffer = AirSpiderRequestBuffer(`
`46`	`46`	`db=self._memory_db, dedup_name=self.name`
`47`	`47`	`)`