Microsoft MVP성태의 닷넷 이야기
글쓴 사람
정성태 (seongtaejeong at gmail.com)
홈페이지
첨부 파일
 

(시리즈 글이 3개 있습니다.)
스크립트: 23. 파이썬 - WSGI를 만족하는 최소한의 구현 코드 및 PyCharm에서의 디버깅 방법
; https://www.sysnet.pe.kr/2/0/12794

스크립트: 64. 파이썬 - ASGI를 만족하는 최소한의 구현 코드
; https://www.sysnet.pe.kr/2/0/13633

스크립트: 65. 파이썬 - asgi 버전(2, 3)에 따라 달라지는 uvicorn 호스팅
; https://www.sysnet.pe.kr/2/0/13642




파이썬 - asgi 버전(2, 3)에 따라 달라지는 uvicorn 호스팅

지난 글에서 ASGI 버전 3을 만족하는 유형의 asgi 예제를 봤는데요,

# test_main.py

async def simple_app_v3(scope, receive, send):
    event = await receive()

    await send({
        'type': 'http.response.start',
        'status': 200,
        'headers': [
            [b'content-type', b'text/plain'],
        ]
    })

    await send({"type": "http.response.body", "body": b'Hello, world!'})


application = simple_app_v3

그에 앞서 나온 (문서에 Legacy Application으로 표기된) 버전 2는 scope와 receive/send가 분리된 형식으로 돼 있습니다. 이에 대한 예제를 보면,

jordaneremieff/asgi-examples
; https://github.com/jordaneremieff/asgi-examples

def simple_app_v2(scope):
    async def asgi(receive, send):
        await send(
            {
                "type": "http.response.start",
                "status": 200,
                "headers": [[b"content-type", b"text/plain"]],
            }
        )
        await send({"type": "http.response.body", "body": b"Hello, world!"})

    return asgi


application = simple_app_v2


scope을 받는 함수가 내부적으로 send/receive를 정의한 함수를 반환하는 형태로 구성하고 있는데요, 2가지(asgi v2, v3) 모두 uvicorn으로는 이렇게 실행할 수 있습니다.

uvicorn test_main:application --port 18090




부가적으로 uvicorn은 명령행에서 --interface 인자를 통해 asgi 버전을 지정할 수 있습니다. 그래서 simple_app_v2와 simple_app_v3에 따라 각각 다음과 같이 인자를 명시할 수도 있습니다.

[asgi v2]
uvicorn test_main:simple_app_v2 --port 18090 --interface asgi2

[asgi v3]
uvicorn test_main:simple_app_v3 --port 18090 --interface asgi3

만약 지정하지 않았다면 "auto"인데 자동으로 판단해 주는 것입니다. 그렇다면 uvicorn은 어떻게 v2, v3 인터페이스를 판단하는 걸까요? 혹시 def 정의에 붙는 async 유무에 따라 결정할까요?

실제로 이에 대한 테스트를 async 가변 인자에 내부적으로는 v3 규칙을 따르는 함수를 만들고,

async def simple_app_any(*args, **kwargs):
    scope = args[0]
    receive = args[1]
    send = args[2]

    event = await receive() // 내부 코드는 version 3 스펙을 따름

    await send({
        'type': 'http.response.start',
        'status': 200,
        'headers': [
            [b'content-type', b'text/plain'],
        ]
    })

    await send({"type": "http.response.body", "body": b'Hello, world!'})

이것을 uvicorn의 v2로 실행하면 당연히 오류가 발생할 것입니다.

$ uvicorn test_main:simple_app_any --port 18090 --interface asgi2
...[생략]...

Traceback (most recent call last):
  File "/home/kevin/.local/lib/python3.8/site-packages/uvicorn/protocols/http/httptools_impl.py", line 435, in run_asgi
    result = await app(  # type: ignore[func-returns-value]
  File "/home/kevin/.local/lib/python3.8/site-packages/uvicorn/middleware/proxy_headers.py", line 80, in __call__
    return await self.app(scope, receive, send)
  File "/home/kevin/.local/lib/python3.8/site-packages/uvicorn/middleware/asgi2.py", line 20, in __call__
    instance = self.app(scope)
TypeError: 'coroutine' object is not callable)

왜냐하면, v2 스펙상 self.app은 동기 함수로 약속돼 있기 때문에 async 함수로는 오류가 발생하는 것이 맞습니다. (단지, "TypeError: 'coroutine' object is not callable" 오류는 맞지 않는데요, 이에 대해서는 마지막에 설명하겠습니다.)

재미있는 것은 그렇다고 해서 v3 스펙으로 호출해도 여전히 오류가 발생한다는 점입니다.

