@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框架中将这段代码运行中的输出信息，实时发送给前端，给出前端访问地址

时间: 2023-06-24 20:08:55 浏览: 47
可以使用 Flask-SocketIO 扩展来实现 WebSocket 实时发送输出信息给前端。 首先，需要在服务器上安装 Flask-SocketIO 扩展： ``` pip install flask-socketio ``` 然后，在 Flask 应用程序中导入并初始化 SocketIO： ```python from flask import Flask, render_template from flask_socketio import SocketIO app = Flask(__name__) app.config['SECRET_KEY'] = 'secret!' socketio = SocketIO(app) ``` 接下来，在你的视图函数中，需要将输出信息发送给所有连接的 WebSocket 客户端： ```python import subprocess @socketio.on('connect') def test_connect(): print('Client connected') @app.route('/restruct', methods=['POST']) def restruct(): # ... process = subprocess.Popen(["python", "restruct.py", dch, photos_folder, project_folder, kmls_folder], stdout=subprocess.PIPE, stderr=subprocess.STDOUT) while True: output = process.stdout.readline() if output == '' and process.poll() is not None: break if output: print(output.strip()) socketio.emit('output', output.strip()) return render_template('index.html') ``` 然后，在前端 HTML 文件中，需要引入 SocketIO JavaScript 库，并连接到服务器： ```html <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>WebSocket Output</title> <script src="//code.jquery.com/jquery-1.11.1.min.js"></script> <script src="//cdn.socket.io/socket.io-1.2.0.js"></script> </head> <body> <script type="text/javascript" charset="utf-8"> var socket = io.connect('http://' + document.domain + ':' + location.port); socket.on('connect', function() { console.log('Connected to server'); }); socket.on('output', function(data) { console.log(data); }); </script> </body> </html> ``` 最后，启动 Flask 应用程序并访问前端页面，就可以实现 WebSocket 实时发送输出信息给前端了。需要注意的是，可能需要根据你的服务器环境和项目结构进行适当的修改。

相关推荐

exe

Fingerprint_WBF_USB_DCH_ELAN_Z_V3.5.12201.11001_24387.exe

Fingerprint_WBF_USB_DCH_ELAN_Z_V3.5.12201.11001_24387.exe
exe

Camera_DCH_Sonix_Z_V10.16.19041.10_27415.exe

Camera_DCH_Sonix_Z_V10.16.19041.10_27415.exe

LAN_DCH_ROG_Intel_B_V12.19.2.45_28913_1 (1).exe

LAN_DCH_ROG_Intel_B_V12.19.2.45_28913_1 (1).exe

@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框架中将这段代码运行中的输出信息，实时发送给前端

@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 = ...

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.这段警告

@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....

@app.route('/tiji', methods=['POST']) def tiji(): dch = request.form.get('dch') name = request.form.get('filename') print(name) folder_name = f"{dch}dianyun" if not os.path.exists(folder_name): os.mkdir(folder_name) for file in request.files.getlist('file'): filename = file.filename file.save(os.path.join(folder_name, filename)) dhs = request.form.getlist('dh') print(len(dhs)) for i in range(len(dhs)): print(dhs[i]) folder_path = os.path.join(folder_name) file_name = f"{name}.laz" if has_file(folder_path, file_name): return jsonify({"code": 200, "msg": "success"}) else: return jsonify({"code": 500, "msg": "fail"}) print('hi') 如何在这段代码中调用@socketio.on向前端发送数据

@app.route('/tiji', methods=['POST']) def tiji(): dch = request.form.get('dch') name = request.form.get('filename') print(name) folder_name = f"{dch}dianyun" if not os.path.exists(folder_name): ...

@app.route('/tiji', methods=['POST']) def tiji(): dch = request.form.get('dch') name = request.form.get('filename') print(name) folder_name = f"{dch}dianyun" if not os.path.exists(folder_name): os.mkdir(folder_name) for file in request.files.getlist('file'): filename = file.filename file.save(os.path.join(folder_name, filename)) dhs = request.form.getlist('dh') print(len(dhs)) for i in range(len(dhs)): print(dhs[i]) folder_path = os.path.join(folder_name) file_name = f"{name}.laz" if has_file(folder_path, file_name): return jsonify({"code": 200, "msg": "success"}) else: return jsonify({"code": 500, "msg": "fail"}) print('hi') 用什么替换return jsonify，可以在发送success给前端后还可以打印hi

