Microsoft MVP성태의 닷넷 이야기
스크립트: 58. 파이썬 - async/await 기본 사용법 [링크 복사], [링크+제목 복사],
조회: 14950
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
 

(시리즈 글이 3개 있습니다.)
스크립트: 58. 파이썬 - async/await 기본 사용법
; https://www.sysnet.pe.kr/2/0/13423

스크립트: 59. 파이썬 - 비동기 호출 함수(run_until_complete, run_in_executor, create_task, run_in_threadpool)
; https://www.sysnet.pe.kr/2/0/13426

스크립트: 71. 파이썬 - asyncio의 ContextVar 전달
; https://www.sysnet.pe.kr/2/0/13899




파이썬 - async/await 기본 사용법

C# 개발자라면, 파이썬의 async/await를 유사한 경험으로 사용할 수 있습니다. 우선, 간단하게 콘솔 앱으로 예제를 작성해 볼까요? ^^

async def main_async():
    print('async called')

await main_async()

""" 
실행 결과:

  File "C:\test\main.py", line 6
    await main_async()
    ^
SyntaxError: 'await' outside function
"""

위의 코드를 실행하면 "실행 결과"에서 보는 바대로 await을 함수 밖에서 사용했다고 오류가 발생합니다. 그래서 이것을 함수에 담아서 다시 호출해 보면,

import time

async def do_something(delay: int=0):
    time.sleep(delay)
    return delay

def main():
    await do_something(3)

main()


""" 
실행 결과:

  File "/home/testusr/main.py", line 10
    await do_something(3)
    ^
SyntaxError: 'await' outside async function
"""

이번엔 async 함수가 아닌 곳에서 사용했다고 나옵니다. 그렇다면 main 함수를 async로 만들어야 하지만,

async def main():
    await do_something(3)

main()

""" 
실행 결과:

/home/testusr/main.py:12: RuntimeWarning: coroutine 'main' was never awaited
  main()
RuntimeWarning: Enable tracemalloc to get the object allocation traceback
"""

그럼 main 함수가 비동기 호출 처리가 안 되었다는 불평을 하게 되므로, 결국 main 호출도 "await main()"으로 바꿔야 하고 문제가 다시 원점으로 돌아가게 됩니다.




C#은 Main 메서드 시작부터 async Main으로 만드는 것이 가능하지만 파이썬은 그에 대한 처리는 없기 때문에 이런 경우 라이브러리의 도움을 받아야 합니다. 실제로 최초의 async 진입 함수를 asyncio.run 등의 함수를 이용해 실행하면,

import time
import asyncio

async def main_async():
    print('async calling', time.strftime('%X'))
    time.sleep(5)
    print('async called', time.strftime('%X'))

asyncio.run(main_async())

""" 
실행 결과:

async calling 14:06:08
async called 14:06:13
""" 

아무런 문제 없이 코드가 수행됩니다. 또한 await을 순차적으로 비동기 처리하는 것은 C#의 체계와 같습니다. 그래서 아래의 코드는 총 9초를 소요하게 되는데요,

import time
import asyncio

async def do_something(delay: int=0):
    time.sleep(delay)


async def main_async():
    print('async calling', time.strftime('%X'))
    await do_something(3)
    await do_something(6)
    print('async called', time.strftime('%X'))  # 9초 지나서 실행
                                                # 아래에서 다루겠지만, do_something 함수 내부의 코드 문제로 비동기 처리와 무관하게 9초가 걸립니다.
    

asyncio.run(main_async())

그렇다면 병렬처리는 어떻게 할 수 있을까요? C#의 경우라면 개별 호출을 Task로 받아 await을 별도로 진행하거나 Task.WhenAll로 받을 수 있는데요, 파이썬도 유사한 사용자 경험을 제공합니다.

실제로 해볼까요? ^^ 우선, C#처럼 다음과 같이 코딩하면,

task1 = do_something(3)  # 동기 호출: 이곳에서 time.sleep(3) 코드 동작
task2 = do_something(6)  # 동기 호출: 이곳에서 time.sleep(6) 코드 동작

await task1
await task2

위의 호출은 총 9초가 소요됩니다. 사실 "task1 = do_something(...)" 형식이 동기 호출이든 비동기 호출이든 상관없이 저 코드는 총 9초가 소요됩니다. 왜냐하면 do_something의 내부에 있는 time.sleep이 동기적으로 호출되기 때문에 그것을 호출하는 측의 스레드가 그대로 묶이기 때문입니다.

따라서, 이 문제를 없애려면 time.sleep도 비동기 버전을 사용해야 합니다.

async def do_something(delay: int=0):
    await asyncio.sleep(delay)


task1 = do_something(3)  # 동기 호출이지만 asyncio.sleep 비동기 호출로 3초를 대기하지 않고 제어 반환
task2 = do_something(6)  # 동기 호출이지만 asyncio.sleep 비동기 호출로 6초를 대기하지 않고 제어 반환

await task1  # 이곳에서 비동기 3초 작업 대기
await task2  # 이미 3초가 흘렀으므로 남은 비동기 3초 대기

# 총 6초 소요

