2.4. Amazon SQS(Simple Queue Service)에 연결

절차

1. Fuse Online의 왼쪽 패널에서 연결을 클릭하여 사용 가능한 연결을 표시합니다.
2. 연결 생성 을 클릭하여 Fuse Online 커넥터를 표시합니다.
3. Amazon SQS 커넥터를 클릭합니다.

4. 액세스 키 필드에 연결하려는 큐를 관리하는 AWS 계정의 사용자 액세스 키 ID에 포함된 Amazon 액세스 키 ID를 입력합니다.

   액세스하려는 큐가 아직 존재하지 않는 경우 Fuse Online에서 통합 실행을 시작하려고 할 때 이 액세스 키와 연결된 AWS 계정을 사용하여 큐를 생성합니다. 그러나 다른 AWS 계정에 큐가 이미 있는 경우 연결은 큐를 생성할 수 없으며 통합을 시작할 수 없습니다.

5. 시크릿 키 필드에 사용자가 지정한 Amazon 액세스 키 ID의 Amazon 시크릿 액세스 키를 입력합니다.
6. Region 필드에서 큐가 상주하는 AWS 리전을 선택합니다. 연결이 큐를 생성하면 선택한 지역에 큐가 생성됩니다.
7. Validate 를 클릭합니다. Fuse Online은 즉시 연결의 유효성을 검사하려고 시도하며 유효성 검사에 성공했는지 여부를 나타내는 메시지를 표시합니다. 유효성 검사가 실패하면 필요에 따라 구성 세부 정보를 수정하고 다시 시도합니다.
8. 유효성 검사가 성공하면 다음을 클릭합니다.
9. 이름 필드에 이 연결을 다른 연결과 구별하는 데 도움이 되는 이름의 선택을 입력합니다. 예를 들어 SQS South 를 입력합니다.
10. 설명 필드에 선택적으로 이 연결에 대해 알 수 있는 정보를 입력합니다. 예를 들어 남부 지역 큐로 메시지를 보내는 샘플 SQS 연결을 입력합니다.
11. 저장을 클릭하여 생성한 연결을 지금 사용할 수 있는지 확인합니다. 예제 이름을 입력하면 SQS South 가 통합에 추가하도록 선택할 수 있는 연결로 표시됩니다.

절차

1. 왼쪽의 Fuse Online 패널에서 통합을 클릭합니다.
2. 통합 생성을 클릭합니다.
3. 연결 선택 페이지에서 통합을 시작하는 데 사용할 Amazon SQS 연결을 클릭합니다.
4. 작업 선택 페이지에서 Amazon SQS 대기열 폴링을 선택하여 SQS 대기열에서 정기적으로 메시지를 검색합니다.

5. 이 작업을 구성합니다.

   1. Delay 필드에서 폴링 사이에 경과되는 시간으로 기본 500밀리초를 수락합니다. 또는 다른 폴링 간격을 지정하려면 번호를 입력하고 시간 단위를 선택합니다.

   2. 최대 개체에서 검색 필드에 하나의 폴링 작업에서 가져올 수 있는 최대 메시지 수를 입력합니다. 기본값은 10입니다.

      가져올 수 있는 메시지 수를 제한하지 않으려면 0 또는 음수 정수를 지정합니다. 검색할 최대 개체가 무제한이면 폴링 작업은 SQS 큐의 모든 메시지를 가져옵니다.

   3. 큐 이름 또는 Amazon 리소스 이름 필드에서 메시지를 검색할 SQS 대기열 또는 큐의 ARN을 지정합니다. 이 이름의 큐가 없으면 연결에서 해당 이름을 생성합니다. 이 필드는 유일한 필수 필드입니다.
   4. 메시지를 탐색하고 큐에서 삭제할지 여부를 나타냅니다. 큐에서 메시지를 가져온 다음 삭제하는 것이 기본 동작입니다. 이 옵션을 선택 해제하여 메시지를 검색하고 큐에 남기는 경우에만 이 옵션을 선택 해제합니다. 즉, 메시지가 다시 검색됩니다.
   5. Camel 필터를 통해 메시지를 추출하고 메시지를 삭제할 지 여부를 나타냅니다. 이 옵션은 기본적으로 선택됩니다. 검색된 메시지를 필터를 통해 전달하여 큐에서 삭제할지 여부를 결정할 때 선택한 상태로 두십시오. 선택 취소 메시지를 취소한 다음 대기열에서 삭제할 필요가 없습니다. Fuse Online은 메시지 Obtain을 선택하고 Camel 필터를 통해 메시지를 삭제하는 경우 올바른 동작을 확인합니다.
