收集更多信息

jetblue.py

@@ -94,9 +94,9 @@ for i in range(100):
         # r = requests.get('http://127.0.0.1:5000/getinfo').json()['message']
         # r = requests.get('http://127.0.0.1:3001').json()
         # p = subprocess.Popen(['node', 'js_dom_run.js', selectId, '11'], stdin=subprocess.PIPE, stdout=subprocess.PIPE,
-        # p = subprocess.Popen(['node', 'src_run_chrome_105.js', selectId, '11'], stdin=subprocess.PIPE, stdout=subprocess.PIPE,
+        p = subprocess.Popen(['node', 'src_run_chrome_105.js', selectId, '11'], stdin=subprocess.PIPE, stdout=subprocess.PIPE,
         # p = subprocess.Popen(['node', 'src_run_company_chrome.js', selectId, '11'], stdin=subprocess.PIPE, stdout=subprocess.PIPE,
-        p = subprocess.Popen(['node', 'src_run1.js', selectId, '11'], stdin=subprocess.PIPE, stdout=subprocess.PIPE,
+        # p = subprocess.Popen(['node', 'src_run1.js', selectId, '11'], stdin=subprocess.PIPE, stdout=subprocess.PIPE,
                              stderr=subprocess.PIPE)
         output, err = p.communicate(timeout=10)
         tmp = ''
@@ -113,7 +113,7 @@ for i in range(100):
 
         headers.update(r)
         # headers = r
-        logger.info(f"success:{success}  total:{i+1}  {(time.time() - t1) *1000:.3f}ms {len(headers['X-1ItxWO9i-a'.lower()])} {selectId} {headers['user-agent']}")
+        logger.info(f"success:{success}  total:{total}  {(time.time() - t1) *1000:.3f}ms {len(headers['X-1ItxWO9i-a'.lower()])} {selectId} {headers['user-agent']}")
         # logger.info(f"success:{success}  {(time.time() - t1) *1000:.3f}ms {headers['X-1ItxWO9i-a'.lower()]}")
         url = "https://jbrest.jetblue.com/lfs-rwb/outboundLFS"
         data = {
@@ -146,7 +146,7 @@ for i in range(100):
 
         response = session.post(url, headers=headers, json=data, insecure_skip_verify=True)
         logger.info(f'tls:{tlsV} proxy:{proxy}  res:: {response.status_code}')
-
+        total += 1
         # print(response.text)
         if response.status_code != 403:
             res = db.env_shape.update_one(