|
|
@@ -24,7 +24,7 @@ class CrawlerScheduler:
|
|
|
|
|
|
self._lock = threading.Lock()
|
|
|
|
|
|
- self.heartbeat_url = 'http://pricesys2.kailin.com.cn:8082/api/collect_task/heartbeat'
|
|
|
+ self.heartbeat_url = 'http://pricesys2.kailin.com.cn:8083/api/collect_task/heartbeat'
|
|
|
self.heartbeat_interval = heartbeat_interval
|
|
|
self.end = False
|
|
|
self.heartbeat_thread = None
|
|
|
@@ -80,8 +80,10 @@ class CrawlerScheduler:
|
|
|
|
|
|
def get_task(self):
|
|
|
try:
|
|
|
- task_api = "http://pricesys2.kailin.com.cn:8082/api/collect_task/pull"
|
|
|
+ task_api = "http://pricesys2.kailin.com.cn:8083/api/collect_task/pull"
|
|
|
+
|
|
|
headers = {'X-Crawler-Token': 'zhijiayun_crawler_2026'}
|
|
|
+
|
|
|
params = {
|
|
|
'platform': self.platform,
|
|
|
'username': self.username
|
|
|
@@ -99,7 +101,7 @@ class CrawlerScheduler:
|
|
|
|
|
|
def post_report(self, data):
|
|
|
try:
|
|
|
- url = "http://pricesys2.kailin.com.cn:8082/api/collect_task/report"
|
|
|
+ url = "http://pricesys2.kailin.com.cn:8083/api/collect_task/report"
|
|
|
print('传给返回接口的数据', data)
|
|
|
logger.info(f'report上传数据：{data}')
|
|
|
headers = {'X-Crawler-Token': 'zhijiayun_crawler_2026'}
|
