请求造纸

b6/src/jetblue.py

@@ -25,12 +25,12 @@ def md5(text):
 client = MongoClient('mongodb://lcc-spider:JIUsfhiad&^@18.144.59.80:27017/?authSource=admin&directConnection=true')
 db = client.env
 # 查询所有文档
-if platform.uname().system != 'Darwin':
-    result = db.env_shape.find({'env.funcs' :{'$ne': None}, 'success': {'$gte': 30}})
-    data = {str(x['_id']): x['env'] for x in result}
-    print(result)
-    with open('env.json', 'w', encoding='utf-8') as f:
-        f.write(json.dumps(data))
+# if platform.uname().system != 'Darwin':
+result = db.env_shape.find({'env.funcs' :{'$ne': None}, 'success': {'$gte': 30}})
+data = {str(x['_id']): x['env'] for x in result}
+print(result)
+with open('env.json', 'w', encoding='utf-8') as f:
+    f.write(json.dumps(data))
 
 with open('env.json', 'r', encoding='utf-8') as f:
     data = json.loads(f.read())
@@ -116,7 +116,8 @@ while True:
             #     # with open('js_dom_run1.js', 'w', encoding='utf-8') as f:
             #     #     f.write(code1 + '\n\n' + c)`
             t1 = time.time()
-            token = list(db.token_shape.aggregate( [ {'$match': {'update_time':{'$gte': int(time.time() * 1000) - 60*60*12}}}, { '$sample': { 'size': 1 } } ] ))[0]['_id']
+            # token = list(db.token_shape.aggregate( [ {'$match': {'update_time':{'$gte': int(time.time() * 1000) - 60*60*12}}}, { '$sample': { 'size': 1 } } ] ))[0]['_id']
+            token = '11'
             # 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,