Phiên PUT Python

Thực hiện một yêu cầu

Bắt đầu bằng cách nhập mô-đun aiohttp và asyncio

import aiohttp
import asyncio

Bây giờ, hãy thử lấy một trang web. Ví dụ: hãy truy vấn

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

Bây giờ, chúng ta có một tên là

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

Để thực hiện yêu cầu HTTP POST, hãy sử dụng coroutine

session.post['//httpbin.org/post', data=b'data']

Các phương thức HTTP khác cũng có sẵn

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

Để thực hiện một số yêu cầu đến cùng một trang đơn giản hơn, có thể sử dụng tham số

async with aiohttp.ClientSession['//httpbin.org'] as session:
    async with session.get['/get']:
        pass
    async with session.post['/post', data=b'data']:
        pass
    async with session.put['/put', data=b'data']:
        pass

async with aiohttp.ClientSession['//httpbin.org'] as session:
    async with session.get['/get']:
        pass
    async with session.post['/post', data=b'data']:
        pass
    async with session.put['/put', data=b'data']:
        pass

async with aiohttp.ClientSession['//httpbin.org'] as session:
    async with session.get['/get']:
        pass
    async with session.post['/post', data=b'data']:
        pass
    async with session.put['/put', data=b'data']:
        pass

Ghi chú

Không tạo phiên theo yêu cầu. Nhiều khả năng bạn cần một phiên cho mỗi ứng dụng thực hiện tất cả các yêu cầu hoàn toàn

Các trường hợp phức tạp hơn có thể yêu cầu một phiên trên mỗi trang web, e. g. một cho Github và một cho Facebook API. Dù sao thì việc tạo phiên cho mọi yêu cầu là một ý tưởng rất tồi

Một phiên chứa một nhóm kết nối bên trong. Sử dụng lại kết nối và duy trì kết nối [cả hai đều được bật theo mặc định] có thể tăng tốc tổng hiệu suất

Việc sử dụng trình quản lý bối cảnh phiên là không bắt buộc nhưng nên gọi phương thức

async with aiohttp.ClientSession['//httpbin.org'] as session:
    async with session.get['/get']:
        pass
    async with session.post['/post', data=b'data']:
        pass
    async with session.put['/put', data=b'data']:
        pass

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

Truyền tham số trong URL

Bạn thường muốn gửi một số loại dữ liệu trong chuỗi truy vấn của URL. Nếu bạn đang tạo URL theo cách thủ công, thì dữ liệu này sẽ được cung cấp dưới dạng các cặp khóa/giá trị trong URL sau dấu chấm hỏi, e. g.

async with aiohttp.ClientSession['//httpbin.org'] as session:
    async with session.get['/get']:
        pass
    async with session.post['/post', data=b'data']:
        pass
    async with session.put['/put', data=b'data']:
        pass

async with aiohttp.ClientSession['//httpbin.org'] as session:
    async with session.get['/get']:
        pass
    async with session.post['/post', data=b'data']:
        pass
    async with session.put['/put', data=b'data']:
        pass

async with aiohttp.ClientSession['//httpbin.org'] as session:
    async with session.get['/get']:
        pass
    async with session.post['/post', data=b'data']:
        pass
    async with session.put['/put', data=b'data']:
        pass

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

Bạn có thể thấy rằng URL đã được mã hóa chính xác bằng cách in URL

Để gửi dữ liệu có nhiều giá trị cho cùng một khóa có thể được sử dụng;

Cũng có thể chuyển danh sách gồm 2 bộ dữ liệu mục làm tham số, trong trường hợp đó, bạn có thể chỉ định nhiều giá trị cho mỗi khóa

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

Bạn cũng có thể chuyển nội dung dưới dạng thông số, nhưng hãy cẩn thận – nội dung không được mã hóa bởi thư viện. Lưu ý rằng

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

Ghi chú

aiohttp thực hiện chuẩn hóa URL trong nội bộ trước khi gửi yêu cầu

Canonicalization mã hóa phần máy chủ bằng codec và áp dụng cho các phần đường dẫn và truy vấn

Ví dụ:

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

