First write!
"); responseStream.write("${loremIpsum1}
`); await new Promise(r => setTimeout(r, 1000)); responseStream.write("DONE!
"); responseStream.write(""); responseStream.end(); } ); ``` 다음은 `template.yaml` 파일의 예제입니다. Lambda 함수의 응답 스트리밍은 `FunctionUrlConfig` 속성을 사용하여 구성됩니다. ``` AWSTemplateFormatVersion: '2010-09-09' Transform: AWS::Serverless-2016-10-31 Description: > Sample SAM Template for lambda-streaming-nodejs-app Resources: StreamingFunction: Type: AWS::Serverless::Function Properties: CodeUri: src/ Handler: index.handler Runtime: nodejs18.x Architectures: - x86_64 Timeout: 10 FunctionUrlConfig: AuthType: AWS_IAM InvokeMode: RESPONSE_STREAM Outputs: StreamingFunction: Description: "Streaming Lambda Function ARN" Value: !GetAtt StreamingFunction.Arn StreamingFunctionURL: Description: "Streaming Lambda Function URL" Value: !GetAtt StreamingFunctionUrl.FunctionUrl ``` 일반적으로 `sam build` 및 `sam deploy --guided`를 사용하여 프로덕션 애플리케이션을 빌드하고 배포할 수 있습니다. 이 예제에서는 개발 환경을 가정하고 `sam sync` 명령을 사용하여 애플리케이션을 빌드하고 배포해 보겠습니다. **참고** 이 `sam sync` 명령은 개발 환경에 권장됩니다. 자세한 내용은 [를 사용하여 sam sync에 동기화 소개 AWS 클라우드](using-sam-cli-sync.md)를 참조하세요. `sam sync`를 실행하기 전에 `samconfig.toml` 파일에 프로젝트가 올바르게 구성되어 있는지 확인합니다. 가장 중요한 것은 `stack_name` 및 `watch`의 값을 검증하는 것입니다. 구성 파일에 이러한 값을 지정하면 명령줄에서 값을 제공할 필요가 없습니다. ``` version = 0.1 [default] [default.global.parameters] stack_name = "lambda-streaming-nodejs-app" [default.build.parameters] cached = true parallel = true [default.validate.parameters] lint = true [default.deploy.parameters] capabilities = "CAPABILITY_IAM" confirm_changeset = true resolve_s3 = true s3_prefix = "lambda-streaming-nodejs-app" region = "us-west-2" image_repositories = [] [default.package.parameters] resolve_s3 = true [default.sync.parameters] watch = true [default.local_start_api.parameters] warm_containers = "EAGER" [default.local_start_lambda.parameters] warm_containers = "EAGER" ``` 다음으로 `sam sync`를 실행하여 애플리케이션을 빌드하고 배포합니다. `--watch` 옵션이 구성 파일에 구성되어 있으므로 AWS SAMCLI는 애플리케이션을 빌드하고, 애플리케이션을 배포하고, 변경 사항을 확인합니다. ``` $ sam sync The SAM CLI will use the AWS Lambda, Amazon API Gateway, and AWS StepFunctions APIs to upload your code without performing a CloudFormation deployment. This will cause drift in your CloudFormation stack. **The sync command should only be used against a development stack**. Queued infra sync. Waiting for in progress code syncs to complete... Starting infra sync. Building codeuri: /Users/.../lambda-streaming-nodejs-app/src runtime: nodejs18.x metadata: {} architecture: x86_64 functions: StreamingFunction package.json file not found. Continuing the build without dependencies. Running NodejsNpmBuilder:CopySource Build Succeeded Successfully packaged artifacts and wrote output template to file /var/folders/45/5ct135bx3fn2551_ptl5g6_80000gr/T/tmpavrzdhgp. Execute the following command to deploy the packaged template sam deploy --template-file /var/folders/45/5ct135bx3fn2551_ptl5g6_80000gr/T/tmpavrzdhgp --stack-nameFirst write!
Lorem ipsum dolor sit amet, consectetur adipiscing elit. Quisque vitae mi tincidunt tellus ultricies dignissim id et diam. Morbi pharetra eu nisi et finibus. Vivamus diam nulla, vulputate et nisl cursus, pellentesque vehicula libero. Cras imperdiet lorem ante, non posuere dolor sollicitudin a. Vestibulum ipsum lacus, blandit nec augue id, lobortis dictum urna. Vestibulum ante ipsum primis in faucibus orci luctus et ultrices posuere cubilia curae; Morbi auctor orci eget tellus aliquam, non maximus massa porta. In diam ante, pulvinar aliquam nisl non, elementum hendrerit sapien. Vestibulum massa nunc, mattis non congue vitae, placerat in quam. Nam vulputate lectus metus, et dignissim erat varius a.
DONE!
START RequestId: 1e4cdf04-60de-4769-b3a2-c1481982deb4 Version: $LATEST END RequestId: 1e4cdf04-60de-4769-b3a2-c1481982deb4 REPORT RequestId: 1e4cdf04-60de-4769-b3a2-c1481982deb4 Duration: 4088.66 ms Billed Duration: 4089 ms Memory Size: 128 MB Max Memory Used: 68 MB Init Duration: 168.45 ms ``` 함수 코드를 수정하면 AWS SAMCLI는 변경 사항을 즉시 감지하고 즉시 배포합니다. 다음은 함수 코드를 변경한 후의 AWS SAMCLI 출력의 예입니다. ``` Syncing Lambda Function StreamingFunction... Building codeuri: /Users/.../lambda-streaming-nodejs-app/src runtime: nodejs18.x metadata: {} architecture: x86_64 functions: StreamingFunction package.json file not found. Continuing the build without dependencies. Running NodejsNpmBuilder:CopySource Finished syncing Lambda Function StreamingFunction. Syncing Layer StreamingFunctione9cfe924DepLayer... SyncFlow [Layer StreamingFunctione9cfe924DepLayer]: Skipping resource update as the content didn't change Finished syncing Layer StreamingFunctione9cfe924DepLayer. ``` 이제 다시 `sam remote invoke`를 사용하여 클라우드에서 함수와 상호 작용하고 변경 사항을 테스트할 수 있습니다. ### SQS 예제 #### 기본 예제 **ARN을 리소스 ID로 제공하여 Amazon SQS 대기열을 간접 호출합니다.** ``` $ sam remote invoke arn:aws:sqs:us-west-2:01234567890:sqs-example-4DonhBsjsW1b --event '{"hello": "world"}' --output json Sending message to SQS queue MySqsQueue { "MD5OfMessageBody": "49dfdd54b01cbcd2d2ab5e9e5ee6b9b9", "MessageId": "4f464cdd-15ef-4b57-bd72-3ad225d80adc", "ResponseMetadata": { "RequestId": "95d39377-8323-5ef0-9223-ceb198bd09bd", "HTTPStatusCode": 200, "HTTPHeaders": { "x-amzn-requestid": "95d39377-8323-5ef0-9223-ceb198bd09bd", "date": "Wed, 08 Nov 2023 23:27:26 GMT", "content-type": "application/x-amz-json-1.0", "content-length": "106", "connection": "keep-alive" }, "RetryAttempts": 0 } }% ``` ### Step Functions 예제 #### 기본 예제 **물리적 ID를 리소스 ID로 제공하여 상태 시스템을 간접 호출합니다.** 먼저 `sam list resources`를 사용하여 물리적 ID를 가져옵니다. ``` $ sam list resources --stack-name state-machine-example --output json [ { "LogicalResourceId": "HelloWorldStateMachine", "PhysicalResourceId": "arn:aws:states:us-west-2:513423067560:stateMachine:HelloWorldStateMachine-z69tFEUx0F66" }, { "LogicalResourceId": "HelloWorldStateMachineRole", "PhysicalResourceId": "simple-state-machine-HelloWorldStateMachineRole-PduA0BDGuFXw" } ] ``` 다음으로 물리적 ID를 리소스 ID로 사용하여 상태 시스템을 간접 호출합니다. 명령줄에서 `--event` 옵션을 사용하여 이벤트를 전달합니다. ``` $ sam remote invoke arn:aws:states:us-west-2:01234567890:stateMachine:HelloWorldStateMachine-z69tFEUx0F66 --event '{"is_developer": true}' Invoking Step Function arn:aws:states:us-west-2:01234567890:stateMachine:HelloWorldStateMachine-z69tFEUx0F66 "Hello Developer World"% ``` **빈 이벤트를 전달하여 상태 시스템을 간접 호출합니다.** ``` $ sam remote invoke HelloWorldStateMachine --stack-name state-machine-example Invoking Step Function HelloWorldStateMachine "Hello World"% ``` ## 관련 링크 `sam remote invoke` 및 사용과 관련된 설명서는 다음을 AWS SAM CLI참조하세요. + [sam remote invoke](sam-cli-command-reference-remote-invoke.md) + [AWS SAMCLI 문제 해결](sam-cli-troubleshooting.md) # 를 사용하여 로컬 통합 테스트 자동화 AWS SAM [sam local invoke를 사용한 테스트 소개](using-sam-cli-local-invoke.md)를 사용하여 코드를 수동으로 테스트할 수 있지만를 사용하면 자동 통합 테스트를 사용하여 코드를 테스트할 AWS SAM 수도 있습니다. 통합 테스트를 사용하면 개발 주기 초기에 문제를 감지하고, 코드 품질을 개선하고, 시간을 절약하면서 비용을 절감할 수 있습니다. 에서 자동 통합 테스트를 작성하려면 AWS SAM먼저 AWS 클라우드에 배포하기 전에 로컬 Lambda 함수에 대한 테스트를 실행합니다. [sam local start-lambda를 사용한 테스트 소개](using-sam-cli-local-start-lambda.md) 명령은 Lambda 간접 호출 엔드포인트를 에뮬레이션하는 로컬 엔드포인트를 시작합니다. 자동화된 테스트에서 이를 간접 호출할 수 있습니다. 이 엔드포인트는 Lambda 간접 호출 엔드포인트를 에뮬레이션하므로 테스트를 한 번 작성한 다음 로컬 Lambda 함수 또는 배포된 Lambda 함수에 대해 수정 없이 테스트를 실행할 수 있습니다. CI/CD 파이프라인에 배포된 AWS SAM 스택에 대해 동일한 테스트를 실행할 수도 있습니다. 프로세스 방법은 다음과 같습니다. 1. 로컬 Lambda 엔드포인트를 시작합니다. AWS SAM 템플릿이 포함된 디렉터리에서 다음 명령을 실행하여 로컬 Lambda 엔드포인트를 시작합니다. ``` sam local start-lambda ``` 이 명령은 AWS Lambda를 에뮬레이션하는 `http://127.0.0.1:3001`에서 로컬 엔드포인트를 시작합니다. 이 로컬 Lambda 엔드포인트에 대해 자동 테스트를 실행할 수 있습니다. AWS CLI 또는 SDK를 사용하여이 엔드포인트를 호출하면 요청에 지정된 Lambda 함수를 로컬로 실행하고 응답을 반환합니다. 1. 로컬 Lambda 엔드포인트에 대해 통합 테스트를 실행합니다. 통합 테스트에서 AWS SDK를 사용하여 테스트 데이터로 Lambda 함수를 호출하고, 응답을 기다리고, 응답이 예상과 일치하는지 확인할 수 있습니다. 통합 테스트를 로컬에서 실행하려면 Lambda 간접 호출 API 직접 호출을 전송하여 이전 단계에서 시작한 로컬 Lambda 엔드포인트를 간접 호출하도록 AWS SDK를 구성해야 합니다. 다음은 Python 예제입니다(다른 언어용 AWS SDKs의 구성은 비슷함). ``` import boto3 import botocore # Set "running_locally" flag if you are running the integration test locally running_locally = True if running_locally: # Create Lambda SDK client to connect to appropriate Lambda endpoint lambda_client = boto3.client('lambda', region_name="us-west-2", endpoint_url="http://127.0.0.1:3001", use_ssl=False, verify=False, config=botocore.client.Config( signature_version=botocore.UNSIGNED, read_timeout=15, retries={'max_attempts': 0}, ) ) else: lambda_client = boto3.client('lambda') # Invoke your Lambda function as you normally usually do. The function will run # locally if it is configured to do so response = lambda_client.invoke(FunctionName="HelloWorldFunction") # Verify the response assert response == "Hello World" ``` `running_locally`을 `False`로 설정함으로써 배포된 Lambda 함수를 테스트하기 위해 이 코드를 사용할 수 있습니다. 이렇게 하면 AWS 클라우드에서에 연결할 AWS SDK AWS Lambda 가 설정됩니다. # 를 사용하여 샘플 이벤트 페이로드 생성 AWS SAM Lambda 함수를 테스트하기 위해 다른 AWS 서비스에 의해 트리거될 때 Lambda 함수가 수신할 데이터를 모방하는 샘플 이벤트 페이로드를 생성하고 사용자 지정할 수 있습니다. 여기에는 API Gateway, CloudFormation, Amazon S3 등과 같은 서비스가 포함됩니다. 샘플 이벤트 페이로드를 생성하면 라이브 환경에서 작업할 필요 없이 다양한 입력을 사용하여 Lambda 함수의 동작을 테스트할 수 있습니다. 또한이 접근 방식은 함수를 테스트하기 위한 AWS 서비스 이벤트 샘플을 수동으로 생성하는 것과 비교할 때 시간을 절약합니다. 샘플 이벤트 페이로드를 생성할 수 있는 전체 서비스 목록을 보려면 다음 명령을 사용합니다. ``` sam local generate-event --help ``` 특정 서비스에 사용할 수 있는 옵션 목록을 보려면 다음 명령을 사용합니다. ``` sam local generate-event [SERVICE] --help ``` 예시: ``` #Generates the event from S3 when a new object is created sam local generate-event s3 put # Generates the event from S3 when an object is deleted sam local generate-event s3 delete ``` # 내구성 함수 테스트 및 디버깅 내구성 있는 함수를 로컬에서 테스트하고 디버깅하는 작업은 체크포인트 및 재생을 자동으로 지원하는 일반 Lambda 함수와 비슷하게 작동합니다. 이 가이드에서는 일반적인 테스트 시나리오와 문제 해결 기법을 다룹니다. ## 로컬 테스트 워크플로 내구성이 뛰어난 함수를 로컬에서 테스트할 때 워크플로는 일반 Lambda 함수와 다릅니다. **내구성 있는 함수 테스트 워크플로** 1. 애플리케이션을 빌드합니다. ``` $ sam build ``` 1. 내구성 있는 함수를 호출합니다. ``` $ sam local invoke MyDurableFunction --durable-execution-name test ``` 1. 필요한 경우 실행 기록을 확인합니다. ``` $ sam local execution history execution-id ``` ## 일반적인 테스트 시나리오 ### 체크포인트 동작 테스트 함수가 상태를 올바르게 체크포인트하는지 테스트하려면: ``` # Example Python durable function def handler(event, context): # This will create a checkpoint context.wait(10) # Wait 10 seconds # Function resumes here after wait return {"message": "Function resumed after wait"} ``` 이 함수를 로컬에서 호출하면 대기 기간이 자동으로 처리됩니다. ### 콜백 시나리오 테스트 외부 콜백을 기다리는 함수의 경우: 1. 콜백을 기다리는 내구성 함수 시작 1. 다른 터미널에서 콜백을 해결합니다. ``` $ sam local callback succeed callback-id ``` 1. 함수 재개 실행 관찰 ## 문제 해결 ### 내구성 함수가 제대로 실행되지 않음 **문제:** 함수가 내구성 있는 함수로 동작하지 않습니다. **솔루션:** + SAM 템플릿에 `DurableConfig`이 설정되어 있는지 확인 + 함수 코드가 내구성 있는 함수 SDK 메서드(예: `context.wait()`)를 사용하는지 확인합니다. + 지원되는 런타임(TypeScript, JavaScript, Python)을 사용하고 있는지 확인합니다. ### 실행 기록을 검색할 수 없음 **문제:** `local execution history` 명령이 결과를 반환하지 않습니다. **솔루션:** + 실행 ID가 올바른지 확인 + 함수가 한 번 이상 호출되었는지 확인 ### 콜백 명령이 작동하지 않음 **문제:** 콜백 명령이 보류 중인 작업을 해결하지 못합니다. **솔루션:** + 콜백 ID가 올바른지 확인 + 함수가 실제로 콜백을 기다리고 있는지 확인합니다. + 올바른 콜백 명령 구문을 사용하고 있는지 확인 ## 디버깅 팁 + **실행 기록 사용** - 실행 기록을 검토하여 내구성 있는 함수의 흐름을 이해합니다. + **점진적으로 테스트** - 복잡한 로직을 추가하기 전에 간단한 대기 작업으로 시작 + **상세 로깅 사용** - 세부 로깅을 활성화하여 실행 흐름 추적 ## 자세히 알아보기 테스트 및 디버깅에 대한 자세한 내용은 다음을 참조하세요. + [sam local invoke를 사용한 테스트 소개](using-sam-cli-local-invoke.md) - 로컬 호출 설명서 + [sam local execution history](sam-cli-command-reference-sam-local-execution-history.md) - 실행 기록