42 lines
1.3 KiB
Python
42 lines
1.3 KiB
Python
import os
|
|
import json
|
|
import time
|
|
import requests
|
|
from flask import request
|
|
from flask import Flask, Response
|
|
from concurrent.futures import ThreadPoolExecutor
|
|
app = Flask(__name__)
|
|
executor = ThreadPoolExecutor(3)
|
|
|
|
|
|
def analysing(request_data):
|
|
patrol_host = '172.20.0.115'
|
|
patrol_port = 8000
|
|
request_data = json.loads(request_data)
|
|
file_path = request_data['file_path']
|
|
url = "http://" + patrol_host + ":" + patrol_port + "/notifyresult"
|
|
#url = "http://172.20.0.115:8000/notifyresult"
|
|
headers = {'Content--Type': 'application/json;charset=UTF-8'}
|
|
|
|
'''
|
|
print("--------------------------- url---------------------------", url)
|
|
res = requests.post(url=url, json=result_data, headers=headers)
|
|
print("---------------------------------res------------------------------------", res)
|
|
'''
|
|
|
|
|
|
|
|
|
|
@app.route('/analysis', methods=['POST'])
|
|
def picAnalyse():
|
|
print("---------------------------picAnalyse---start------------------------", request.args)
|
|
request_data = request.get_data().decode('utf-8')
|
|
print("---------------------------request_data---------------------------", request_data)
|
|
executor.submit(analysing, request_data)
|
|
#return Response()
|
|
return json.dumps({'success':True})
|
|
|
|
|
|
if __name__ == '__main__':
|
|
app.run(host='0.0.0.0', port=8000)
|