6. 다음을 클릭합니다.

절차

1. 통합에 추가 페이지에서 연결을 추가할 더하기 기호를 클릭합니다. Fuse Online에서 완료 연결을 선택하라는 메시지가 표시되면 이 단계를 건너뜁니다.
2. 메시지를 보내는 데 사용할 Amazon SQS 연결을 클릭합니다.

3. 연결을 수행할 작업을 선택합니다.

   • Send Object 는 하나의 메시지를 큐에 보냅니다.
   • Batch Object 는 큐로 메시지 배치를 보냅니다.

4. Message group ID 전략 필드에서 FIFO(First-in, first-out) 큐에 대해 ConstantMessageGroupIdStrategy 를 수락하거나 필드를 클릭하고 다른 전략을 선택합니다.

   이 매개변수의 설정은 간단한 큐에 영향을 미치지 않습니다. 메시지 그룹 ID는 메시지가 속한 그룹을 식별합니다. 동일한 메시지 그룹에 속하는 메시지는 메시지 그룹을 기준으로 엄격한 순서로 항상 하나씩 처리됩니다. 메시지 그룹 ID 전략에 따라 연결이 메시지에 그룹 ID를 할당하는 방법이 결정됩니다. 옵션은 다음과 같습니다.

   • ConstantMessageGroupIdStrategy Cryostat- everything 연결은 상수를 사용하여 메시지를 그룹화합니다.
   • 각 메시지에 있는 교환 ID를 사용하여 메시지를 그룹화합니다.
   • PropertyValueMessageGroupIdStrategy Cryostat- everything 연결에서는 내부 속성 값을 사용하여 메시지를 그룹화합니다.

   FIFO 큐는 메시지가 전송 및 수신되는 순서가 엄격하게 보존되고 각 메시지가 정확히 한 번 처리되도록 설계되었습니다. FIFO 큐 이름에는 접미사로 .fifo 가 있습니다.

5. 메시지 중복 ID 전략 필드에서 FIFO 큐의 경우 NullMessageDeduplicationIdStrategy 를 수락하거나 필드를 클릭하여 ExchangeIdMessageDeduplicationIdStrategy 를 선택합니다.

   이 매개변수의 설정은 간단한 큐에 영향을 미치지 않습니다. FIFO 대기열의 경우 연결은 선택한 전략을 사용하여 중복 메시지를 큐에 보내지 않도록 합니다.

   • NullMessageDeduplicationIdStrategy 는 메시지 본문을 중복 제거 요소로 사용합니다. 즉, 연결은 메시지 본문을 비교하여 중복 메시지를 식별합니다.
   • ExchangeIdMessageDeduplicationIdStrategy 는 메시지의 교환 ID를 중복 제거 요소로 사용합니다. 즉, 연결은 교환 ID를 비교하여 중복 메시지를 식별합니다.
6. 큐 이름 또는 Amazon 리소스 이름 필드에 메시지를 보낼 큐의 이름을 입력합니다. 큐가 없으면 연결에서 해당 큐를 생성합니다.
7. Delay 필드에서 기본값을 수락합니다. 이 기본값은 지연 없이 0입니다. 또는 지연을 추가하려면 번호를 지정합니다. 통합은 메시지를 보내기 전에 이 시간(초)을 기다립니다. 이 기능은 메시지 소비자가 연결을 보내는 메시지에 즉시 준비되지 않을 때 유용합니다.
8. 다음을 클릭합니다.