Apabila menggunakan pustaka requests-toolbelt, pastikan anda menyatakan kedua-dua nama fail dan pengepala Jenis Kandungan semasa mengisytiharkan medan untuk upload_file. Berikut ialah contoh:
filename = 'my_file.txt' m = MultipartEncoder(fields={'upload_file': (filename, open(filename, 'rb'))}) r = requests.post( url, data=m, headers={'Content-Type': m.content_type}, verify=False, ) print(r.request.headers) # confirm that the 'Content-Type' header has been set.
Pilihan lain ialah menggunakan permintaan Python atau perpustakaan HTTPX, yang kedua-duanya boleh mengendalikan muat naik fail penstriman dengan cekap. Berikut ialah contoh untuk setiap satu:
Menggunakan permintaan:
import requests url = '...' filename = '...' with open(filename, 'rb') as file: r = requests.post( url, files={'upload_file': file}, headers={'Content-Type': 'multipart/form-data'}, )
Menggunakan HTTPX:
import httpx url = '...' filename = '...' with open(filename, 'rb') as file: r = httpx.post( url, files={'upload_file': file}, )
HTTPX secara automatik menyokong muat naik fail penstriman, manakala permintaan memerlukan anda menetapkan pengepala Jenis Kandungan 'multipart/form-data'.
Kaedah .stream() FastAPI membolehkan anda mengelak daripada memuatkan fail besar ke dalam memori dengan mengakses badan permintaan sebagai strim . Untuk menggunakan pendekatan ini, ikuti langkah berikut:
Untuk memastikan saiz fail yang dimuat naik tidak melebihi had yang ditentukan, anda boleh menggunakan MaxSizeValidator. Berikut ialah contoh:
from streaming_form_data import streaming_form_data from streaming_form_data import MaxSizeValidator FILE_SIZE_LIMIT = 1024 * 1024 * 1024 # 1 GB def validate_file_size(chunk: bytes): if FILE_SIZE_LIMIT > 0: streaming_form_data.validators.MaxSizeValidator( FILE_SIZE_LIMIT). __call__(chunk)
Berikut ialah contoh titik akhir yang menggabungkan teknik ini:
from fastapi import FastAPI, File, Request from fastapi.responses import HTMLResponse from streaming_form_data.targets import FileTarget, ValueTarget from streaming_form_data import StreamingFormDataParser app = FastAPI() @app.post('/upload') async def upload(request: Request): # Parse the HTTP headers to retrieve the boundary string. parser = StreamingFormDataParser(headers=request.headers) # Register FileTarget and ValueTarget objects. file_ = FileTarget() data = ValueTarget() parser.register('upload_file', file_) parser.register('data', data) async for chunk in request.stream(): parser.data_received(chunk) # Validate file size (if necessary) validate_file_size(file_.content) # Process the uploaded file and data. return {'message': 'File uploaded successfully!'}
Atas ialah kandungan terperinci Bagaimana untuk Muat Naik Fail Besar dengan Cekap (≥3GB) ke Bahagian Belakang FastAPI?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!