python requests高級耍法

昨天，我們更多的討論了request的基礎API，讓我們對它有了基礎的認知。學會上一課程，我們已經能寫點基本的爬蟲了。但是還不夠，因為，很多站點是需要登錄的，在站點的各個請求之間，是需要保持回話狀態的，有的站點還需要證書驗證，等等這一系列的問題，我們將在今天這一環節，加以討論。

1.會話對象

會話：session，就是你點進這個站點后，由瀏覽器與服務器之間保持的一次連接。這次連接里面，你跳轉頁面，或發起其他請求，服務器要求某些數據驗證。服務器不會叫你在每次跳轉時候進行驗證，而是用已驗證的結果進行跳轉。這樣就節省服務器資源，底層的TCP連接也會被重用。

跨請求保持數據（客戶端存數據）：

s = requests.Session()

s.get('http://httpbin.org/cookies/set/sessioncookie/123456789')
r = s.get("http://httpbin.org/cookies")

print(r.text)

回話提供請求默認數據（數據會被存到服務端）：

s = requests.Session()
s.auth = ('user', 'pass')
s.headers.update({'x-test': 'true'})

# 'x-test' 和 'x-test2' 一起發送給url
s.get('http://httpbin.org/headers', headers={'x-test2': 'true'})

注意：即便使用了session，方法級別的參數，仍然不會再跨請求保持。

以下代碼，另個請求分別有自己的cookies

s = requests.Session()
r = s.get('http://httpbin.org/cookies')
print(r.text)
# '{"cookies": {}}'

r = s.get('http://httpbin.org/cookies', cookies={'from-my': 'browser'})
print(r.text)
# '{"cookies": {"from-my": "browser"}}'

會話上下文管理器：是指用with 塊限定會話對象的使用范圍

with requests.Session() as s:
s.get('http://httpbin.org/cookies/set/sessioncookie/123456789')

 

2.請求與響應對象

任何時候，我們往服務器發消息，都會返回一個response的響應對象，同時，還能獲得我們自己創建的request對象

r = requests.get('http://en.wikipedia.org/wiki/Monty_Python')
print (r.headers)
print (r.request.headers)

在發送請求之前，需要對body獲header做一些額外處理，使用如下方法：

from requests import Request, Session


s = Session()
req = Request('GET', url,
data=data,
headers=header
)

#要想獲取有狀態的請求，使用：

prepped = s.prepare_request(req)

而不是使用：
prepped = req.prepare()

# do something with prepped.body
# do something with prepped.headers

resp = s.send(prepped,
stream=stream,
verify=verify,
proxies=proxies,
cert=cert,
timeout=timeout
)

print(resp.status_code)

3.SSL 證書驗證

requests.get('https://requestb.in')
requests.get('https://github.com', verify=True)
requests.get('https://github.com', verify='/path/to/certfile')
# 將驗證路徑保持在會話中
s = requests.Session()
s.verify = '/path/to/certfile'
# 忽略對SSL的驗證
requests.get('https://kennethreitz.org', verify=False)

4.客戶端證書

requests.get('https://kennethreitz.org', cert=('/path/client.cert', '/path/client.key'))

#證書在會話中

s = requests.Session()
s.cert = '/path/client.cert'

注意：本地證書的私有 key 必須是解密狀態。目前，Requests 不支持使用加密的 key。

這里補充一句：當登錄12306時喊你要安裝證書。當向有證書驗證要求的站點，就使用上面的代碼

http://5.CA 證書 科普：

Requests 默認附帶了一套它信任的根證書，來自於 Mozilla trust store。然而它們在每次 Requests 更新時才會更新。這意味着如果你固定使用某一版本的 Requests，你的證書有可能已經 太舊了。

從 Requests 2.4.0 版之后，如果系統中裝了 certifi 包，Requests 會試圖使用它里邊的 證書。這樣用戶就可以在不修改代碼的情況下更新他們的可信任證書。

6.響應體內容工作流

import requests

