[PYTHON/LANGCHAIN] CompiledStateGraph 클래스 : asyncio 모듈의 create_task/wait_for 함수를 사용해 최대 실행 시간 설정하기
■ CompiledStateGraph 클래스에서 asyncio 패키지의 create_task/wait_for 함수를 사용해 최대 실행 시간을 설정하는 방법을 보여준다. ※ OPENAI_API_KEY 환경 변수 값은 .env 파일에 정의한다.
[태그:] ASYNCIO
[PYTHON/COMMON] gather 함수 : 복수 비동기 함수 실행 대기하기
■ gather 함수를 사용해 복수 비동기 함수 실행을 대기하는 방법을 보여준다. ▶ 예제 코드 (PY)
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 |
import asyncio async def getFactorial(taskName, number): factorialValue = 1 for i in range(2, number + 1): print(f"{taskName} : {i} 팩토리얼 계산...") await asyncio.sleep(1) factorialValue *= i print(f"{taskName} : 팩토리얼({number}) = {factorialValue}") return factorialValue async def main(): factorialValueList = await asyncio.gather( getFactorial("작업 1", 10), getFactorial("작업 2", 10), getFactorial("작업 3", 10) ) #factorialValueList = await asyncio.gather(*[getFactorial("작업 1", 10), getFactorial("작업 2", 10), getFactorial("작업 3", 10)]) print(factorialValueList) asyncio.run(main()) """ 작업 1 : 2 팩토리얼 계산... 작업 2 : 2 팩토리얼 계산... 작업 3 : 2 팩토리얼 계산... 작업 1 : 3 팩토리얼 계산... 작업 2 : 3 팩토리얼 계산... 작업 3 : 3 팩토리얼 계산... 작업 1 : 4 팩토리얼 계산... 작업 2 : 4 팩토리얼 계산... 작업 3 : 4 팩토리얼 계산... 작업 1 : 5 팩토리얼 계산... 작업 2 : 5 팩토리얼 계산... 작업 3 : 5 팩토리얼 계산... 작업 1 : 6 팩토리얼 계산... 작업 2 : 6 팩토리얼 계산... 작업 3 : 6 팩토리얼 계산... 작업 1 : 7 팩토리얼 계산... 작업 2 : 7 팩토리얼 계산... 작업 3 : 7 팩토리얼 계산... 작업 1 : 8 팩토리얼 계산... 작업 2 : 8 팩토리얼 계산... 작업 3 : 8 팩토리얼 계산... 작업 1 : 9 팩토리얼 계산... 작업 2 : 9 팩토리얼 계산... 작업 3 : 9 팩토리얼 계산... 작업 1 : 10 팩토리얼 계산... 작업 2 : 10 팩토리얼 계산... 작업 3 : 10 팩토리얼 계산... 작업 1 : 팩토리얼(10) = 3628800 작업 2 : 팩토리얼(10) = 3628800 작업 3 : 팩토리얼(10) = 3628800 [3628800, 3628800, 3628800] """ |
[PYTHON/COMMON] run 함수 : 비동기 함수를 동기 호출하기
■ run 함수를 사용해 비동기 함수를 동기 호출하는 방법을 보여준다. ▶ 예제 코드 (PY)
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 |
import asyncio import time async def functionAsync1(): print("START functionAsync1") await asyncio.sleep(1) print("END functionAsync1") async def functionAsync2(): print("START functionAsync2") await asyncio.sleep(3) print("END functionAsync2") async def main(): startTme = time.time() await functionAsync1() await functionAsync2() endTime = time.time() print(f"경과 시간 : {endTime - startTme}") asyncio.run(main()) """ START functionAsync1 END functionAsync1 START functionAsync2 END functionAsync2 경과 시간 : 4.004331588745117 """ |