@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 14:08:48 浏览: 45
可以使用 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() 来输出信息。

相关推荐

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

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

高级色系PPT11.pptx

高级色系PPT11.pptx
recommend-type

node-v7.9.0-linux-x86.tar.xz

Node.js，简称Node，是一个开源且跨平台的JavaScript运行时环境，它允许在浏览器外运行JavaScript代码。Node.js于2009年由Ryan Dahl创立，旨在创建高性能的Web服务器和网络应用程序。它基于Google Chrome的V8 JavaScript引擎，可以在Windows、Linux、Unix、Mac OS X等操作系统上运行。 Node.js的特点之一是事件驱动和非阻塞I/O模型，这使得它非常适合处理大量并发连接，从而在构建实时应用程序如在线游戏、聊天应用以及实时通讯服务时表现卓越。此外，Node.js使用了模块化的架构，通过npm（Node package manager，Node包管理器）,社区成员可以共享和复用代码，极大地促进了Node.js生态系统的发展和扩张。 Node.js不仅用于服务器端开发。随着技术的发展，它也被用于构建工具链、开发桌面应用程序、物联网设备等。Node.js能够处理文件系统、操作数据库、处理网络请求等，因此，开发者可以用JavaScript编写全栈应用程序，这一点大大提高了开发效率和便捷性。 在实践中，许多大型企业和组织已经采用Node.js作为其Web应用程序的开发平台，如Netflix、PayPal和Walmart等。它们利用Node.js提高了应用性能，简化了开发流程，并且能更快地响应市场需求。
recommend-type

基于tensorflow的的cnn卷积神经网络的图像识别分类

【作品名称】：基于tensorflow的的cnn卷积神经网络的图像识别分类 【适用人群】：适用于希望学习不同技术领域的小白或进阶学习者。可作为毕设项目、课程设计、大作业、工程实训或初期项目立项。
recommend-type

### 数据分析概念、使用技巧、优缺点的文章

数据分析是指通过收集、清洗、处理和解释数据，以发现其中的模式、趋势和关联，从而提供决策支持或洞察见解的过程。它在各行各业中都扮演着至关重要的角色，从市场营销到科学研究，从金融领域到医疗保健，都有广泛的应用。
recommend-type

对微信帐单进行数据分析

#pip install pandas -i https://mirrors.aliyun.com/pypi/simple #安装pandas处理数据模块 #pip install xlwt -i https://mirrors.aliyun.com/pypi/simple #安装excel模块 #pip install openpyxl #从微信导出对帐帐单 import pandas as pd #引入pandas，重命名为pd,Python3.9.10版本的Pandas无法兼容低版本的xls import numpy as np #导入均值模块 #从第17行读取csv格式的帐单 df = pd.read_csv('微信支付账单(20230101-20230401).csv',header=16) #分析数据 ...... #将分析数据另存为out.xlsx ..... #进行交易进间分析 ...... #统计交易对方 ...... #将结果保存到excel ..... writer.close()
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

如何用python编写api接口

在Python中编写API接口可以使用多种框架，其中比较流行的有Flask和Django。这里以Flask框架为例，简单介绍如何编写API接口。 1. 安装Flask框架 使用pip命令安装Flask框架： ``` pip install flask ``` 2. 编写API接口 创建一个Python文件，例如app.py，编写以下代码： ```python from flask import Flask, jsonify app = Flask(__name__) @app.route('/api/hello', methods=['GET']) def hello():
recommend-type

JSBSim Reference Manual

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