@app.route('/tiji', methods=['POST']) def tiji(): dch = request.form.get('dch') name = request.form.get('filename') print(name) folder_name = f"{dch}dianyun" if not os.path.exists(folder_name): ...

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_ENV 环境变量的值为 production 来禁用开发模式，从而避免警告信息的输出。在 Windows 环境下，可以在命令行中输入以下命令： set FLASK_ENV=production python t1.py ...

subprocess.Popen(["python", "restruct.py", dch, photos_folder, project_folder, kmls_folder])使用python实现，这段代码启动restruct.py后，restruct.py每生成一次信息，都实时发送给前端接收

@sockets.route('/restruct') def restruct_socket(ws): # 接收来自客户端的连接 while not ws.closed: # 在restruct.py中生成信息后，发送给客户端 # 这里假设生成的信息为msg msg = {'message': 'Hello, ...

folder_path = os.path.join(os.getcwd(), f"{dch}堆场")

其中，os.getcwd()返回当前工作目录的路径，os.path.join()将路径组合起来，{dch}堆场是一个文件夹的名称，f""是Python3.6及以上版本中的字符串格式化语法。因此，这段代码的作用是将当前工作目录和文件夹...

用python写一个服务并注释，开放一个接口http://192.168.1.226:5000/dezip，启动后，前端访问该接口时会输入堆场号,然后前端会上传压缩文件夹，程序接收到dch并将其作为参数，后将收到的压缩文件解压，解压后，将解压文件中的子文件夹复制到当前目录下的"'dch'+duichang"文件夹中，后将解压文件夹和压缩文件夹删除。

@app.route('/dezip', methods=['POST']) def dezip(): # 获取堆场号 dch = request.form['dch'] # 获取上传的文件 file = request.files['file'] # 保存文件到本地 file.save(file.filename) # 解压...

用python写一个服务并注释，开放一个接口http://192.168.1.226:5000/dezip，启动后，前端访问该接口时输入dch,然后前端上传压缩文件夹，程序接收dch并将其作为参数，后将收到的文件解压，解压后将解压后的文件重命名为"'dch'+duichang"

@app.route('/dezip', methods=['POST']) def dezip(): # 获取前端传递的参数dch dch = request.form.get('dch') # 获取上传的文件对象 file = request.files['file'] # 获取上传文件的文件名 filename = file...

用python写一个服务并注释，开放一个接口http://192.168.1.226:5000/dezip，启动后，前端访问该接口时输入dch,然后前端上传压缩文件夹，程序接收dch并将其作为参数，后将收到的文件解压，解压后，将解压生成文件中的子文件夹复制到当前项目下的"'dch'+duichang"文件夹中，后将解压文件夹和压缩文件夹删除

@app.route('/dezip', methods=['POST']) def dezip(): # 获取输入的参数dch dch = request.form.get('dch') # 获取上传的文件 f = request.files['file'] # 保存上传的文件 filepath = os.path.join(os....

用python写一个服务并注释，开放一个接口http://192.168.1.226:5000/dezip，启动后，前端访问该接口时会输入堆场号,然后前端会上传duichang.zip压缩文件夹，程序接收到dch并将其作为参数，后将收到的duichang.zip文件解压，解压后，将解压文件中的子文件夹复制到当前项目下的"'dch'+duichang"文件夹中，后将解压文件夹和压缩文件夹删除。

@app.route('/dezip', methods=['POST']) def dezip(): # 获取堆场号 duichang = request.form['duichang'] # 获取上传的文件 dch = request.files['dch'] # 保存上传的文件 dch.save('dch.zip') # 解压文件 ...

用python写一个服务并注释，开放一个接口http://192.168.1.226:5000/dezip，启动后，前端访问该接口时会输入堆场号,然后前端会上传duichang.zip压缩文件夹，程序接收到dch并将其作为参数，后将收到的压缩文件解压，解压后，将解压文件中的子文件夹复制到当前目录下的"'dch'+duichang"文件夹中，后将解压文件夹和压缩文件夹删除。最后给出前端与接口对应的网页代码

