如何加速API请求？

Question

我已经构建了以下使用google的place api获取电话号码的小程序，但速度非常慢。当我测试6个项目时，它需要4.86秒到1.99秒，我不知道为什么时间会发生重大变化。我对API非常陌生，所以我甚至不确定哪些事情可以/不能加快，哪些事情留给为API提供服务的Web服务器处理，以及我自己可以改变什么。

import requests,json,time
searchTerms = input("input places separated by comma")

start_time = time.time() #timer
searchTerms = searchTerms.split(',')
for i in searchTerms:
    r1 = requests.get('https://maps.googleapis.com/maps/api/place/textsearch/json?query='+ i +'&key=MY_KEY')
    a = r1.json()
    pid = a['results'][0]['place_id']
    r2 = requests.get('https://maps.googleapis.com/maps/api/place/details/json?placeid='+pid+'&key=MY_KEY')
    b = r2.json()
    phone = b['result']['formatted_phone_number']
    name = b['result']['name']
    website = b['result']['website']
    print(phone+' '+name+' '+website)

print("--- %s seconds ---" % (time.time() - start_time))

Answer 1

大多数时间并没有花在计算您的请求上。该时间用于与服务器通信。这是一件你无法控制的事情。

然而，您可以使用并行化来加速它。为每个请求创建一个单独的线程作为开始。

from threading import Thread

def request_search_terms(*args):
    #your logic for a request goes here
    pass

#...

threads = []
for st in searchTerms:
    threads.append (Thread (target=request_search_terms, args=(st,)))
    threads[-1].start()

for t in threads:
    t.join();

然后随着请求数量的增长使用线程池，这将避免重复创建线程的开销。

Answer 2

使用会话启用持久HTTP连接（因此您不必每次都建立新连接）

文档：请求高级使用-会话对象

Answer 3

您可能希望并行发送请求。Python提供了适合此类任务的多重处理模块。

示例代码：

from multiprocessing import Pool

def get_data(i):
    r1 = requests.get('https://maps.googleapis.com/maps/api/place/textsearch/json?query='+ i +'&key=MY_KEY')
    a = r1.json()
    pid = a['results'][0]['place_id']
    r2 = requests.get('https://maps.googleapis.com/maps/api/place/details/json?placeid='+pid+'&key=MY_KEY')
    b = r2.json()
    phone = b['result']['formatted_phone_number']
    name = b['result']['name']
    website = b['result']['website']
    return ' '.join((phone, name, website))

if __name__ == '__main__':
    terms = input("input places separated by comma").split(",")
    with Pool(5) as p:
        print(p.map(get_data, terms))