|
|
@@ -25,7 +25,7 @@ class CrawlerScheduler:
|
|
|
|
|
|
self._lock = threading.Lock()
|
|
|
|
|
|
- self.heartbeat_url = 'http://192.168.2.246:8080/api/collect_task/heartbeat'
|
|
|
+ self.heartbeat_url = 'http://120.24.26.108:8082/api/collect_task/heartbeat'
|
|
|
self.heartbeat_interval = heartbeat_interval
|
|
|
self.end = False
|
|
|
self.heartbeat_thread = None
|
|
|
@@ -84,7 +84,7 @@ class CrawlerScheduler:
|
|
|
|
|
|
def get_task(self):
|
|
|
try:
|
|
|
- task_api = "http://192.168.2.246:8080/api/collect_task/pull"
|
|
|
+ task_api = "http://120.24.26.108:8082/api/collect_task/pull"
|
|
|
|
|
|
headers = {'X-Crawler-Token':'zhijiayun_crawler_2026'}
|
|
|
|
|
|
@@ -107,7 +107,7 @@ class CrawlerScheduler:
|
|
|
|
|
|
def post_report(self,data):
|
|
|
try:
|
|
|
- url = "http://192.168.2.246:8080/api/collect_task/report"
|
|
|
+ url = "http://120.24.26.108:8082/api/collect_task/report"
|
|
|
print('传给返回接口的数据',data)
|
|
|
logger.info(f'report上传数据：{data}')
|
|
|
headers = {'X-Crawler-Token':'zhijiayun_crawler_2026'}
|