# 默認情況下，發起請求會同時下載響應頭和響應體（就是響應內容）
tarball_url = 'https://github.com/kennethreitz/requests/tarball/master'
# 如果將stream=True 則會推遲響應內容的下載
r = requests.get(tarball_url, stream=True)
# 這里就是：滿足某種條件才去下載
if int(r.headers['content-length']) < TOO_LONG:
content = r.content

# 在請求中把 stream 設為 True，Requests 無法將連接釋放回連接池，
# 除非消耗了所有的數據，或者調用了 Response.close。
# 這樣會帶來連接效率低下的問題。如果在使用 stream=True 的同時還在部分讀取請求的 body（或者完全沒有讀取 body），
# 那么就應該使用 with 語句發送請求，這樣可以保證請求一定會被關閉
with requests.get('http://httpbin.org/get', stream=True) as r:
# 這里處理響應
content = r.content

7.保持活動狀態（持久連接）科普

同一會話內的持久連接是完全自動處理的，同一會話內你發出的任何請求都會自動復用恰當的連接。

注意：只有所有的響應體數據被讀取完畢連接才會被釋放回連接池；所以確保將 stream 設置為 False 或讀取 Response 對象的 content 屬性。

8.流式上傳

Requests支持流式上傳，這允許發送大的數據流或文件，而無需先把它們讀入內存。要使用流式上傳，需，為請求體，提供一個類文件對象即可：

with open('massive-body') as f:
requests.post('http://some.url/streamed', data=f)

注意的問題：

最好使用二進制模式打開文件。這是因為 requests 有默認設置 header 中的 Content-Length，在這種情況下該值會被設為文件的字節數。如果用文本模式打開文件，就可能碰到錯誤

9.塊編碼請求

對於出去和進來的請求，Requests 也支持分塊傳輸編碼。要發送一個塊編碼的請求，僅需為請求體提供一個生成器（或任意沒有具體長度的迭代器）

def gen():
yield 'hi'
yield 'there'

requests.post('http://some.url/chunked', data=gen())

注意：

對於分塊的編碼請求，最好使用 Response.iter_content() 對其數據進行迭代。在理想情況下，request 會設置 stream=True，這樣就可以通過調用 iter_content 並將分塊大小參數設為 none，從而進行分塊的迭代。如果要設置分塊的最大體積，可以把分塊大小參數設為任意整數。

說白了，就是段點續傳

妹的，報了一堆錯。先記錄在這，后面遇到了再研究

10.POST 多個分塊編碼的文件

上傳圖片

import requests

url = 'http://httpbin.org/post'
multiple_files = [
('images', ('foo.png', open('foo.png', 'rb'), 'image/png')),
('images', ('bar.png', open('bar.png', 'rb'), 'image/png'))]
r = requests.post(url, files=multiple_files)
print (r.text)

11.事件掛鈎

import requests


def print_url(r, *args, **kwargs):
print(r.url)


# Requests有一個鈎子系統，你可以用來操控部分請求過程，或信號事件處理。
# 在產生響應之前調用print_url 就是server響應之前的回調
hooks = dict(response=print_url)
r = requests.get('http://httpbin.org', hooks=dict(response=print_url))
print (r.text)

也沒看有什么用

12.自定義身份驗證

import requests
from requests.auth import AuthBase


class PizzaAuth(AuthBase):

def __init__(self, username):
# setup any auth-related data here
self.username = username

def __call__(self, r):
# modify and return the request
r.headers['X-Pizza'] = self.username
return r

#注意：auth參數必須是一個可調用對象 實現了 __call__ 方法
requests.get('http://pizzabin.org/admin', auth=PizzaAuth('kenneth'))

作用就是在請求發出之前，有機會修改請求

13.流式請求

 

import requests

r = requests.get('http://httpbin.org/stream/20', stream=True)

for line in r.iter_lines():

# filter out keep-alive new lines
if line:
decoded_line = line.decode('utf-8')
print(json.loads(decoded_line))

 

就是將請求參數設置stream=True

