는 : 하나 개의 볼트 작업에 코드의 라인을 실행하는 방법

Question

나는 주둥이와 볼트 (numTasks은 = 16)와 폭풍 토폴로지가 있습니다. 볼트의 한 작업에서만 코드의 특정 부분 (한 번만)을 실행하고 싶습니다. 어떻게해야합니까?

나는 볼트의 준비 방법으로 그 일을 생각,하지만 난 미리 볼트에 할당됩니다 작업 ID를 알 수 없습니다.

은 가능한 그 사육사 이상에서 볼트의 준비 방법은 현재 작업 ID로 선거 지도자와 일치하는 검색에 선거 및 저장 작업을 수행하는 것입니다. 작업 ID가 선거 리더와 일치하면 해당 볼트 작업 인스턴스에서 특정 코드가 실행됩니까? 이것이 적절한 접근법이라면 어떻게해야할까요?

Answer 1

당신은 #prepare()에 매개 변수로 제공 TopologyContext를 통해 모든 메타 정보를 전체 토폴로지 DAG에 액세스 할 수 있습니다. 거기서 당신은 자신의 task-id를 포함한 모든 task-id를 얻을 수 있습니다.

따라서, 간단한 방법은 당신의 작업이 최소 (또는 최대)이있는 경우 작업-ID가 할당 만 특수 코드를 실행하는 것입니다.