보는 바와 같이, 이제야 원하는 대로 병렬 처리가 잘 되었습니다. (저렇게 보면 C#의 코드와 거의 같습니다.)

또한, 파이썬 역시 C#의 Task.WhenAll과 유사하게 병렬 처리를 위한 전용 함수인 asyncio.gather를 제공합니다. 따라서 이것을 이용하면 다음과 같이 재작성할 수 있습니다.

# Can I use await on multiple functions at once?
# https://stackoverflow.com/questions/68733675/can-i-use-await-on-multiple-functions-at-once

import time
import asyncio

async def do_something(delay: int=0):
    await asyncio.sleep(delay)


async def main_async():
    print('async calling', time.strftime('%X'))

    await asyncio.gather(do_something(3), do_something(6))  # 6초 소요

    print('async called', time.strftime('%X'))


asyncio.run(main_async())

참고로, gather의 경우 인자를 개별적으로 지정하는데, 인자가 포함된 리스트를 받는 wait 함수를 쓰는 것도 가능합니다. (gather/wait)

async def main_async():
    print('async calling', time.strftime('%X'))

    jobs = [do_something(3), do_something(6)]  # 리스트로 전달
    await asyncio.wait(jobs)  # 6초 소요

    print('async called', time.strftime('%X'))




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







[최초 등록일: ]
[최종 수정일: 10/13/2023]

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

비밀번호

댓글 작성자
 




... 106  107  108  109  110  111  112  113  114  115  116  117  118  119  [120]  ...
NoWriterDateCnt.TitleFile(s)
11014정성태8/6/201626988오류 유형: 347. Hyper-V Virtual Machine Management service Account does not have permission to open attachment
11013정성태8/6/201638121개발 환경 구성: 290. Windows 10에서 경험해 보는 Windows Containers와 docker [4]
11012정성태8/6/201628249오류 유형: 346. Windows 10에서 Windows Containers의 docker run 실행 시 encountered an error during CreateContainer failed in Win32 발생
11011정성태8/6/201629511기타: 59. outlook.live.com 메일 서비스의 아웃룩 POP3 설정하는 방법
11010정성태8/6/201626128기타: 58. Outlook에 설정한 SMTP/POP3(예:천리안 메일) 계정 암호를 잊어버린 경우
11009정성태8/3/201631143개발 환경 구성: 289. 2016-08-02부터 시작된 윈도우 10 1주년 업데이트에서 Bash Shell 사용 [8]
11008정성태8/1/201625780오류 유형: 345. 2의 30승 이상의 원소를 갖는 경우 버그가 발생하는 이진 검색(Binary Search) 코드
11007정성태8/1/201627337오류 유형: 344. RDP ActiveX 컨트롤로 특정 PC에 연결할 수 없을 때, 오류 상황을 해결하기 위한 팁파일 다운로드1
11006정성태7/22/201630729개발 환경 구성: 288. SSL 인증서를 Azure Cloud Service에 적용하는 방법
11005정성태7/22/201629509개발 환경 구성: 287. Let's Encrypt 인증서 업데이트 주기: 90일
11004정성태7/22/201623837오류 유형: 343. Invalid service definition or service configuration. Please see the Error List for more details.
11003정성태7/20/201631694VS.NET IDE: 110. Visual Studio 2015에서 .NET Core 응용 프로그램 개발 [1]
11002정성태7/20/201624993개발 환경 구성: 286. Microsoft Azure 서비스의 구독은 반드시 IE로!
11001정성태7/19/201636287.NET Framework: 599. .NET Core/SDK 설치 및 기본 사용법 [6]
11000정성태7/16/201624788오류 유형: 342. Microsoft Visual Studio 2010 Tools for Office Runtime (x86 and x64) 설치 시 오류
10999정성태7/16/201624859오류 유형: 341. .NET Framework 4.5.2가 설치 안 되는 경우
10998정성태7/16/201624368.NET Framework: 598. C# - Excel 시트에 윈도우 폼 기능을 추가하는 방법 [1]파일 다운로드1
10997정성태7/16/201625708오류 유형: 340. HTTP Error 500.23 - Internal Server Error파일 다운로드1
10996정성태7/14/201630308Windows: 118. 유선 접속 상태에서 재부팅하면 무선 연결이 자동 연결 안되는 문제 [4]파일 다운로드1
10995정성태6/27/201623637VS.NET IDE: 109. Visual Studio 유료 버전 사용자의 주기적인 온라인 인증을 없애는 방법
10994정성태6/23/201622390개발 환경 구성: 285. 알고스팟(https://algospot.com)을 위한 Visual C++ 답안 작성 요령파일 다운로드1
10993정성태6/23/201623907.NET Framework: 597. 닷넷 메타데이터에 struct/class(값/참조 형식)의 구분이 있을까요?
10992정성태6/13/201620354오류 유형: 339. vbs 스크립트 실행 시 항상 실행 여부를 묻는 질문 창이 뜬다면?
10991정성태6/13/201626707오류 유형: 338. octave-gui 실행 시 "octave-gui.exe has stopped working" 오류
10990정성태6/13/201627824오류 유형: 337. missing type specifier - [type] assumed. Note: C++ does not support default-[type]
10989정성태6/7/201624469.NET Framework: 596. C# - WCF wsDualHttpBinding의 ClientBaseAddress 속성 - 두 번째 이야기
... 106  107  108  109  110  111  112  113  114  115  116  117  118  119  [120]  ...