| 1 |
1
복수의 워커 노드(worker node)가 분산된 환경에서 제1 워커 노드가 태스크(task)를 수행하는 방법으로서,상기 제1 워커 노드가, 어플리케이션 관리 장치로부터 어플리케이션에 포함되는 적어도 하나의 태스크 중 제1 태스크를 할당받는 단계;상기 제1 워커 노드가, 상기 제1 태스크를 수행하는 단계; 상기 제1 워커 노드가, 상기 제1 태스크의 유형에 따라 상기 제1 태스크를 수행한 결과를 협업한 다른 워커 노드로 전송하는 단계; 및상기 제1 워커 노드가, 측정 정보 - 상기 측정 정보는 상기 제1 태스크를 수행한 결과, 협업한 다른 워커 노드와의 네트워크 품질, 상기 제1 워커 노드의 부하 상태, 상기 제1 워커 노드가 상기 제1 태스크를 수행하는데 걸린 시간, 상기 제1 워커 노드의 물리적 위치, 상기 제1 워커 노드의 부하에 따른 전력 소모 정보를 포함함 - 를 상기 어플리케이션 관리 장치로 전송하는 단계를 포함하고, 상기 제1 태스크를 수행하는 단계는상기 제1 태스크가 소스(source) 태스크인 경우에, 상기 제1 워커 노드가 센서로부터 데이터 스트림을 수집하는 단계;상기 제1 태스크가 분석(analysis) 태스크인 경우에, 상기 제1 워커 노드는 소스 태스크를 할당받은 워커 노드에 의해 수집된 데이터 스트림을 제공받아서 상기 수집된 데이터 스트림을 분석하여 분석 결과를 생성하는 단계; 및상기 제1 태스크가 싱크(sink) 태스크인 경우에, 상기 제1 워커 노드는 분석 태스크를 할당받은 워커 노드로부터 분석 결과를 제공받아서 상기 분석 결과를 출력 또는 전송하거나 시각화하는 단계를 포함하는, 제1 워커 노드의 태스크 수행 방법
|
| 2 |
2
제1항에 있어서,상기 수행한 결과를 협업한 다른 워커 노드로 전송하는 단계는, 상기 제1 태스크가 소스 태스크인 경우에, 상기 제1 워커 노드가 수집한 데이터 스트림을 분석 태스크를 할당받은 워커 노드로 전송하는 단계; 및상기 제1 태스크가 분석 태스크인 경우에, 상기 제1 워커 노드가 상기 수집된 데이터 스트림을 분석한 분석 결과를 싱크 태스크를 할당받은 워커 노드로 전송하는 단계를 포함하는, 제1 워커 노드의 태스크 수행 방법
|
| 3 |
3
제1항에 있어서,상기 어플리케이션에 포함되는 적어도 하나의 태스크 중 상기 제1 태스크의 수행 결과를 입력 데이터로써 사용하는 제2 태스크를 수행하는 제2 워커 노드에 장애가 발생하는 경우에, 상기 제1 워커 노드가 상기 제2 워커 노드를 대신하여 상기 제2 태스크를 수행하는 단계를 더 포함하는 제1 워커 노드의 태스크 수행 방법
|
| 4 |
4
어플리케이션 관리 장치가 어플리케이션을 관리하는 방법으로서,분산된 복수의 워커 노드로부터, 상기 복수의 워커 노드에 의해 측정된 제1 측정 정보 - 상기 제1 측정 정보는 각 워커 노드의 계산 능력, 각 워커 노드의 부하 상태, 워커 노드들 간의 네트워크 품질, 각 워커 노드의 물리적 위치, 각 워커 노드의 부하에 따른 전력 소모 정보를 포함함 - 를 수집하는 단계;상기 복수의 워커 노드 중에서 상기 어플리케이션에 포함되는 적어도 하나의 태스크를 수행할 협업 워커 노드들을, 상기 제1 측정 정보에 기초해 결정하는 단계; 및상기 협업 워커 노드들에게 상기 어플리케이션에 포함되는 적어도 하나의 태스크 - 상기 태스크는 센서로부터 데이터 스트림을 수집하기 위한 소스 태스크, 수집된 데이터 스트림을 분석하여 분석 결과를 생성하기 위한 분석 태스크, 및 분석 결과를 소비하기 위한 싱크 태스크를 포함함 - 를 할당하는 단계를 포함하고,상기 적어도 하나의 태스크를 할당하는 단계는 상기 어플리케이션에 포함되는 적어도 하나의 태스크를 위한 입력 데이터의 크기와 출력 데이터의 크기, 각 워커 노드의 처리량, 각 워커 노드의 부하, 워커 노드들 간의 링크 품질, 태스크의 크기를 고려하여 상기 어플리케이션을 최단 시간에 수행하도록 상기 적어도 하나의 태스크를 상기 협업 워커 노드들에게 할당하면서, 추가적으로, 상기 협업 워커 노드들의 부하에 따른 전력 소모 정보를 고려하여 최소의 에너지 소모로 상기 어플리케이션을 수행하도록 상기 적어도 하나의 태스크를 상기 협업 워커 노드들에게 할당하는, 어플리케이션 관리 장치의 관리 방법
|
| 5 |
5
제4항에 있어서,상기 협업 워커 노드들을, 상기 제1 측정 정보에 기초해 결정하는 단계는, 상기 복수의 워커 노드 중에서 상기 어플리케이션에 포함되는 적어도 하나의 태스크를 최단 시간 내에 수행하는 상기 협업 워커 노드들을, 상기 제1 측정 정보, 상기 적어도 하나의 태스크의 특성, 그리고 각 워커 노드에 대한 접근 권한에 기초해 결정하는, 어플리케이션 관리 장치의 관리 방법
|
| 6 |
6
제4항에 있어서,상기 협업 워커 노드들을, 상기 제1 측정 정보에 기초해 결정하는 단계는,상기 제1 측정 정보의 가중치를 결정하는 단계; 및상기 제1 측정 정보와 상기 제1 측정 정보의 가중치를 고려해, 상기 협업 워커 노드들을 결정하는 단계를 포함하는어플리케이션 관리 장치의 관리 방법
|
| 7 |
7
제4항에 있어서,상기 협업 워커 노드들로부터, 상기 협업 워커 노드들이 상기 어플리케이션에 포함되는 적어도 하나의 태스크를 수행하는데 걸린 시간 정보를 포함하는 제2 측정 정보 - 상기 제2 측정 정보는 상기 적어도 하나의 태스크를 수행한 결과, 협업한 다른 워커 노드와의 네트워크 품질, 해당 워커 노드의 부하 상태, 해당 워커 노드의 물리적 위치, 해당 워커 노드의 부하에 따른 전력 소모 정보를 더 포함함 - 를 수집하는 단계; 상기 복수의 워커 노드 중에서 상기 어플리케이션에 포함되는 적어도 하나의 태스크를 할당받는 워커 노드들을, 상기 제2 측정 정보에 기초해 다시 결정하는 단계; 및상기 제2 측정 정보에 포함된 네트워크 품질에 기초하여, 상기 네트워크 품질과 이전 네트워크 품질 사이의 차이 값이 임계값 보다 큰 경우에, 상기 어플리케이션에 포함되는 적어도 하나의 태스크를 상기 협업 워커 노드들에 재배치하는 단계를 더 포함하는 어플리케이션 관리 장치의 관리 방법
|
| 8 |
8
제4항에 있어서, 상기 협업 워커 노드들 중 제1 워커 노드에 장애가 발생한 경우에, 상기 제1 워커 노드에 할당된 제1 태스크를 재할당할 것을, 상기 협업 워커 노드들 중 제2 워커 노드로부터 요청받는 단계; 및상기 복수의 워커 노드 중 상기 제1 워커 노드와 다른 워커 노드에, 상기 제1 태스크를 할당하는 단계를 더 포함하는 어플리케이션 관리 장치의 관리 방법
|
| 9 |
9
복수의 워커 노드로부터, 상기 복수의 워커 노드에 의해 측정된 제1 측정 정보 - 상기 제1 측정 정보는 각 워커 노드의 계산 능력, 각 워커 노드의 부하 상태, 워커 노드들 간의 네트워크 품질, 각 워커 노드의 물리적 위치, 각 워커 노드의 부하에 따른 전력 소모 정보를 포함함 - 를 수집하는 시스템 정보 수집부;상기 복수의 워커 노드 중에서 어플리케이션에 포함되는 적어도 하나의 태스크를 수행할 적어도 하나의 협업 워커 노드를, 상기 제1 측정 정보에 기초해 결정하는 분석 노드 판단부; 및상기 적어도 하나의 협업 워커 노드에게 상기 적어도 하나의 태스크 - 상기 태스크는 센서로부터 데이터 스트림을 수집하기 위한 소스 태스크, 수집된 데이터 스트림을 분석하여 분석 결과를 생성하기 위한 분석 태스크, 및 분석 결과를 소비하기 위한 싱크 태스크를 포함함 - 를 할당하는 태스크 배치부를 포함하고,상기 태스크 배치부는, 상기 어플리케이션에 포함되는 적어도 하나의 태스크를 위한 입력 데이터의 크기와 출력 데이터의 크기, 각 워커 노드의 처리량, 각 워커 노드의 부하, 워커 노드들 간의 링크 품질, 태스크의 크기를 고려하여 상기 어플리케이션을 최단 시간에 수행하도록 상기 적어도 하나의 태스크를 상기 협업 워커 노드들에게 할당하면서, 추가적으로, 상기 협업 워커 노드들의 부하에 따른 전력 소모 정보를 고려하여, 최소의 에너지 소모로 상기 어플리케이션을 수행하도록 상기 적어도 하나의 태스크를 상기 협업 워커 노드들에게 할당하는, 어플리케이션 관리 장치
|
| 10 |
10
제9항에 있어서,상기 시스템 정보 수집부는, 상기 협업 워커 노드들로부터, 상기 협업 워커 노드들이 상기 어플리케이션에 포함되는 적어도 하나의 태스크를 수행하는데 걸린 시간 정보를 포함하는 제2 측정 정보 - 상기 제2 측정 정보는 상기 적어도 하나의 태스크를 수행한 결과, 협업한 다른 워커 노드와의 네트워크 품질, 해당 워커 노드의 부하 상태, 해당 워커 노드의 물리적 위치, 해당 워커 노드의 부하에 따른 전력 소모 정보를 더 포함함 - 를 수집하고, 상기 분석 노드 판단부는, 상기 복수의 워커 노드 중에서 상기 어플리케이션에 포함되는 적어도 하나의 태스크를 할당받는 워커 노드들을, 상기 제2 측정 정보에 기초해 다시 결정하고, 상기 태스크 배치부는, 상기 제2 측정 정보에 포함된 네트워크 품질에 기초하여, 상기 네트워크 품질과 이전 네트워크 품질 사이의 차이 값이 임계값 보다 큰 경우에, 상기 어플리케이션에 포함되는 적어도 하나의 태스크를 상기 협업 워커 노드들에 재배치하는, 어플리케이션 관리 장치
|
| 11 |
11
제9항에 있어서, 상기 분석 노드 판단부는, 상기 복수의 워커 노드 중에서 상기 어플리케이션에 포함되는 적어도 하나의 태스크를 최단 시간 내에 수행하는 상기 협업 워커 노드들을, 상기 제1 측정 정보, 상기 적어도 하나의 태스크의 특성, 그리고 각 워커 노드에 대한 접근 권한에 기초해 결정하는, 어플리케이션 관리 장치
|
| 12 |
12
삭제
|
| 13 |
13
삭제
|
| 14 |
14
삭제
|
| 15 |
15
삭제
|
| 16 |
16
삭제
|
| 17 |
17
삭제
|
| 18 |
18
삭제
|
| 19 |
19
삭제
|
| 20 |
20
삭제
|
