5
내 Storm 토폴로지에서 스트림을 처리하는 동안 향후 일정 시점까지 일부 메시지의 처리를 지연하고 싶습니다. 이 작업을 수행하기위한 합리적인 옵션은 무엇입니까?Storm에서 지연된 대기열/메시지 처리
는 지금까지, 나는 다음에 대해 생각 :
- 자바의
Thread.sleep사용. (단, 일부 논의에 기반이 효율적 스톰의 자원을 활용하기 위해 권장되는 방법이 아닙니다.) - 이 지연 큐를 사용 ...
- 특히, java.util.concurrent.DelayQueue을 시도합니다.
- 시도해 볼만한 다른 구현이 있습니까?
- 스톰에 간과 한 메시지를 지연시키는 API가 있습니까?
- ZeroMQ는 Storm (수정 된 경우)이 이용할 수있는 지연된 메시징 API를 제공합니까?
왜 이렇게하고 싶은지 몇 가지 아이디어를 줄 수 있습니까? 이 물건을 처리 할 준비가되지 않았다면 왜 폭풍 토폴로지로 넘어가서 시작합니까? –
첫 응답 : 왜 묻는거야? 질문을 이해하거나 대답하는 것이 중요합니까? 튜플을 지연 (또는 재조정)하는 것이 유용한 이유는 많이 있습니다. 내 튜플 처리는 데이터의 순수한 기능 변환에 관한 것이 아닙니다. 필자의 경우 튜플을 처리하는 것은 시스템 외부의 상태를 캡처하고 다른 스트림과 통합하는 작업을 포함합니다. 시간이 지남에 따라 변하기 때문에 나는 통제 된 간격으로 그 상태를 포착하고 싶다. 이러한 요구 사항 중 하나는 외부 리소스를 너무 자주 사용하지 않는 것입니다. –