Đôi khi việc chuẩn hóa không được mong muốn nếu máy chủ chấp nhận đại diện chính xác và không tự báo giá lại URL

Để tắt chuẩn hóa, hãy sử dụng tham số

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

Cảnh báo

Truyền tham số sẽ ghi đè

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

Nội dung phản hồi và mã trạng thái

Chúng tôi có thể đọc nội dung phản hồi của máy chủ và mã trạng thái của nó. Xem xét lại dòng thời gian GitHub

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

in ra một cái gì đó như

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

Nội dung phản hồi nhị phân

Bạn cũng có thể truy cập nội dung phản hồi dưới dạng byte, đối với các yêu cầu không phải văn bản

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

Mã hóa chuyển đổi

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

Bạn có thể kích hoạt hỗ trợ mã hóa chuyển đổi

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

Yêu cầu JSON

Bất kỳ phương thức yêu cầu nào của phiên như , , v.v. chấp nhận tham số json

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

Theo mặc định, phiên sử dụng mô-đun tiêu chuẩn của python để tuần tự hóa. Nhưng có thể sử dụng

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

Ghi chú

Thư viện

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

Nội dung phản hồi JSON

Ngoài ra còn có bộ giải mã JSON tích hợp, trong trường hợp bạn đang xử lý dữ liệu JSON

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

Trong trường hợp giải mã JSON không thành công, sẽ đưa ra một ngoại lệ. Có thể chỉ định chức năng mã hóa và giải mã tùy chỉnh cho cuộc gọi

Ghi chú

Các phương pháp trên đọc toàn bộ nội dung phản hồi vào bộ nhớ. Nếu bạn định đọc nhiều dữ liệu, hãy cân nhắc sử dụng phương pháp phản hồi trực tuyến được ghi lại bên dưới

Nội dung phản hồi trực tuyến

Trong khi các phương thức , và rất tiện lợi, bạn nên sử dụng chúng một cách cẩn thận. Tất cả các phương thức này tải toàn bộ phản hồi trong bộ nhớ. Ví dụ: nếu bạn muốn tải xuống nhiều tệp có kích thước gigabyte, các phương thức này sẽ tải tất cả dữ liệu trong bộ nhớ. Thay vào đó bạn có thể sử dụng thuộc tính. Nó là một thể hiện của lớp. Mã hóa chuyển đổi

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

Tuy nhiên, nói chung, bạn nên sử dụng một mẫu như thế này để lưu nội dung đang được truyền trực tuyến vào một tệp

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

Không thể sử dụng và sau khi đọc rõ ràng từ

Yêu cầu POST phức tạp hơn

Thông thường, bạn muốn gửi một số dữ liệu được mã hóa biểu mẫu – giống như biểu mẫu HTML. Để làm điều này, chỉ cần chuyển một từ điển đến đối số dữ liệu. Từ điển dữ liệu của bạn sẽ tự động được mã hóa theo mẫu khi có yêu cầu

session.post['//httpbin.org/post', data=b'data']

session.post['//httpbin.org/post', data=b'data']

Nếu bạn muốn gửi dữ liệu không được mã hóa theo mẫu, bạn có thể thực hiện việc đó bằng cách chuyển thay vì. Dữ liệu này sẽ được đăng trực tiếp và loại nội dung được đặt thành 'application/octet-stream' theo mặc định

session.post['//httpbin.org/post', data=b'data']

Nếu bạn muốn gửi dữ liệu JSON

session.post['//httpbin.org/post', data=b'data']

Để gửi văn bản có loại nội dung phù hợp, chỉ cần sử dụng đối số

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

session.post['//httpbin.org/post', data=b'data']

POST một tệp được mã hóa nhiều phần

Để tải lên các tệp được mã hóa nhiều phần

session.post['//httpbin.org/post', data=b'data']

Bạn có thể đặt rõ ràng

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

session.post['//httpbin.org/post', data=b'data']

Nếu bạn chuyển một đối tượng tệp làm tham số dữ liệu, aiohttp sẽ tự động truyền nó đến máy chủ. Kiểm tra thông tin định dạng được hỗ trợ

Xem thêm

Tải lên trực tuyến

