Python 并发未来,每个线程,每个代理
Python Concurent Future, Each Thread, Each Proxy
所以我有这样的代码:
站点列表
a.com
b.com
c.com
d.com
e.com
etc
代理列表
1.1.1.1
2.2.2.2
etc
def extract(url, proxy):
print(f'Thread Name : {threading.current_thread().name}')
print(f'We are using this proxy : {proxy}')
headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:80.0) Gecko/20100101 Firefox/80.0'}
try:
r = requests.get(url, headers=headers, proxies={'http' : proxy,'https': proxy}, timeout=2)
soup = BeautifulSoup(r.text, 'html.parser')
page_title = soup.find('title').text.strip()
print(page_title)
except:
pass
我需要循环提取功能,直到完成列表中的所有站点。据我所知,python 中有 concurent.futures
,所以我尝试这样做:
with concurrent.futures.ThreadPoolExecutor(max_workers=2) as executor:
executor.map(extract, url_list, proxy_list)
问题是,假设我只有 2 个有效代理,并且我有 5 个站点,代码将在仅 2 个代理中停止,
如何解决这个问题?所以我想要的是每个线程都有自己的代理,并完成任务,直到列表中的所有站点完成..
谢谢
使用 itertools.cycle 创建一个无限期重复您的代理的迭代器
with concurrent.futures.ThreadPoolExecutor(max_workers=2) as executor:
executor.map(extract, url_list, itertools.cycle(proxy_list))
所以我有这样的代码:
站点列表
a.com
b.com
c.com
d.com
e.com
etc
代理列表
1.1.1.1
2.2.2.2
etc
def extract(url, proxy):
print(f'Thread Name : {threading.current_thread().name}')
print(f'We are using this proxy : {proxy}')
headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:80.0) Gecko/20100101 Firefox/80.0'}
try:
r = requests.get(url, headers=headers, proxies={'http' : proxy,'https': proxy}, timeout=2)
soup = BeautifulSoup(r.text, 'html.parser')
page_title = soup.find('title').text.strip()
print(page_title)
except:
pass
我需要循环提取功能,直到完成列表中的所有站点。据我所知,python 中有 concurent.futures
,所以我尝试这样做:
with concurrent.futures.ThreadPoolExecutor(max_workers=2) as executor:
executor.map(extract, url_list, proxy_list)
问题是,假设我只有 2 个有效代理,并且我有 5 个站点,代码将在仅 2 个代理中停止,
如何解决这个问题?所以我想要的是每个线程都有自己的代理,并完成任务,直到列表中的所有站点完成..
谢谢
使用 itertools.cycle 创建一个无限期重复您的代理的迭代器
with concurrent.futures.ThreadPoolExecutor(max_workers=2) as executor:
executor.map(extract, url_list, itertools.cycle(proxy_list))