@app.route('/dezip', methods=['POST']) def dezip(): dch = request.form['dch'] f = request.files['file'] f.save(f.filename) with zipfile.ZipFile(f.filename, 'r') as zip_ref: zip_ref.extractall(dch...

for folder_name in os.listdir(MuDiDi): src_subfolder = os.path.join(MuDiDi, folder_name) if os.path.isdir(src_subfolder): dest_subfolder = os.path.join(BackUp, dch, current_time, folder_name) shutil.copytree(src_subfolder, dest_subfolder) 这段代码如何改，将最近1小时内生成的文件拷贝到dest_subfolder，而不是全拷贝

dest_subfolder = os.path.join(BackUp, dch, current_time, folder_name) os.makedirs(dest_subfolder, exist_ok=True) # 创建目标子文件夹 # 遍历源子文件夹中的文件 for filename in os.listdir(src_...
rar

Win10-DCH_64.rar

Windows server 2019_Geforce RTX 3060驱动
exe

INFUpdate_DCH_ROG_Intel_B_V10.1.36.6_25941.exe

INFUpdate_DCH_ROG_Intel_B_V10.1.36.6_25941.exe

WirelessLan_DCH_MediaTek_Z_V3.0.1.1237_27699_1.exe

WirelessLan_DCH_MediaTek_Z_V3.0.1.1237_27699_1.exe
exe

WirelessLan_PIE_DCH_Intel_Z_V22.120.0.3_27372.exe

WirelessLan_PIE_DCH_Intel_Z_V22.120.0.3_27372.exe

最新推荐

recommend-type

pre_o_1csdn63m9a1bs0e1rr51niuu33e.a

pre_o_1csdn63m9a1bs0e1rr51niuu33e.a
recommend-type

matlab建立计算力学课程的笔记和文件.zip

matlab建立计算力学课程的笔记和文件.zip
recommend-type

FT-Prog-v3.12.38.643-FTD USB 工作模式设定及eprom读写

FT_Prog_v3.12.38.643--FTD USB 工作模式设定及eprom读写
recommend-type

matlab基于RRT和人工势场法混合算法的路径规划.zip

matlab基于RRT和人工势场法混合算法的路径规划.zip
recommend-type

matlab基于matlab的两步定位软件定义接收机的开源GNSS直接位置估计插件模块.zip

matlab基于matlab的两步定位软件定义接收机的开源GNSS直接位置估计插件模块.zip
recommend-type

zigbee-cluster-library-specification

最新的zigbee-cluster-library-specification说明文档。
recommend-type

管理建模和仿真的文件

管理Boualem Benatallah引用此版本：布阿利姆·贝纳塔拉。管理建模和仿真。约瑟夫-傅立叶大学-格勒诺布尔第一大学，1996年。法语。NNT：电话：00345357HAL ID：电话：00345357https://theses.hal.science/tel-003453572008年12月9日提交HAL是一个多学科的开放存取档案馆，用于存放和传播科学研究论文，无论它们是否被公开。论文可以来自法国或国外的教学和研究机构，也可以来自公共或私人研究中心。L’archive ouverte pluridisciplinaire
recommend-type

实现实时数据湖架构：Kafka与Hive集成

![实现实时数据湖架构：Kafka与Hive集成](https://img-blog.csdnimg.cn/img_convert/10eb2e6972b3b6086286fc64c0b3ee41.jpeg) # 1. 实时数据湖架构概述** 实时数据湖是一种现代数据管理架构，它允许企业以低延迟的方式收集、存储和处理大量数据。与传统数据仓库不同，实时数据湖不依赖于预先定义的模式，而是采用灵活的架构，可以处理各种数据类型和格式。这种架构为企业提供了以下优势： - **实时洞察：**实时数据湖允许企业访问最新的数据，从而做出更明智的决策。 - **数据民主化：**实时数据湖使各种利益相关者都可
recommend-type

2． 通过python绘制y=e-xsin(2πx)图像

可以使用matplotlib库来绘制这个函数的图像。以下是一段示例代码： ```python import numpy as np import matplotlib.pyplot as plt def func(x): return np.exp(-x) * np.sin(2 * np.pi * x) x = np.linspace(0, 5, 500) y = func(x) plt.plot(x, y) plt.xlabel('x') plt.ylabel('y') plt.title('y = e^{-x} sin(2πx)') plt.show() ``` 运行这段
recommend-type

JSBSim Reference Manual

JSBSim参考手册，其中包含JSBSim简介，JSBSim配置文件xml的编写语法，编程手册以及一些应用实例等。其中有部分内容还没有写完，估计有生之年很难看到完整版了，但是内容还是很有参考价值的。