我想使用urllib.request.urlretrieve与多处理模块一起下载一些文件并对它们进行一些处理。然而,每一个我尝试运行我的程序时,它给我的错误:python3 URLError未知的url类型http
multiprocessing.pool.RemoteTraceback:
"""
Traceback (most recent call last):
File "/usr/lib/python3.4/multiprocessing/pool.py", line 119, in worker
result = (True, func(*args, **kwds))
File "/usr/lib/python3.4/multiprocessing/pool.py", line 44, in mapstar
return list(map(*args))
File "./thumb.py", line 13, in download_and_convert
filename, headers = urlretrieve(url)
File "/usr/lib/python3.4/urllib/request.py", line 186, in urlretrieve
with contextlib.closing(urlopen(url, data)) as fp:
File "/usr/lib/python3.4/urllib/request.py", line 161, in urlopen
return opener.open(url, data, timeout)
File "/usr/lib/python3.4/urllib/request.py", line 463, in open
response = self._open(req, data)
File "/usr/lib/python3.4/urllib/request.py", line 486, in _open
'unknown_open', req)
File "/usr/lib/python3.4/urllib/request.py", line 441, in _call_chain
result = func(*args)
File "/usr/lib/python3.4/urllib/request.py", line 1252, in unknown_open
raise URLError('unknown url type: %s' % type)
urllib.error.URLError: <urlopen error unknown url type: http>
"""
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "./thumb.py", line 27, in <module>
pool.map(download_and_convert, enumerate(csvr))
File "/usr/lib/python3.4/multiprocessing/pool.py", line 260, in map
return self._map_async(func, iterable, mapstar, chunksize).get()
File "/usr/lib/python3.4/multiprocessing/pool.py", line 599, in get
raise self._value
urllib.error.URLError: <urlopen error unknown url type: http>
,它似乎被噎死的URL是http://phytoimages.siu.edu/users/vitt/10_27_06_2/Equisetumarvense.JPG
。这里是我的代码:
#!/usr/bin/env python3
from subprocess import Popen
from sys import argv, stdin
import csv
from multiprocessing import Pool
from urllib.request import urlretrieve
def download_and_convert(args):
num, url_list = args
url = url_list[0]
try:
filename, headers = urlretrieve(url)
except:
print(url)
raise
Popen(["convert", filename, "-resize", "250x250",\
str(num)+'.'+url.split('.')[-1]])
if __name__ == "__main__":
csvr = csv.reader(open(argv[1]))
if(len(argv) > 2): nprocs = argv[2]
else: nprocs = None
pool = Pool(processes=nprocs)
pool.map(download_and_convert, enumerate(csvr))
我不知道为什么这个错误发生。难道是因为我正在使用多处理?如果任何人都可以帮助我,那将非常感激。
编辑:这是它尝试处理的第一个url,如果我更改它并不会更改错误。
你说,“它似乎窒息的网址是......”。你能证实吗?我在您的except块中看到了一个“print(url)”,但在您的问题中我看不到这个输出。如果你在一个单独的文件中隔离包含该URL的行,你能重现错误吗?你可以在你的问题中发布该行吗? – larsks
是的,那就是从外部打印输出的行。 – Aereaux
我还应该提到,这是我处理的文件中的第一个URL,如果我删除它,会给我提供与下一个url相同的错误。 – Aereaux