18.2. MongoDB 컬렉션이 업데이트될 때 통합 트리거
문서가 MongoDB 컬렉션에 추가될 때 통합 실행을 트리거하려면 시작 연결로 간단한 통합에 MongoDB 연결을 추가합니다. 통합이 실행되면 MongoDB 연결은 통합을 만들 때 지정한 데이터베이스 컬렉션을 모니터링합니다. 연결이 구성된 컬렉션에 새 문서를 삽입하면 통합 실행이 트리거됩니다. MongoDB 연결은 새 문서를 통합으로 반환하고 이 데이터는 통합의 다음 단계에서 사용할 수 있습니다.
사전 요구 사항
- MongoDB 연결을 생성했습니다.
- 연결을 읽을 MongoDB 컬렉션의 이름을 알고 있습니다.
모니터링할 연결이 제한된 컬렉션인 경우 다음을 알아야 합니다.
- 들어오는 문서를 추적하는 MongoDB 컬렉션 필드의 이름입니다.
- 컬렉션이 포함된 데이터베이스에 대해 영구 추적이 활성화되어 있는지 여부입니다.
- 연결을 읽을 데이터와 관련된 tail 추적 정보를 지정하는 방법 MongoDB 연결은 tail 추적 정보를 사용하여 예기치 않은 연결 종료 후 작업을 재개할 수 있습니다. tail 추적을 사용하면 연결이 작업을 재개할 때 중복 데이터를 통합에 반환하지 않고 통합으로 반환해야 하는 데이터가 삭제되지 않습니다.
절차
- 왼쪽의 Fuse Online 패널에서 통합을 클릭합니다.
- 통합 생성을 클릭합니다.
- 연결 선택 페이지에서 통합에서 업데이트를 가져올 데이터베이스에 액세스하도록 구성된 MongoDB 연결을 클릭합니다.
작업 선택 페이지에서 다음 작업 중 하나를 선택합니다.
- 문서 검색(스트림) 은 일반적으로 선택할 작업입니다. 이스케이프되지 않은 컬렉션에서 데이터를 검색합니다.
- 문서 검색(세부 정보) 은 제한된 컬렉션에서 데이터를 검색하는 작업입니다.
작업을 구성합니다.
컬렉션 이름 필드에 연결을 읽을 MongoDB 컬렉션의 이름을 입력합니다.
Retrieve documents (stream) 작업을 구성하는 경우 이는 유일한 필수 매개변수입니다. 6단계로 이동합니다. Retrieve documents (tail) 작업을 구성하는 경우 나머지 하위 단계를 따르십시오.
- 들어오는 문서 필드를 추적하는 데 사용되는 컬렉션 필드에 관련 MongoDB 컬렉션 필드의 이름을 입력합니다. 이 필드에는 날짜 또는 ID와 같이 정렬할 수 있는 데이터가 포함되어 있습니다.
- 연결을 읽을 데이터베이스에 영구 추적이 활성화된 경우 영구 추적이 활성화된 경우 확인란을 선택합니다.
- 선택 사항: 이 추적 프로세스 필드를 식별하는 고유 ID에서 동일한 컬렉션을 모니터링하는 소비자가 여러 개인 경우 고유한 ID를 지정합니다. 자세한 내용은 Tailable Cursor Consumer 에 대한 Camel 설명서를 참조하십시오.
- 선택 사항: tail 추적 정보를 저장하는 데 사용된 DB에서 tail 추적 정보가 포함된 MongoDB 데이터베이스의 이름을 입력합니다.
- 선택 사항: tail 추적 필드를 저장하는 데 사용되는 컬렉션에서 tail 추적 정보가 포함된 컬렉션의 이름을 입력합니다.
- 선택 사항: tail 추적 필드를 저장하는 데 사용되는 필드에 이 연결이 읽는 컬렉션에 대한 tail 추적 정보를 저장하는 필드의 이름을 입력합니다.
tail 추적 필드를 식별하려면 tail 추적 데이터베이스 또는 tail 추적 컬렉션을 지정할 수 있습니다. 이러한 정보 중 하나를 사용하면 연결에서 tail tracking 필드를 찾을 수 있습니다.
- 다음을 클릭하여 작업의 출력 유형을 지정합니다.
유형 선택 필드에서 데이터 유형을 알 필요가 없는 경우 Type 사양 을 수락하고 Next 를 클릭합니다. 이 지침의 나머지 부분을 따를 필요가 없습니다.
그러나 구조화된 데이터 유형을 사용하는 것이 좋습니다. 예를 들어 연결 출력을 데이터 매퍼 단계에 매핑하려면 데이터 유형을 지정해야 합니다. 데이터 매퍼는 구조화되지 않은 데이터의 필드를 표시할 수 없습니다.
데이터 유형을 지정하려면 유형 선택 필드를 클릭하고 스키마 유형으로 다음 중 하나를 선택합니다.
-
JSON 스키마 는 JSON 데이터의 구조를 설명하는 문서입니다. 문서의 미디어 유형은
application/schema+json입니다. -
JSON 인스턴스는 JSON 데이터가 포함된 문서입니다. 문서의 미디어 유형은
application/json입니다. -
XML 스키마 는 XML 데이터의 구조를 설명하는 문서입니다. 문서의 파일 확장자는
.xsd입니다. -
XML 인스턴스는 XML 데이터가 포함된 문서입니다. 문서의 파일 확장자는
.xml입니다.
-
JSON 스키마 는 JSON 데이터의 구조를 설명하는 문서입니다. 문서의 미디어 유형은
-
정의 입력 상자에 선택한 스키마 유형을 준수하는 정의를 붙여넣습니다. 예를 들어 JSON 스키마를 선택하면
애플리케이션/schema+json의 미디어 유형이 있는 JSON 스키마 파일의 내용을 붙여넣습니다. 데이터 유형 이름 필드에 데이터 유형에 대해 선택한 이름을 입력합니다. 예를 들어 공급업체에 대한 JSON 스키마를 지정하는 경우 벤더를 데이터 유형 이름으로 지정할 수 있습니다.
이 유형을 지정하는 연결을 사용하는 통합을 생성하거나 편집할 때 이 데이터 유형 이름이 표시됩니다. Fuse Online은 통합 시각화 및 데이터 매퍼에 유형 이름을 표시합니다.
- 데이터 유형 설명 필드에 이 유형을 구분하는 데 도움이 되는 정보를 제공합니다. 이 설명은 이 유형을 처리하는 단계를 마우스로 가리킬 때 데이터 매퍼에 표시됩니다.
- 다음을 클릭합니다.
결과
이제 통합이 시작 연결되고 Fuse Online에서 완료 연결을 선택하라는 메시지가 표시됩니다.
실행하는 동안 연결은 삽입된 문서를 JSON 형식으로 반환합니다.
