### 处理HTML上传文件与数据库信息的方法 在 Docker 中运行 Python 应用程序时，可以通过 Flask 或其他 Web 框架来接收 HTML 表单提交的文件和数据，并将其存储到数据库中。以下是具体实现方式： #### 接收并保存上传文件 通过 Flask 的 `request` 对象可以轻松获取表单中的文件和其他字段的数据。以下是一个简单的示例代码用于处理文件上传[^1]: ```python from flask import Flask, request, jsonify app = Flask(__name__) @app.route('/upload', methods=['POST']) def upload_file(): if 'file' not in request.files: return jsonify({'error': 'No file part'}), 400 file = request.files['file'] if file.filename == '': return jsonify({'error': 'No selected file'}), 400 # 将文件保存到指定目录 save_path = '/path/to/save/' + file.filename file.save(save_path) return jsonify({'message': 'File uploaded successfully', 'filename': file.filename}), 200 ``` 此代码片段展示了如何从请求中提取文件对象并将它保存到本地磁盘。 #### 数据库连接与操作 为了将接收到的信息存入数据库，在 Docker 环境下的 Python 应用通常会使用 SQLAlchemy 这样的 ORM 工具或者直接调用驱动器（如 MySQL、PostgreSQL 驱动）。如果目标是 ClickHouse，则需先安装相应的驱动模块[^3]： ```bash pip install clickhouse-driver ``` 下面是一段向 ClickHouse 插入记录的例子： ```python import clickhouse_driver client = clickhouse_driver.Client(host='localhost') # 假设有一个名为 resources 的表格 data_to_insert = [ ('resource_name_1', 'type_value_1'), ('resource_name_2', 'type_value_2') ] query = """ INSERT INTO resources (name, type) VALUES """ client.execute(query, data_to_insert) print("Data inserted into database.") ``` 这段脚本创建了一个客户端实例并与 ClickHouse 数据库建立通信链路；随后定义了一组待插入的数据并通过执行 SQL 查询完成写入动作。 #### 综合应用案例 当需要同时处理文件上传及其元数据入库的情况时，可参照如下逻辑结构设计 API 路由函数： ```python from flask import Flask, request, jsonify import os import clickhouse_driver app = Flask(__name__) client = clickhouse_driver.Client(host='your_clickhouse_host') @app.route('/process_data', methods=['POST']) def process_data_and_save_db(): try: # 获取文件部分 if 'file' not in request.files or 'metadata' not in request.form: raise ValueError('Missing required fields.') metadata_json = request.form.get('metadata') file_obj = request.files['file'] # 存储文件至特定位置 unique_filename = str(uuid.uuid4())[:8]+'_'+secure_filename(file_obj.filename) full_filepath = os.path.join('/uploads/', unique_filename) file_obj.save(full_filepath) # 解析meta-data 并准备插入DB parsed_meta = json.loads(metadata_json) db_entry = { "filepath":full_filepath, **parsed_meta } insert_query = """ INSERT INTO your_table (...) VALUES ...""" client.execute(insert_query,[db_entry]) response_body={ "status":"success", "details":{ "uploadedFileName":unique_filename, "databaseEntryId":last_row_id_from_execute() } } return jsonify(response_body),201 except Exception as e: error_response={"status":"failure","reason":str(e)} return jsonify(error_response),500 ``` 以上综合了前面提到的技术要点——既实现了文件的安全落地又完成了关联属性同步录入数据库的功能。 ---