hỗ trợ nhiều loại tải lên trực tuyến, cho phép bạn gửi các tệp lớn mà không cần đọc chúng vào bộ nhớ

Là một trường hợp đơn giản, chỉ cần cung cấp một đối tượng giống như tệp cho cơ thể của bạn

session.post['//httpbin.org/post', data=b'data']

Hoặc bạn có thể sử dụng trình tạo không đồng bộ

session.post['//httpbin.org/post', data=b'data']

Bởi vì thuộc tính là một [cung cấp giao thức trình lặp không đồng bộ], bạn có thể xâu chuỗi các yêu cầu nhận và đăng cùng nhau

session.post['//httpbin.org/post', data=b'data']

Ghi chú

Trăn 3. 5 không có hỗ trợ riêng cho trình tạo không đồng bộ, hãy sử dụng thư viện

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

Không dùng nữa kể từ phiên bản 3. 1. ______170 vẫn hỗ trợ trình trang trí

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

ổ cắm web

hoạt động với websockets của khách hàng vượt trội

Bạn phải sử dụng coroutine để kết nối websocket của máy khách. Nó chấp nhận một url làm tham số đầu tiên và trả về, với đối tượng đó, bạn có thể giao tiếp với máy chủ websocket bằng các phương thức của phản hồi

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

Bạn phải sử dụng tác vụ websocket duy nhất cho cả việc đọc [e. g.

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

Hết giờ

Cài đặt thời gian chờ được lưu trữ trong cấu trúc dữ liệu

Theo mặc định, aiohttp sử dụng tổng thời gian chờ là 300 giây [5 phút], điều đó có nghĩa là toàn bộ thao tác sẽ kết thúc sau 5 phút

Giá trị có thể bị ghi đè bởi tham số thời gian chờ cho phiên [được chỉ định bằng giây]

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

Thời gian chờ có thể bị ghi đè cho một yêu cầu như

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

Các trường được hỗ trợ là

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

08

Số giây tối đa cho toàn bộ hoạt động bao gồm thiết lập kết nối, gửi yêu cầu và đọc phản hồi

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

09

Số giây tối đa để thiết lập kết nối của một kết nối mới hoặc chờ kết nối miễn phí từ nhóm nếu vượt quá giới hạn kết nối nhóm

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

10

Số giây tối đa để kết nối với một người ngang hàng cho một kết nối mới, không được cung cấp từ một nhóm

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

11

Số giây tối đa cho phép trong khoảng thời gian giữa việc đọc một phần dữ liệu mới từ một máy ngang hàng

Tất cả các trường đều là số float,

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

Do đó, thời gian chờ mặc định là

session.put['//httpbin.org/put', data=b'data']
session.delete['//httpbin.org/delete']
session.head['//httpbin.org/get']
session.options['//httpbin.org/get']
session.patch['//httpbin.org/patch', data=b'data']

Ghi chú

aiohttp hết thời gian chờ nếu giá trị bằng hoặc lớn hơn 5 giây. Thời gian chờ hết hạn ở giây tiếp theo lớn hơn

async def main[]:
    async with aiohttp.ClientSession[] as session:
        async with session.get['//httpbin.org/get'] as resp:
            print[resp.status]
            print[await resp.text[]]

asyncio.run[main[]]

Mức trần được thực hiện vì mục đích tối ưu hóa, khi nhiều tác vụ đồng thời được lên lịch để đánh thức vào những thời điểm tuyệt đối gần như giống nhau nhưng khác nhau. Nó dẫn đến rất nhiều lần đánh thức vòng lặp sự kiện, làm giảm hiệu suất

Việc tối ưu hóa thay đổi thời gian đánh thức tuyệt đối bằng cách lên lịch cho chúng chính xác cùng thời điểm với các hàng xóm khác, vòng lặp đánh thức mỗi giây một lần khi hết thời gian chờ

Thời gian chờ nhỏ hơn không được làm tròn để giúp kiểm tra;

Yêu cầu Phiên [] trong Python là gì?

Những gì được đưa vào Python?

Làm cách nào để gửi dữ liệu trong yêu cầu POST Python?

Làm thế nào chúng ta có thể nhận được một đối tượng Session?