Github上代理池项目IPProxyPool运行时出现的一个错误

发布于 2022-09-04 18:12:22 字数 5284 浏览 12 评论 0

我在用Github一个开源代理池项目
运行的过程中,在某些情况下会出现以下错误:

Traceback (most recent call last):
  File "E:\proxy\IPProxyPool\spider\HtmlDownloader.py", line 18, in download
    r = requests.get(url=url, headers=config.get_header(), timeout=config.TIMEOUT)
  File "D:\anaconda\lib\site-packages\requests\api.py", line 70, in get
    return request('get', url, params=params, **kwargs)
  File "D:\anaconda\lib\site-packages\requests\api.py", line 56, in request
    return session.request(method=method, url=url, **kwargs)
  File "D:\anaconda\lib\site-packages\requests\sessions.py", line 488, in request
    resp = self.send(prep, **send_kwargs)
  File "D:\anaconda\lib\site-packages\requests\sessions.py", line 609, in send
    r = adapter.send(request, **kwargs)
  File "D:\anaconda\lib\site-packages\requests\adapters.py", line 479, in send
    raise ConnectTimeout(e, request=request)
requests.exceptions.ConnectTimeout: HTTPSConnectionPool(host='proxy-list.org', port=443): Max retrie
s exceeded with url: /english/index.php?p=9 (Caused by ConnectTimeoutError(<requests.packages.urllib
3.connection.VerifiedHTTPSConnection object at 0x0000000006B95390>, 'Connection to proxy-list.org ti
med out. (connect timeout=5)'))

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "D:\anaconda\lib\site-packages\sqlalchemy\engine\base.py", line 1139, in _execute_context
    context)
  File "D:\anaconda\lib\site-packages\sqlalchemy\engine\default.py", line 450, in do_execute
    cursor.execute(statement, parameters)
sqlite3.OperationalError: database is locked

The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "D:\anaconda\lib\multiprocessing\process.py", line 249, in _bootstrap
    self.run()
  File "D:\anaconda\lib\multiprocessing\process.py", line 93, in run
    self._target(*self._args, **self._kwargs)
  File "E:\proxy\IPProxyPool\spider\ProxyCrawl.py", line 26, in startProxyCrawl
    crawl.run()
  File "E:\proxy\IPProxyPool\spider\ProxyCrawl.py", line 56, in run
    self.crawl_pool.map(self.crawl, parserList)
  File "D:\anaconda\lib\site-packages\gevent\pool.py", line 308, in map
    return list(self.imap(func, iterable))
  File "D:\anaconda\lib\site-packages\gevent\pool.py", line 102, in next
    raise value.exc
  File "D:\anaconda\lib\site-packages\gevent\greenlet.py", line 534, in run
    result = self._run(*self.args, **self.kwargs)
  File "E:\proxy\IPProxyPool\spider\ProxyCrawl.py", line 67, in crawl
    response = Html_Downloader.download(url)
  File "E:\proxy\IPProxyPool\spider\HtmlDownloader.py", line 27, in download
    proxylist = sqlhelper.select(10)
  File "E:\proxy\IPProxyPool\db\SqlHelper.py", line 127, in select
    return query.order_by(Proxy.score.desc(), Proxy.speed).limit(count).all()
  File "D:\anaconda\lib\site-packages\sqlalchemy\orm\query.py", line 2613, in all
    return list(self)
  File "D:\anaconda\lib\site-packages\sqlalchemy\orm\query.py", line 2761, in __iter__
    return self._execute_and_instances(context)
  File "D:\anaconda\lib\site-packages\sqlalchemy\orm\query.py", line 2776, in _execute_and_instances

    result = conn.execute(querycontext.statement, self._params)
  File "D:\anaconda\lib\site-packages\sqlalchemy\engine\base.py", line 914, in execute
    return meth(self, multiparams, params)
  File "D:\anaconda\lib\site-packages\sqlalchemy\sql\elements.py", line 323, in _execute_on_connecti
on
    return connection._execute_clauseelement(self, multiparams, params)
  File "D:\anaconda\lib\site-packages\sqlalchemy\engine\base.py", line 1010, in _execute_clauseeleme
nt
    compiled_sql, distilled_params
  File "D:\anaconda\lib\site-packages\sqlalchemy\engine\base.py", line 1146, in _execute_context
    context)
  File "D:\anaconda\lib\site-packages\sqlalchemy\engine\base.py", line 1341, in _handle_dbapi_except
ion
    exc_info
  File "D:\anaconda\lib\site-packages\sqlalchemy\util\compat.py", line 202, in raise_from_cause
    reraise(type(exception), exception, tb=exc_tb, cause=cause)
  File "D:\anaconda\lib\site-packages\sqlalchemy\util\compat.py", line 185, in reraise
    raise value.with_traceback(tb)
  File "D:\anaconda\lib\site-packages\sqlalchemy\engine\base.py", line 1139, in _execute_context
    context)
  File "D:\anaconda\lib\site-packages\sqlalchemy\engine\default.py", line 450, in do_execute
    cursor.execute(statement, parameters)
sqlalchemy.exc.OperationalError: (sqlite3.OperationalError) database is locked [SQL: 'SELECT proxys.
ip AS proxys_ip, proxys.port AS proxys_port, proxys.score AS proxys_score \nFROM proxys ORDER BY pro
xys.score DESC, proxys.speed\n LIMIT ? OFFSET ?'] [parameters: (10, 0)]

stackoverflow看到以下解答:

SQLite locks the database when a write is made to it, such as when an UPDATE, INSERT or DELETE is sent. When using the ORM, these get sent on flush. The database will remain locked until there is a COMMIT or ROLLBACK.

结合上面的报错,我估计错误是这样产生的:
程序正在抓取过程中,爬到的代理都send到了flush,此时连接超时,程序来到HtmlDownloader.py文件的27行又开始调用数据库命令,从而引发了错误。

然而我技术很菜,研究了很久也不知道怎么改好,希望大神帮忙分析分析,谢谢!

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
列表为空,暂无数据
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文