PutLambda 프로세서
PutLambda 프로세서
PutLambda는 지정한 Amazon Lambda 함수로 내용을 보내는 OpenFlow 프로세서예요.
출처: Snowflake 문서
본문
이 프로세서는 일반 사용 가능(Generally Available) 상태예요. OpenFlow Snowflake 배포는 AWS, Azure, GCP 상용(Commercial) 리전의 모든 계정에서 사용할 수 있고, OpenFlow BYOC 배포는 AWS 상용 리전의 모든 계정에서 사용할 수 있어요.
Bundle org.apache.nifi | nifi-aws-nar
설명
지정한 Amazon Lambda 함수로 내용을 보내요. 인증에 사용되는 AWS 자격 증명은 Lambda 함수를 실행할 권한(lambda:InvokeFunction)이 있어야 해요. FlowFile 내용은 JSON이어야 해요.
Tags amazon, aws, lambda, put
입력 요구 사항 필수(REQUIRED)
민감 동적 속성 지원 아니요(false)
속성 (Properties)
| 속성 | 설명 |
|---|---|
| AWS Credentials Provider service | AWS 자격 증명 공급자를 얻기 위해 사용하는 Controller Service예요. |
| Amazon Lambda Name | Lambda 함수 이름이에요. |
| Amazon Lambda Qualifier (version) | Lambda 함수 버전이에요. |
| Communications Timeout | AWS와 통신할 때의 타임아웃이에요. |
| Endpoint Override URL | scheme, host, port, path를 포함해 AWS 기본값 대신 사용할 Endpoint URL이에요. AWS 라이브러리는 AWS 리전을 기준으로 endpoint URL을 선택하지만, 이 속성은 선택된 endpoint URL을 덮어써서 다른 S3 호환 endpoint와 함께 사용할 수 있게 해줘요. |
| Region | 연결할 AWS 리전이에요. |
| SSL Context Service | 제공되면 연결을 만드는 데 사용되는 선택적 SSL Context Service를 지정해요. |
| proxy-configuration-service | 네트워크 요청을 프록시할 Proxy Configuration Controller Service를 지정해요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
| failure | FlowFile이 failure 관계로 라우팅돼요. |
| success | FlowFile이 success 관계로 라우팅돼요. |
기록되는 속성 (Writes attributes)
| 속성 | 설명 |
|---|---|
| aws.lambda.result.function.error | AWS Lambda에 메시지를 보낼 때 결과에서의 함수 오류 메시지예요. |
| aws.lambda.result.status.code | AWS Lambda에 메시지를 보낼 때 결과에서의 상태 코드예요. |
| aws.lambda.result.payload | AWS Lambda의 결과 페이로드예요. |
| aws.lambda.result.log | Lambda로 보낸 메시지 결과의 로그예요. |
| aws.lambda.exception.message | AWS Lambda 호출 시 예외 메시지예요. |
| aws.lambda.exception.cause | AWS Lambda 호출 시 예외 원인(cause)이에요. |
| aws.lambda.exception.error.code | AWS Lambda 호출 시 예외 오류 코드예요. |
| aws.lambda.exception.request.id | AWS Lambda 호출 시 예외 요청 ID예요. |
| aws.lambda.exception.status.code | AWS Lambda 호출 시 예외 상태 코드예요. |