Python 中 requests 与 aiohttp 在实际项目中的选择策略详解

pip install requests

import requests
response = requests.get('https://www.example.com')
print(response.text)

import requests
params = {'key1': 'value1', 'key2': 'value2'}
headers = {'User-Agent': 'Mozilla/5.0'}
response = requests.get('https://www.example.com', params=params, headers=headers)
print(response.text)

import requests
response = requests.get('https://www.example.com')
print(response.status_code)
print(response.headers)
print(response.text)

import requests
response = requests.get('https://www.example.com')
if response.status_code == 200:
    print(response.text)
else:
    print('请求失败')

pip install aiohttp

import aiohttp
async def main():
    async with aiohttp.ClientSession() as session:
        async with session.get('https://www.example.com') as response:
            print(await response.text())
asyncio.run(main())

import aiohttp
async def main():
    async with aiohttp.ClientSession() as session:
        params = {'key1': 'value1', 'key2': 'value2'}
        headers = {'User-Agent': 'Mozilla/5.0'}
        async with session.get('https://www.example.com', params=params, headers=headers) as response:
            print(await response.text())
asyncio.run(main())

import aiohttp
async def main():
    async with aiohttp.ClientSession() as session:
        async with session.get('https://www.example.com') as response:
            print(response.status)
            print(response.headers)
            print(await response.text())
asyncio.run(main())

import aiohttp
async def main():
    async with aiohttp.ClientSession() as session:
        async with session.get('https://www.example.com') as response:
            if response.status == 200:
                print(await response.text())
            else:
                print('请求失败')
asyncio.run(main())

import requests
# 发送GET请求到新闻网站的某个页面
response = requests.get('https://news.example.com/article1')
if response.status_code == 200:
    # 处理获取到的新闻内容
    news_content = response.text
    print(news_content)
else:
    print('请求失败')

import aiohttp
import asyncio
async def fetch(session, url):
    async with session.get(url) as response:
        return await response.text()
async def main():
    async with aiohttp.ClientSession() as session:
        tasks = []
        urls = ['https://page1.example.com', 'https://page2.example.com', 'https://page3.example.com']
        for url in urls:
            task = asyncio.ensure_future(fetch(session, url))
            tasks.append(task)
        responses = await asyncio.gather(*tasks)
        for response in responses:
            print(response)
asyncio.run(main())