GetSQS 프로세서
GetSQS 프로세서
Openflow의 GetSQS 프로세서는 Amazon Simple Queuing Service(SQS) 큐에서 메시지를 가져오는 프로세서예요.
출처: Snowflake 문서
본문
기능 — 일반 공급 (Generally Available)
Openflow Snowflake 배포는 AWS, Azure, GCP 상용(Commercial) 리전의 모든 계정에서 사용할 수 있어요. Openflow BYOC 배포는 AWS 상용 리전의 모든 계정에서 사용할 수 있습니다.
Bundle
org.apache.nifi | nifi-aws-nar
설명
Amazon Simple Queuing Service 큐에서 메시지를 가져옵니다.
태그
AWS, Amazon, Fetch, Get, Poll, Queue, SQS
입력 요구사항
금지 (FORBIDDEN)
민감한 동적 속성 지원
false
속성
| 이름 | 설명 |
|---|---|
| AWS Credentials Provider service | AWS 자격 증명 제공자를 얻는 데 사용하는 컨트롤러 서비스입니다. |
| Auto Delete Messages | 메시지를 수신한 후 프로세서가 자동으로 삭제할지 여부를 지정합니다. |
| Batch Size | 단일 네트워크 요청으로 보낼 최대 메시지 수입니다. |
| Character Set | SQS 메시지의 텍스트 콘텐츠를 인코딩하는 데 사용할 문자 집합입니다. |
| Communications Timeout | 통신 시간 초과 설정입니다. |
| Endpoint Override URL | AWS 기본값 대신 사용할 엔드포인트 URL로, scheme, host, port, path를 포함합니다. AWS 라이브러리는 AWS 리전에 따라 엔드포인트 URL을 선택하지만, 이 속성은 선택된 엔드포인트 URL을 재정의하여 다른 S3 호환 엔드포인트와 함께 사용할 수 있게 합니다. |
| Queue URL | 메시지를 가져올 큐의 URL입니다. |
| Receive Message Wait Time | 긴 폴링(long polling) 수신 호출에서 대기할 최대 시간입니다. 이 값을 1초 이상으로 설정하면 SQS 요청 수가 줄고 가져오기 지연 시간이 줄어드는 대신 스레드가 지속적으로 활성화됩니다. |
| Region | 연결할 AWS 리전입니다. |
| SSL Context Service | 선택적인 SSL Context Service를 지정합니다. 제공되면 연결 생성에 사용됩니다. |
| Visibility Timeout | 메시지가 수신되었지만 삭제되지 않은 후, 다른 소비자에게 숨겨지는 시간입니다. |
| proxy-configuration-service | 네트워크 요청을 프록시할 Proxy Configuration 컨트롤러 서비스를 지정합니다. |
관계
| 이름 | 설명 |
|---|---|
| success | FlowFile은 success 관계로 라우팅됩니다. |
쓰기 속성
| 이름 | 설명 |
|---|---|
| hash.value | 메시지의 MD5 합입니다. |
| hash.algorithm | MD5 |
| sqs.message.id | SQS 메시지의 고유 식별자입니다. |
| sqs.receipt.handle | 큐에서 메시지를 삭제하는 데 사용할 SQS Receipt Handle입니다. |
참고 항목
org.apache.nifi.processors.aws.sqs.DeleteSQSorg.apache.nifi.processors.aws.sqs.PutSQS