Python에서 asyncio 이벤트 루프를 닫으면 예외가 발생합니다.

Question

Windows에서 Python 3.4에서 asyncio 및 aiohttp를 사용하는 https 요청의 경우 2 개의 이벤트 루프를 사용해야합니다. 셸 명령을 실행하는 ProactorEventLoop 및 HTTPS 요청의 기본 이벤트 루프. ProactorEventLoop은 HTTPS 명령에 대해 작동하지 않습니다.

다음 코드는 새로 만든 기본 이벤트 루프를 사용하고 Windows에서 마지막으로 닫으려고하면 어떻게되는지 보여줍니다.

> Traceback (most recent call last): 
> File "C:\BuildUtilities\p3.4env0\lib\site-packages\aiohttp\connector.py", line 56, in __del__ 
> self.close() 
> File "C:\BuildUtilities\p3.4env0\lib\site-packages\aiohttp\connector.py", line 97, in close 
> transport.close() 
> File "C:\Python34\Lib\asyncio\selector_events.py", line 375, in close 
> self._loop.remove_reader(self._sock_fd) 
> File "C:\Python34\Lib\asyncio\selector_events.py", line 155, in remove_reader 
> key = self._selector.get_key(fd) 
> AttributeError: 'NoneType' object has no attribute 'get_key' 

그것을 언급하는 것은 예외를 제거하고 그 이유를 모르는 : 아래 그림과 같이 내가 마지막에 loop.close를 호출하면 나는 말에 예외를 얻을. 하나 밖에없는

import asyncio 
import aiohttp 

@asyncio.coroutine 
def get_body(url): 
    response = yield from aiohttp.request('GET', url) 
    return (yield from response.read_and_close()) 

#loop = asyncio.ProactorEventLoop() 
loop = asyncio.new_event_loop() 
asyncio.set_event_loop(loop) 

f = asyncio.async(get_body('https://www.google.com')) 
try: 
    loop.run_until_complete(f) 
except Exception as e: 
    print(e) 

if f.result(): 
    print(f.result()) 

loop.close() 

감사합니다, greenaj

Answer 1

업데이트는 : 문제는 GitHub의 버전 (0.7.2)에 고정되는 것 같습니다. 오류가 생성되지 않습니다. @danj.py said으로 지정하면 "Get rid of __del__ in connector" commit으로 고정됩니다.

---

ProactorEventLoop 또는 Windows와 관련이 없습니다. 나는 기본 이벤트 루프와 우분투에 오류를 재현 할 수 있습니다 사용이 올바른 것 때문에

#!/usr/bin/env python3 
import asyncio 
import aiohttp # $ pip install aiohttp 

@asyncio.coroutine 
def get_body(url): 
    response = yield from aiohttp.request('GET', url) 
    return (yield from response.read_and_close()) 

loop = asyncio.get_event_loop() 
body = loop.run_until_complete(get_body('https://stackoverflow.com/q/23283502')) 
print(len(body), type(body), body[:200]) 
loop.close() 

그것은 aiohttp에서 버그가 수 있습니다.

#!/usr/bin/env python3 
import asyncio 
from contextlib import closing 
from urllib.parse import urlsplit 

@asyncio.coroutine 
def get_body(url): 
    # parse url 
    url = urlsplit(url) 
    path = '/' * (not url.path) + url.path + '?' * bool(url.query) + url.query 
    # open connection 
    reader, writer = yield from asyncio.open_connection(
     host=url.hostname, 
     port=url.port or (443 if url.scheme == 'https' else 80), 
     ssl=(url.scheme == 'https')) 
    with closing(writer): 
     # send request 
     writer.write(b'GET ' + path.encode('ascii') + b' HTTP/1.1\r\n' 
        b'Host: ' + url.netloc.encode('ascii') + b'\r\n' 
        b'Connection: close\r\n\r\n') 
     # read headers 
     while True: 
      line = yield from reader.readline() 
      line = line.rstrip(b'\n\r') 
      print(line.decode('latin-1')) 
      if not line: 
       break 
     # read body 
     body = yield from reader.read() 
    return body 

loop = asyncio.get_event_loop() 
body = loop.run_until_complete(get_body('https://stackoverflow.com/q/23283502')) 
print(len(body), type(body), body[:200]) 
loop.close() 

참고 :

는 요청이 aiohttp없이하면 오류가없는 예는 예를 들어, 완전히 동일하지 있으며, 후자는 리디렉션을 수행하지 않습니다.

Answer 2

J.F. Seioastian은 aiohttp의 버그라고 정확합니다.

다음 커밋을 통해이 문제가 해결 된 것 같습니다.

https://github.com/KeepSafe/aiohttp/commit/a229110539e93c21ae0198f6f883ae3e40ea866b#diff-7f25afde79f309e2f8722c26cf1f10ad

이 글을 쓰는 현재, pypi에 그것의 방법을 만든 것을 표시되지 않습니다.

Answer 3

사실 파이썬 3.4 자체가 (고정) 버그 : http://bugs.python.org/issue21435

임시 솔루션 (파이썬 3.3 지원을 위해이) 나는 https://github.com/KeepSafe/aiohttp/pull/48

는하지만, 다시 말을 끌어 오기 요청 루트를 만들어 문제는 Python 3.4.0의 가비지 컬렉터입니다 (향후 Python 3.4.1 bugfix 릴리즈로 해결됨).