Python中的HTTP高手：如何玩转requests模块

news2024/10/10 11:21:34

引言

在日常开发工作中，我们经常需要从远程服务器获取信息或向其发送数据。比如，当你要抓取网页内容时，或者在开发Web应用时需要调用第三方API接口等场景下，掌握如何高效地发送HTTP请求就显得尤为重要了。Requests模块正是为此而生，它不仅简化了发送各种类型HTTP请求的过程，还提供了丰富的功能来处理响应结果。

基础语法介绍

核心概念

GET：用于请求访问已经被URI（统一资源标识符）识别的资源。
POST：用于向指定资源提交数据进行处理请求（例如提交表单或者上传文件）。数据被包含在请求体中。
PUT：从客户端向服务器发送被请求资源的整个表示。
DELETE：请求服务器删除URI所标识的资源。

基本用法

import requests

response = requests.get('https://www.example.com')
print(response.status_code)  # 打印状态码
print(response.text)         # 获取网页源码

上述代码展示了最基本的GET请求操作。通过requests.get()函数可以轻松发起一个GET请求，并接收服务器返回的数据。response对象包含了所有从服务器接收到的信息，如状态码、响应头以及正文等。

基础实例

假设我们需要查询某个天气预报网站提供的JSON数据接口，获取北京当前的天气情况，可以这样写：

url = 'http://api.openweathermap.org/data/2.5/weather?q=Beijing&appid=YOUR_API_KEY'
response = requests.get(url)
weather_data = response.json()
print(weather_data['main']['temp'])  # 输出温度

注意替换YOUR_API_KEY为你自己的API密钥。这段代码首先构造了一个URL地址，然后通过requests.get()方法发起请求，最后解析返回的JSON数据，提取出温度值打印出来。

进阶实例

在实际开发过程中，我们往往需要处理更加复杂的HTTP请求，比如设置自定义头部信息、携带认证凭据等。下面是一个使用POST请求的例子，演示如何向服务器提交表单数据：

login_data = {
    'username': 'admin',
    'password': 'secret'
}
headers = {'Content-Type': 'application/x-www-form-urlencoded'}

response = requests.post('https://example.com/login', data=login_data, headers=headers)

if response.status_code == 200:
    print('登录成功！')
else:
    print('登录失败，请检查用户名和密码是否正确。')

这里我们定义了一个字典login_data用来存储表单字段及其值，并通过headers参数指定了请求头类型。之后调用requests.post()方法发送POST请求，并检查返回的状态码判断登录是否成功。

实战案例

接下来分享一个我在项目中遇到的真实案例。当时我们的团队正在开发一款基于地理位置的服务应用，需要频繁地与地图提供商的API进行交互，以获取用户附近的兴趣点信息。

问题描述：由于涉及到敏感的用户隐私保护问题，我们必须确保每次请求都经过加密处理，并且能够有效地管理API调用次数，防止超出限制。
解决方案：我们决定采用requests库来构建一个封装好的API客户端类，该类支持动态添加认证信息、自动重试失败请求等功能。
代码实现：

class GeoServiceClient:
    def __init__(self, base_url, api_key):
        self.base_url = base_url
        self.api_key = api_key
        self.session = requests.Session()

    def _request(self, method, endpoint, params=None, retries=3):
        url = f'{self.base_url}/{endpoint}'
        headers = {'Authorization': f'Bearer {self.api_key}'}
        
        for _ in range(retries):
            try:
                resp = self.session.request(method, url, headers=headers, params=params)
                resp.raise_for_status()  # 如果响应状态码不是200，将抛出HTTPError异常
                return resp.json()
            except requests.exceptions.RequestException as e:
                print(f'Request failed: {e}')
                continue
        
        raise Exception('Max retries exceeded')

    def search_places(self, location, radius=5000):
        params = {'location': location, 'radius': radius}
        return self._request('GET', 'search', params=params)

# 使用示例
client = GeoServiceClient('https://maps.googleapis.com/maps/api/place/nearbysearch/json', 'YOUR_API_KEY')
results = client.search_places('40.7128,-74.0060')  # 查询纽约市附近地点
for result in results['results']:
    print(result['name'], result['vicinity'])