$ uvicorn test_main:simple_app_any --port 18090 --interface asgi3
...[생략]...

Traceback (most recent call last):
  File "/home/kevin/.local/lib/python3.8/site-packages/uvicorn/protocols/http/httptools_impl.py", line 435, in run_asgi
    result = await app(  # type: ignore[func-returns-value]
  File "/home/kevin/.local/lib/python3.8/site-packages/uvicorn/middleware/proxy_headers.py", line 80, in __call__
    return await self.app(scope, receive, send)
TypeError: 'coroutine' object is not callable)

대신 이번에는 "await self.app(scope, receive, send)"로 비동기 호출을 했다는 것만 다릅니다. 하지만 그런데도 오류가 발생하는 것은 self.app이 (coroutine function이 아니라) coroutine으로 보관돼 있기 때문입니다. 아니... 왜 그런 것일까요? ^^




우선, 이 문제를 해석하려면 Coroutine과 Coroutine Function의 차이를 알아야 합니다. 이에 대해서는 다음의 글에 자세하게 설명하니 생략하고,

Coroutines vs Coroutine Functions in Python
; https://medium.com/geekculture/coroutines-vs-coroutine-functions-in-python-a3957c1a0f9b

따라서, asgi3 규약으로 호출했는데도 uvicorn은 "async def simple_app_any" 함수를 Coroutine Function으로 구분하지 않고 v2의 경우처럼 일반 함수로 인식해 그것에 대해 한 번 더 호출한 함수를 self.app에 보관해 두고 있었다고 추측할 수 있습니다. 결국 self.app에는 coroutine이 들어가게 되고 그것을 await 호출을 했으니 저런 오류가 발생한 것입니다.

그렇다면, 가변 인자를 갖는 함수로 정의된 경우라면 uvicorn이 한번 호출한다는 것을 가정하고 이렇게 만들어 주면 됩니다.

# uvicorn test_main:simple_app_any --port 18090 --interface asgi3


def simple_app_any_wrap():

    async def _handler(*args, **kwargs):
        scope = args[0]
        receive = args[1]
        send = args[2]
        await simple_app_any(scope, receive, send)

    return _handler


async def simple_app_any(*args, **kwargs):
    # ...[생략]...

뭐랄까, uvicorn은 asgi3 인자로 명시했지만 어찌 되었든 v2/v3를 판별하는 코드를 (아마도) scope, receive, send 3개의 인자를 갖고 있는지 여부로 판별하는 듯합니다. 만약 3개의 인자를 갖고 있다면 처음 한 번의 호출을 하지 않고, 그렇지 않다면 호출을 무조건 해버리는 것입니다.

실제로 위의 simple_app_any_wrap 함수에 임의로 3개의 인자를 받게 만들면,

def simple_app_any_wrap(arg1, arg2, arg3):
    # ...[생략]...

이제는 최초 한 번 호출을 하지 않으므로 이런 예외가 발생합니다.

