|
|
@@ -119,7 +119,7 @@ class Scheduler(threading.Thread):
|
|
|
self._spider_name = redis_key
|
|
|
|
|
|
# 声明爬虫心跳队列
|
|
|
- self._tab_spider_heartbeat = setting.SPIDER_HEARTBEAT
|
|
|
+ self._tab_spider_heartbeat = setting.TAB_SPIDER_HEARTBEAT
|
|
|
self._rabbitmq.declare(queue=self._tab_spider_heartbeat)
|
|
|
|
|
|
self._is_notify_end = False # 是否已经通知结束
|
