apache storm 예제

아파치 스톰은 분산 스트림 처리 엔진입니다. Storm은 데이터의 스트리밍 및 처리를 처리하는 “주유” 및 “볼트” 그래프 정점으로 구성된 방향 비순환 그래프(DAG)를 만듭니다. Storm이 연속 스트리밍 데이터를 처리함에 따라 명시적으로 종료될 때까지 무한히 실행되도록 구성됩니다. 로컬 모드에서 토폴로지실행을 실행하려면 스톰 항아리 대신 로컬 명령 폭풍을 실행합니다. 실행될 때 토폴로지가 시작 정보를 표시합니다. 다음 텍스트는 단어 수 출력의 예입니다: Bolt는 데이터 처리를 처리합니다. 볼트는 계산, 지속성 또는 외부 구성 요소와의 대화 와 같은 모든 작업을 수행할 수 있습니다. 이 토폴로지는 두 개의 볼트를 사용합니다: “스트림 그룹화”는 Storm에게 작업 집합 간에 투플을 보내는 방법을 알려주면서 이 질문에 답합니다. 다양한 종류의 스트림 그룹화를 살펴보기 전에 스톰 스타터의 또 다른 토폴로지에서 살펴보겠습니다. 이 WordCountTopology는 주어의 문장을 읽고 WordCountBolt에서 스트리밍하는 총 횟수로 이전에 해당 단어를 보았습니다: 이름으로 제안된 주푸트는 데이터 스트리밍을 담당합니다. 여러 개의 주둥이가 있을 수 있지만 각 주둥이는 데이터 스트림을 방출해야 합니다. 예를 들어 Spout은 Kafka 또는 RabbitMQ와 같은 메시지 큐에 연결하거나 트위터의 스트리밍 API와 같은 데이터 원본을 사용하여 Spout에서 트윗을 내줄 수 있습니다.

아파치 폭풍 튜토리얼의 전제 조건은 다음과 같습니다:이 문서는 아파치 폭풍에 궁극적 인 가이드아니다, 도 될 예정이다. 폭풍은 꽤 거대하고, 단 한 번의 긴 읽기는 어쨌든 정의를 할 수 없습니다. 물론, 어떤 추가, 피드백 또는 건설적인 비판은 크게 감사하게 될 것입니다. 이 섹션의 제공 줄에 유의하십시오. 이 설정은 Maven이 시스템에서 제공되므로 생성된 JAR 파일에서 스톰 코어를 제외하도록 지시합니다. 아파치 폭풍에서 트라이던트 확장의 기본 원리를 이해합니다. 플럭스 프레임워크의 이러한 기능 및 기타 기능에 대한 자세한 내용은 Flux(https://storm.apache.org/releases/current/flux.html)를 참조하십시오. 이제 pom.xml의 다른 섹션에서 이 값을 사용할 수 있습니다. 예를 들어 Storm 구성 요소 의 버전을 지정할 때 값을 하드 코딩하는 대신 ${storm.version}을 사용할 수 있습니다.