229.7. 소비자

커서를 tailable 커서로 전환하기 위해 먼저 커서를 생성할 때 몇 가지 특수 플래그가 MongoDB에 신호를 보냅니다. 생성된 커서는 열린 상태로 유지되며 새 데이터가 도달할 때까지 MongoCursor.next() 메서드를 호출하면 차단됩니다. 그러나 MongoDB 서버는 결정되지 않은 기간 후에 새 데이터가 나타나지 않는 경우 커서를 종료할 수 있는 권한을 예약합니다. 새 데이터를 계속 사용하고자 하는 경우 커서를 다시 생성해야 합니다. 그리고 이렇게하려면, 왼쪽 위치가 없거나 맨 위에서 다시 소비하기 시작할 위치를 명심해야합니다.

Camel MongoDB tailable 커서 소비자는 이러한 모든 작업을 처리합니다. 증가한 특성의 데이터에 키를 제공해야 합니다. 이러한 키는 재생성될 때마다 커서를 배치하는 마커 역할을 합니다(예: 타임스탬프, 순차 ID 등). MongoDB에서 지원하는 모든 데이터 유형일 수 있습니다. 날짜, 문자열 및 정수가 제대로 작동하는 것으로 확인됩니다. 이 구성 요소의 컨텍스트에서 이 메커니즘을 "tail tracking"이라고 합니다.

소비자는 이 필드의 마지막 값을 기억할 것이며 커서가 다시 생성될 때마다 increaseField > lastValue 과 같은 필터를 사용하여 쿼리를 실행하여 읽지 않은 데이터만 사용합니다.

increasing 필드 설정: 끝점 URI tailingIncreasingField 옵션에서 increasing 필드의 키를 설정합니다. Camel 2.10에서는 이 필드의 중첩된 탐색이 아직 지원되지 않으므로 데이터의 최상위 필드여야 합니다. 즉, "timestamp" 필드는 부드럽지만 "nested.timestamp"는 작동하지 않습니다. 중첩된 증가하는 필드에 대한 지원이 필요한 경우 Camel JIRA에서 티켓을 작성하십시오.

커서 재생성 지연: 초기 시 새 데이터를 사용할 수 없는 경우 MongoDB에서 커서를 즉시 종료합니다. 이 경우 서버를 재정의하지 않기 때문에 필요에 맞게 수정할 수 있는 cursorRegenerationDelay 옵션이 도입되었습니다(기본값: 1000ms.).

예를 들면 다음과 같습니다.

from("mongodb3:myDb?database=flights&collection=cancellations&tailTrackIncreasingField=departureTime")
    .id("tailableCursorConsumer1")
    .autoStartup(false)
    .to("mock:test");

위의 경로는 기본 재생성 커서 지연이 1000ms인 "departureTime" 필드로 "departureTime"을 사용하여 "flights.cancellations"에서 사용됩니다.

표준 테일 추적은 volatile이며 마지막 값은 메모리에만 유지됩니다. 그러나 실제로는 이제 Camel 컨테이너를 다시 시작해야 하지만 마지막 값이 손실되고 tailable 커서 소비자가 상단에서 다시 소비되기 시작하여 경로에 중복 레코드를 보낼 가능성이 높습니다.

이 상황을 극복하기 위해 영구 테일 추적 기능을 활성화하여 MongoDB 데이터베이스 내부의 특수 컬렉션에서 마지막으로 소비되는 값을 추적할 수 있습니다. 소비자가 다시 초기화하면 마지막으로 추적한 값을 복원하고 아무 일도 없던 것처럼 계속됩니다.

마지막 읽기 값은 두 번 실행됩니다. 커서가 재생될 때마다 그리고 소비자가 종료될 때입니다. 수요가 있는 경우 향후 (5초 마다 유입) 일정한 간격으로 유지되는 것을 고려할 수 있습니다. 이 기능을 요청하려면 Camel JIRA에서 티켓을 작성하십시오.

이 기능을 활성화하려면 끝점 URI에서 다음 옵션을 최소한으로 설정합니다.

또한 tailECDHE Db , tail ECDHEECDHE 및 tail ECDHEField 옵션을 설정하여 런타임 정보가 저장될 위치를 사용자 지정할 수 있습니다. 각 옵션에 대한 설명은 이 페이지 상단에 있는 끝점 옵션 테이블을 참조하십시오.

예를 들어 다음 경로는 증가하는 필드로 "departureTime"을 사용하여 1000ms의 기본 재생 커서 지연과 함께 1000ms의 "flights.cancellations"에서 소비되고 "flight.camelTail wishing" ID에 따라 유지됩니다. 마지막으로 처리된 값을 "최종" 필드에 저장(camelTailECDHEing 및 lastECDHE ingValue 은 기본값임).

from("mongodb3:myDb?database=flights&collection=cancellations&tailTrackIncreasingField=departureTime&persistentTailTracking=true" +
     "&persistentId=cancellationsTracker")
    .id("tailableCursorConsumer2")
    .autoStartup(false)
    .to("mock:test");

다음은 위의 예와 동일하지만 영구 테일 추적 런타임 정보는 "lastProcessedDepartureTime" 필드의 "trackers.camelECDHEers" 컬렉션에 저장됩니다.

from("mongodb3:myDb?database=flights&collection=cancellations&tailTrackIncreasingField=departureTime&persistentTailTracking=true" +
     "&persistentId=cancellationsTracker&tailTrackDb=trackers&tailTrackCollection=camelTrackers" +
     "&tailTrackField=lastProcessedDepartureTime")
    .id("tailableCursorConsumer3")
    .autoStartup(false)
    .to("mock:test");