230.7. 소비자

커서를 테일 수 있는 커서로 전환하려면 커서를 처음 생성할 때 몇 가지 특수 플래그를 MongoDB로 표시해야 합니다. 생성된 후 커서는 열린 상태로 유지되며 새 데이터가 전달될 때까지 MongoCursor.next() 메서드를 호출하면 차단됩니다. 그러나 MongoDB 서버는 결정되지 않은 기간이 지나면 새 데이터가 나타나지 않으면 커서를 종료할 수 있는 권한을 보유합니다. 새 데이터를 계속 사용하려면 커서를 다시 생성해야 합니다. 그리고 그렇게하기 위해, 당신은 당신이 떠나거나 다른 곳에서는 다시 맨 위에서 소비하기 시작할 위치를 기억해야합니다.

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

소비자는 이 필드의 마지막 값을 기억하고 커서를 재생성할 때마다 increasingField > lastValue 와 같은 필터를 사용하여 쿼리를 실행하여 읽지 않은 데이터만 사용합니다.

증가 필드 설정: 엔드포인트 URI tailTrackingIncreasingField 옵션에서 증가 필드의 키를 설정합니다. 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");

위의 경로는 "flights.cancellations" capped 컬렉션에서 사용되며, 증가 필드로 "departureTime"을 사용하고 기본 재생성 커서 지연은 1000ms입니다.

표준 tail 추적은 volatile이며 마지막 값은 메모리에만 유지됩니다. 그러나 실제로 언제든지 Camel 컨테이너를 다시 시작해야 하지만 마지막 값이 손실되고 테일 수 있는 커서 소비자가 다시 사용하기 시작합니다. 따라서 중복 레코드를 경로로 보낼 가능성이 큽니다.

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

마지막 읽기 값은 두 번 유지됩니다. 커서가 다시 생성될 때마다 소비자가 종료됩니다. 요구가 있는 경우 강력한 안정성을 위해 향후 (5초마다 플러시) 정기적으로 지속하는 것을 고려할 수 있습니다. 이 기능을 요청하려면 Camel JIRA에서 티켓을 여십시오.

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

또한 tailTrackDb,tailTrackCollection 및 tailTrackField 옵션을 설정하여 런타임 정보가 저장되는 위치를 사용자 지정할 수 있습니다. 각 옵션에 대한 설명은 이 페이지 상단에 있는 끝점 옵션 표를 참조하십시오.

예를 들어, 다음 경로는 "flights.cancellations" capped 컬렉션에서 소비하고, 증가 필드로 "departureTime"을 사용하고, 1000ms의 기본 다시 생성 커서 지연과 함께 영구 tail 추적이 켜지고 "flights.camelTailTracking"의 "cancellationsTracker" ID 아래에 유지됩니다. "lastTrackingValue" 필드에 마지막으로 처리된 값을 저장합니다(camelTailTracking 및 lastTrackingValue 는 기본값임).

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

다음은 위의 항목과 동일한 예입니다. 그러나 영구 테일 추적 런타임 정보는 "마지막ProcessedDepartureTime" 필드의 "trackers.camelTrackers" 컬렉션에 저장됩니다.

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");