Traceback (most recent call last):
  File "/home/kevin/.local/lib/python3.8/site-packages/uvicorn/protocols/http/httptools_impl.py", line 435, in run_asgi
    result = await app(  # type: ignore[func-returns-value]
  File "/home/kevin/.local/lib/python3.8/site-packages/uvicorn/middleware/proxy_headers.py", line 80, in __call__
    return await self.app(scope, receive, send)
TypeError: object function can't be used in 'await' expression

정리하면, asgi v3인 경우에는,

  • 인자를 아예 받지 않는 동기 함수에서, 한 번 호출되는 것을 가정해 3개의 인자(또는 가변 인자)를 받아 처리하는 함수를 반환하거나,
  • 인자를 3개 받아 처리하는 async 함수를 정의하거나,

반드시 저 2개 함수 정의 중 하나여야 합니다. 즉, 가변 함수를 직접 받는 함수를 정의할 수는 없습니다.




[이 글에 대해서 여러분들과 의견을 공유하고 싶습니다. 틀리거나 미흡한 부분 또는 의문 사항이 있으시면 언제든 댓글 남겨주십시오.]







[최초 등록일: ]
[최종 수정일: 6/11/2024]

Creative Commons License
이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이센스에 따라 이용하실 수 있습니다.
by SeongTae Jeong, mailto:techsharer at outlook.com

비밀번호

댓글 작성자
 




... 31  32  33  34  35  36  37  38  [39]  40  41  42  43  44  45  ...
NoWriterDateCnt.TitleFile(s)
12961정성태2/8/202215108.NET Framework: 1151. C# - ffmpeg(FFmpeg.AutoGen)를 이용한 비디오 프레임의 크기 및 포맷 변경 예제(scaling_video.c) [7]파일 다운로드1
12960정성태2/8/202214319개발 환경 구성: 637. ffmpeg(FFmpeg.AutoGen)를 이용한 비디오 디코딩 예제(decode_video.c) - 세 번째 이야기
12959정성태2/7/202215413.NET Framework: 1150. C# - ffmpeg(FFmpeg.AutoGen)를 이용한 비디오 디코딩 예제(decode_video.c) - 두 번째 이야기 [2]파일 다운로드1
12958정성태2/6/202216198.NET Framework: 1149. C# - ffmpeg(FFmpeg.AutoGen) - 비디오 프레임 디코딩 [2]파일 다운로드1
12957정성태2/6/202215169개발 환경 구성: 636. ffmpeg.exe를 이용해 planar 포맷의 데이터를 packed 형식으로 변환하는 방법? [2]
12956정성태2/4/202214702.NET Framework: 1148. C# - ffmpeg(FFmpeg.AutoGen) - decoding 과정 [2]파일 다운로드1
12955정성태2/4/202214095개발 환경 구성: 635. 비주얼 스튜디오에서 실행하던 ASP.NET Core (.NET Framework) 응용 프로그램을 명령행에서 실행하는 방법 (2)
12954정성태2/4/202213363VS.NET IDE: 173. 비주얼 스튜디오 - Output 창에 색상이 지정된 출력 결과가 "[39m[22m" 식의 문자로 나오는 문제
12953정성태2/2/202213402Linux: 48. Windows 11 + WSL 우분투 GUI 환경에서 한글 출력
12952정성태2/2/202214315.NET Framework: 1148. C# - ffmpeg(FFmpeg.AutoGen)를 이용한 오디오 필터 예제(filter_audio.c)파일 다운로드1
12951정성태2/2/202213776.NET Framework: 1147. C# - ffmpeg(FFmpeg.AutoGen)를 이용한 오디오 필터링 예제(filtering_audio.c)파일 다운로드1
12950정성태2/1/202214023.NET Framework: 1146. .NET 6에 추가되지 않은 Generic Math (예: INumber<T>)
12949정성태2/1/202213350.NET Framework: 1145. C# - ffmpeg(FFmpeg.AutoGen) - Codec 정보 열람 및 사용 준비파일 다운로드1
12948정성태1/30/202214014.NET Framework: 1144. C# - ffmpeg(FFmpeg.AutoGen) AVFormatContext를 이용해 ffprobe처럼 정보 출력파일 다운로드1
12947정성태1/30/202215235개발 환경 구성: 634. ffmpeg.exe - 기존 동영상 컨테이너에 다중 스트림을 추가하는 방법
12946정성태1/28/202213903오류 유형: 792. .NET Core - 로컬 개발 중에 docker 호스팅으로 바꾸는 경우 SQL 서버 접근 방법
12945정성태1/28/202213984오류 유형: 791. SQL 서버 로그인 시 localhost는 되고, 127.0.0.1로는 안 되는 문제
12944정성태1/28/202217375.NET Framework: 1143. C# - Entity Framework Core 6 개요
12943정성태1/27/202216663.NET Framework: 1142. .NET 5+로 포팅 시 플랫폼 호환성 경고 메시지(SYSLIB0006, SYSLIB0011, CA1416) [1]파일 다운로드1
12942정성태1/27/202216135.NET Framework: 1141. XmlSerializer와 Dictionary 타입파일 다운로드1
12941정성태1/26/202217385오류 유형: 790. AKS/k8s - pod 상태가 Pending으로 지속되는 경우
12940정성태1/26/202213838오류 유형: 789. AKS에서 hpa에 따른 autoscale 기능이 동작하지 않는다면?
12939정성태1/25/202214967.NET Framework: 1140. C# - ffmpeg(FFmpeg.AutoGen)를 이용해 MP3 오디오 파일 인코딩/디코딩하는 예제파일 다운로드1
12938정성태1/24/202218175개발 환경 구성: 633. Docker Desktop + k8s 환경에서 local 이미지를 사용하는 방법
12937정성태1/24/202215749.NET Framework: 1139. C# - ffmpeg(FFmpeg.AutoGen)를 이용해 오디오(mp2) 인코딩하는 예제(encode_audio.c) [2]파일 다운로드1
12936정성태1/22/202215346.NET Framework: 1138. C# - ffmpeg(FFmpeg.AutoGen)를 이용해 멀티미디어 파일의 메타데이터를 보여주는 예제(metadata.c)파일 다운로드1
... 31  32  33  34  35  36  37  38  [39]  40  41  42  43  44  45  ...