import requests

r = requests.get('http://httpbin.org/stream/20', stream=True)

#當使用 decode_unicode=True 在 Response.iter_lines() 或 Response.iter_content() 中#時，需要提供一個編碼方式，以防服務器沒有提供默認回退編碼，從而導致錯誤

if r.encoding is None:
r.encoding = 'utf-8'#設置編碼方式
for line in r.iter_lines(decode_unicode=True):
if line:
print(json.loads(line))

 

#注意：iter_lines 不保證重進入時的安全性。多次調用該方法 會導致部分收到的數據丟失。#如果要在多處調用它，就應該使用生成的迭代器對象:

lines = r.iter_lines()
# 保存第一行以供后面使用，或者直接跳過

first_line = next(lines)

for line in lines:
print(line)

 

不曉得各位看懂什么是流式請求沒。指的不是請求是流，而是請求返回的數據流。返回一點即取一點。而不是普通的是返回完成后在取內容

14.代理

 

import requests

proxies = {
"http": "http://10.10.1.10:3128",
"https": "http://10.10.1.10:1080",
}

requests.get("http://example.org", proxies=proxies)

代理：就是你訪問一個網站，其實並不是你直接訪問的，而是你發請求給A機器，A機器取請求B機器。B返回給A，A再返回給你。代理就是中間人的意思。為什么需要代理？因為：反爬蟲網站一般使用IP來識別一個機器。老是一個IP再不停訪問網站，該網站就會把這個IP拉入黑名單，不允許訪問。這時，就需要很多IP再擾亂反爬蟲工具的思維，避免封IP。

 

15.SOCKS

除了基本的 HTTP 代理，Request 還支持 SOCKS 協議的代理。這是一個可選功能，若要使用， 你需要安裝第三方庫。

在后面的項目實戰中，我們將會使用

16.HTTP動詞

GET、OPTIONS、HEAD、POST、PUT、PATCH、DELETE

GET POST最常用

PUT，DELETE在調用rest的接口時，也會用到

17.定制動詞

有些服務器不接受GET POST等，要求用自定義的，就使用如下方法

r = requests.request('MKCOL', url, data=data)

r.status_code

18.響應頭鏈接字段

許多 HTTP API 都有響應頭鏈接字段的特性，它們使得 API 能夠更好地自我描述和自我顯露。

比如在使用分頁的情況下最有用

url = 'https://api.github.com/users/kennethreitz/repos?page=1&per_page=10'
r = requests.head(url=url)
print(r.headers['link'])
print(r.links["next"])

19.阻塞和非阻塞

使用默認的傳輸適配器，Requests 不提供任何形式的非阻塞 IO。 Response.content 屬性會阻塞，直到整個響應下載完成。如果你需要更多精細控制，該庫的數據流功能（見 流式請求） 允許你每次接受少量的一部分響應，不過這些調用依然是阻塞式的。

如果你對於阻塞式 IO 有所顧慮，還有很多項目可以供你使用，它們結合了 Requests 和 Python 的某個異步框架。典型的優秀例子是 grequests 和 requests-futures。

20.Header 排序

在某些特殊情況下你也許需要按照次序來提供 header，如果你向 headers 關鍵字參數傳入一個OrderedDict，就可以向提供一個帶排序的 header。然而，Requests 使用的默認 header 的次序會被優先選擇，這意味着如果你在 headers 關鍵字參數中覆蓋了默認 header，和關鍵字參數中別的 header 相比，它們也許看上去會是次序錯誤的。

如果這個對你來說是個問題，那么用戶應該考慮在 Session 對象上面設置默認 header，只要將 Session 設為一個定制的 OrderedDict 即可。這樣就會讓它成為優選的次序。

以上內容，是request的高級耍法，也不算好高級。接下來的一周，我們將着重討論如何解析網頁。當然，這一部分內容不會包含JS生成的HTML。這個我們將會在項目實戰環節再討論。

 

轉載:https://zhuanlan.zhihu.com/p/30251855