@app.route('/restruct', methods=['POST']) def restruct(): dch = request.form['dch'] dch_folder = "restr" + dch count = 1 while os.path.exists(os.path.join('D:\cj', dch_folder)): dch_folder = "restr" + dch + "_" + str(count) count += 1 os.makedirs(os.path.join('D:\cj', dch_folder, 'photos')) os.makedirs(os.path.join('D:\cj', dch_folder, 'kmls')) os.makedirs(os.path.join('D:\cj', dch_folder, 'project')) photos_folder = os.path.join('D:\cj', dch_folder, 'photos') kmls_folder = os.path.join('D:\cj', dch_folder, 'kmls') project_folder = os.path.join('D:\cj', dch_folder, 'project') for file in request.files.getlist('files'): filename = file.filename file.save(os.path.join(photos_folder, filename)) dhs = request.form.getlist('dh') for dh in dhs: src_path = os.path.join(r'D:/911kml/', dh + '.xlsx.kml') dst_path = os.path.join(r'D:/cj', dch_folder, 'kmls/', dh + '.xlsx.kml') shutil.copy(src_path, dst_path) subprocess.Popen(["python", "restruct.py", dch, photos_folder, project_folder, kmls_folder])使用python实现,这段程序启动restruct.py后,restruct.py每生成一次信息,都实时发送给前端接收
时间: 2023-06-24 09:08:33 浏览: 39
这段代码的作用是创建一个名为"dch_folder"的文件夹,并在该文件夹中创建三个子文件夹photos、kmls、project。然后将用户上传的文件和指定文件夹中的文件复制到相应的子文件夹中。最后,使用subprocess模块启动restruct.py脚本,并将dch、photos_folder、project_folder、kmls_folder这四个参数传递给该脚本。restruct.py脚本会实时生成信息并发送给前端接收。
相关问题
@app.route('/restruct', methods=['POST']) def restruct(): dch = request.form['dch'] dch_folder = "restr" + dch count = 1 while os.path.exists(os.path.join('D:\cj', dch_folder)): dch_folder = "restr" + dch + "_" + str(count) count += 1 os.makedirs(os.path.join('D:\cj', dch_folder, 'photos')) os.makedirs(os.path.join('D:\cj', dch_folder, 'kmls')) os.makedirs(os.path.join('D:\cj', dch_folder, 'project')) photos_folder = os.path.join('D:\cj', dch_folder, 'photos') kmls_folder = os.path.join('D:\cj', dch_folder, 'kmls') project_folder = os.path.join('D:\cj', dch_folder, 'project') for file in request.files.getlist('files'): filename = file.filename file.save(os.path.join(photos_folder, filename)) dhs = request.form.getlist('dh') for dh in dhs: src_path = os.path.join(r'D:/911kml/', dh + '.xlsx.kml') dst_path = os.path.join(r'D:/cj', dch_folder, 'kmls/', dh + '.xlsx.kml') shutil.copy(src_path, dst_path) subprocess.Popen(["python", "restruct.py", dch, photos_folder, project_folder, kmls_folder])使用python3.6版本的websocket,在flask框架中将这段代码运行中的输出信息,实时发送给前端
可以使用 Flask-SocketIO 扩展来实现实时发送输出信息给前端,具体实现步骤如下:
1. 安装 Flask-SocketIO 扩展:
```
pip install flask-socketio
```
2. 在 Flask 应用程序中导入 SocketIO:
```python
from flask_socketio import SocketIO, emit
socketio = SocketIO(app)
```
3. 修改 restruct 视图函数,在执行 subprocess.Popen() 之前,发送一个消息给前端:
```python
@socketio.on('connect')
def test_connect():
emit('my_response', {'data': 'Connected'})
@app.route('/restruct', methods=['POST'])
def restruct():
dch = request.form['dch']
dch_folder = "restr" + dch
count = 1
while os.path.exists(os.path.join('D:\cj', dch_folder)):
dch_folder = "restr" + dch + "_" + str(count)
count += 1
os.makedirs(os.path.join('D:\cj', dch_folder, 'photos'))
os.makedirs(os.path.join('D:\cj', dch_folder, 'kmls'))
os.makedirs(os.path.join('D:\cj', dch_folder, 'project'))
photos_folder = os.path.join('D:\cj', dch_folder, 'photos')
kmls_folder = os.path.join('D:\cj', dch_folder, 'kmls')
project_folder = os.path.join('D:\cj', dch_folder, 'project')
for file in request.files.getlist('files'):
filename = file.filename
file.save(os.path.join(photos_folder, filename))
dhs = request.form.getlist('dh')
for dh in dhs:
src_path = os.path.join(r'D:/911kml/', dh + '.xlsx.kml')
dst_path = os.path.join(r'D:/cj', dch_folder, 'kmls/', dh + '.xlsx.kml')
shutil.copy(src_path, dst_path)
socketio.emit('my_response', {'data': 'Restructuring started'})
subprocess.Popen(["python", "restruct.py", dch, photos_folder, project_folder, kmls_folder])
return 'success'
```
4. 在前端页面中使用 SocketIO 客户端连接 Flask 服务器,并监听 my_response 事件,接收输出信息:
```html
<!DOCTYPE html>
<html>
<head>
<title>WebSocket Test</title>
<script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/2.3.1/socket.io.js"></script>
<script type="text/javascript" charset="utf-8">
var socket = io.connect('http://' + document.domain + ':' + location.port);
socket.on('my_response', function(msg) {
console.log(msg.data);
});
</script>
</head>
<body>
<h1>WebSocket Test</h1>
</body>
</html>
```
当视图函数执行到 subprocess.Popen() 时,会向前端发送一个消息,提示重构开始,然后在 restruct.py 脚本执行过程中,输出信息会实时发送给前端,可以通过在 restruct.py 中使用 print() 或者 sys.stdout.write() 来输出信息。
from flask import Flask, request, jsonify import os app = Flask(__name__) @app.route('/upload', methods=['POST']) def upload(): dch = request.form.get('dch') folder_name = f"{dch}duichang" if not os.path.exists(folder_name): os.mkdir(folder_name) for file in request.files.getlist('files'): filename = file.filename file.save(os.path.join(folder_name, filename)) return jsonify({"code": 200, "msg": "success"}) if __name__ == '__main__': app.run(host='192.168.1.226', port=7000)这段代码运行后run窗口会输出C:\Users\a212\AppData\Local\Programs\Python\Python36\python.exe D:\gangko\t1.py * Serving Flask app 't1' (lazy loading) * Environment: production WARNING: This is a development server. Do not use it in a production deployment. Use a production WSGI server instead. * Debug mode: off * Running on http://192.168.1.226:7000/ (Press CTRL+C to quit),如何更改可以运行后没有WARNING: This is a development server. Do not use it in a production deployment. Use a production WSGI server instead.这段警告
可以在运行 Flask 应用程序时设置环境变量 `FLASK_ENV` 的值为 `production`,以便启用生产模式。修改代码如下:
```python
import os
from flask import Flask, request, jsonify
app = Flask(__name__)
@app.route('/upload', methods=['POST'])
def upload():
dch = request.form.get('dch')
folder_name = f"{dch}duichang"
if not os.path.exists(folder_name):
os.mkdir(folder_name)
for file in request.files.getlist('files'):
filename = file.filename
file.save(os.path.join(folder_name, filename))
return jsonify({"code": 200, "msg": "success"})
if __name__ == '__main__':
app.config['ENV'] = 'production'
app.run(host='192.168.1.226', port=7000)
```
这样运行代码后,就不会再输出 `WARNING: This is a development server. Do not use it in a production deployment. Use a production WSGI server instead.` 这段警告信息了。