| 1 |
1
서비스를 구성하는 연산을 수행하기에 최적인 연산 장치를 선정하고, 선정된 연산 장치가 포함된 노드에 상기 연산을 배치하는 서비스 관리 장치; 및상기 배치된 연산이 미리 등록된 성능 가속 연산 라이브러리에 등록된 연산일 때, 상기 선정된 연산 장치를 통해 상기 연산에 포함된 하나 이상의 태스크를 수행하는 태스크 실행 장치;를 포함하는 것을 특징으로 하는 스트림 데이터 분산 처리 시스템
|
| 2 |
2
제1항에 있어서,상기 연산 장치는,CPU(Central Processing Unit)를 포함하는 기본 연산 장치; 및FPGA(Field Programmable Gate Array), GPGPU(General Purpose Graphics Processing Unit) 및 MIC(Many Integrated Core) 중 적어도 하나를 포함하는 성능 가속 장치;를 포함하는 것을 특징으로 하는 스트림 데이터 분산 처리 시스템
|
| 3 |
3
제2항에 있어서,상기 CPU는, 메인 처리기로서 전처리기 또는 보조 처리기를 제어하고, 비정형 데이터 및 미리 설정된 구조를 갖는 연산을 수행하며,상기 FPGA는, 전처리기로서 미리 설정된 규모 이상의 정형 데이터의 입력, 필터링 및 매핑 연산을 수행하며,상기 GPGPU는, 보조 처리기로서 미리 설정된 규모 이상의 정형 데이터에 대한 연산을 수행하며,상기 MIC은, 보조 처리기로서 비정형 데이터 또는 미리 설정된 규모 이상의 정형 데이터에 대한 연산을 수행하는 것을 특징으로 하는 스트림 데이터 분산 처리 시스템
|
| 4 |
4
제1항에 있어서,상기 서비스 관리 장치는,사용자 요청에 따른 서비스의 등록, 삭제 및 검색 중 어느 하나에 대한 처리를 수행하는 서비스 관리부;미리 설정된 시간 간격 또는 요청에 대한 응답으로 노드에 대한 부하 정보 및 연산 장치에 대한 부하 정보를 수집하고, 상기 수집된 노드 및 연산 장치에 대한 부하 정보를 근거로 서비스의 태스크 재배치 정보를 구축하는 자원 감시부; 및상기 수집된 노드 및 연산 장치에 대한 부하 정보를 근거로 상기 연산에 포함된 하나 이상의 태스크를 복수의 노드에 분산 배치하는 스케줄러;를 포함하는 것을 특징으로 하는 스트림 데이터 분산 처리 시스템
|
| 5 |
5
제4항에 있어서,상기 노드에 대한 부하 정보는, 노드별 자원 사용 상태 정보, 장착된 성능 가속 장치 종류 및 개수, 각 성능 가속 장치의 자원 활용 상태 정보를 포함하며,상기 연산 장치에 대한 부하 정보는, 태스크별 입력 부하량, 출력 부하량 및 데이터 처리 성능 정보를 포함하는 것을 특징으로 하는 스트림 데이터 분산 처리 시스템
|
| 6 |
6
제4항에 있어서,상기 자원 감시부는,상기 노드 및 연산 장치에 대한 부하 정보를 근거로 상기 서비스 또는 상기 서비스 내에 포함된 태스크의 재스케줄링 여부를 결정하는 것을 특징으로 하는 스트림 데이터 분산 처리 시스템
|
| 7 |
7
제4항에 있어서,상기 스케줄러는,상기 서비스 관리부로부터 서비스의 등록에 다른 태스크 배치 요청 또는 상기 자원 감시부로부터 상기 서비스 또는 태스크의 재스케줄링 요청을 수신할 때, 상기 서비스 내에 포함된 태스크의 스케줄링을 수행하는 것을 특징으로 하는 스트림 데이터 분산 처리 시스템
|
| 8 |
8
제4항에 있어서,상기 스케줄러는,연산별로 구현된 복수의 연산 장치용 구현 버전 중에서 상기 서비스를 구성하는 연산을 수행하기에 최적인 가장 우선 순위가 높은 연산 장치용 구현 버전을 선정하고, 상기 선정된 가장 우선 순위가 높은 연산 장치가 장착된 노드를 선정하고, 상기 선정된 노드가 사용 가능할 때, 상기 선정된 노드에 상기 서비스를 구성하는 연산을 배치하는 것을 특징으로 하는 스트림 데이터 분산 처리 시스템
|
| 9 |
9
제1항에 있어서,상기 태스크 실행 장치는,상기 서비스 관리 장치로부터 배치된 연산에 포함된 하나 이상의 태스크를 수행하는 태스크 실행부; 및상기 성능 가속 연산 라이브러리 및 사용자 등록 연산 라이브러리를 관리하는 라이브러리부;를 포함하는 것을 특징으로 하는 스트림 데이터 분산 처리 시스템
|
| 10 |
10
제9항에 있어서,상기 태스크 실행부는,상기 서비스를 구성하는 연산이 상기 라이브러리부에 미리 등록된 성능 가속 연산에 대응될 때, 상기 라이브러리부에 미리 등록된 상기 서비스를 구성하는 연산에 대응되는 성능 가속 연산을 로딩하고, 상기 로딩된 성능 가속 연산을 근거로 상기 연산에 포함된 하나 이상의 태스크를 수행하는 것을 특징으로 하는 스트림 데이터 분산 처리 시스템
|
| 11 |
11
제9항에 있어서,상기 태스크 실행부는,상기 서비스를 구성하는 연산이 상기 라이브러리부에 미리 등록된 사용자 등록 연산에 대응될 때, 상기 라이브러리부에 미리 등록된 상기 서비스를 구성하는 연산에 대응되는 사용자 등록 연산을 로딩하고, 상기 로딩된 사용자 등록 연산을 근거로 상기 연산에 포함된 하나 이상의 태스크를 수행하는 것을 특징으로 하는 스트림 데이터 분산 처리 시스템
|
| 12 |
12
서비스 관리 장치와 태스크 실행 장치를 포함하는 스트림 데이터 분산 처리 시스템의 스트림 데이터 분산 처리 방법에 있어서,상기 서비스 관리 장치를 통해, 요청된 서비스를 분석하여 상기 서비스를 구성하는 연산의 흐름을 확인하는 단계;상기 서비스 관리 장치를 통해, 상기 확인된 연산의 흐름을 근거로 상기 서비스를 구성하는 연산이 미리 등록된 성능 가속 연산인지 또는 사용자 등록 연산인지 여부를 확인하는 단계;상기 서비스 관리 장치를 통해, 상기 확인 결과, 상기 서비스를 구성하는 연산이 상기 미리 등록된 성능 가속 연산 라이브러리에 등록된 연산일 때, 노드 및 연산 장치에 대한 부하 정보를 근거로 복수의 연산 장치 중에서 상기 연산을 수행하기에 최적인 연산 장치를 선정하는 단계;상기 서비스 관리 장치를 통해, 상기 선정된 연산 장치가 포함된 노드에 상기 연산을 배치하는 단계; 및상기 태스크 실행 장치를 통해, 상기 연산에 포함된 하나 이상의 태스크를 수행하는 단계;를 포함하는 것을 특징으로 하는 스트림 데이터 분산 처리 방법
|
| 13 |
13
제12항에 있어서,상기 확인 결과, 상기 서비스를 구성하는 연산이 상기 미리 등록된 사용자 등록 연산일 때, 상기 서비스 관리 장치를 통해, CPU를 포함하는 복수의 노드 중에서 상기 연산을 수행하기에 최적인 연산 장치를 선정하는 단계;를 더 포함하는 것을 특징으로 하는 스트림 데이터 분산 처리 방법
|
| 14 |
14
제13항에 있어서,상기 연산에 포함된 하나 이상의 태스크를 수행하는 단계는,상기 서비스를 구성하는 연산이 상기 미리 등록된 성능 가속 연산 라이브러리에 등록된 연산일 때, 라이브러리부에 미리 등록된 상기 연산에 대응되는 성능 가속 연산을 로딩하는 과정;상기 서비스를 구성하는 연산이 상기 미리 등록된 사용자 등록 연산일 때, 상기 라이브러리부에 미리 등록된 상기 연산에 대응되는 사용자 등록 연산을 로딩하는 과정; 및상기 로딩된 성능 가속 연산 또는 사용자 등록 연산을 근거로 상기 연산에 포함된 하나 이상의 태스크를 수행하는 과정;을 포함하는 것을 특징으로 하는 스트림 데이터 분산 처리 방법
|
| 15 |
15
제12항에 있어서,상기 복수의 연산 장치는,CPU를 포함하는 기본 연산 장치; 및FPGA, GPGPU 및 MIC 중 적어도 하나를 포함하는 성능 가속 장치;를 포함하는 것을 특징으로 하는 스트림 데이터 분산 처리 방법
|
| 16 |
16
제12항에 있어서,상기 연산을 수행하기에 최적인 연산 장치를 선정하는 단계는,상기 서비스 관리 장치를 통해, 연산별로 구현된 복수의 연산 장치용 구현 버전 중에서 상기 서비스를 구성하는 연산을 수행하기에 최적인 가장 우선 순위가 높은 연산 장치용 구현 버전을 선정하는 과정;상기 선정된 가장 우선 순위가 높은 연산 장치가 장착된 노드를 선정하는 과정;상기 선정된 노드를 통해 상기 서비스를 구성하는 연산에 대응되는 태스크 수행할 수 있는지 여부를 확인하는 과정;상기 확인 결과, 상기 선정된 노드가 사용 가능할 때, 상기 선정된 노드에 상기 서비스를 구성하는 연산을 배치하는 과정;상기 확인 결과, 상기 선정된 노드가 사용 가능하지 않거나 상기 선정된 연산 장치가 장착된 노드가 없을 때, 상기 서비스를 구성하는 연산을 수행하기에 최적인 가장 우선 순위가 높은 연산 장치용 구현 버전의 다음 순위에 해당되는 다음 순위 연산 장치용 구현 버전이 존재하는지 여부를 판단하는 과정;상기 판단 결과, 상기 다음 순위 연산 장치용 구현 버전이 존재하지 않을 때, 상기 서비스를 구성하는 연산에 대한 배치에 실패하고 종료하는 과정; 및상기 판단 결과, 상기 다음 순위 연산 장치용 구현 버전이 존재할 때, 상기 다음 순위 연산 장치용 구현 버전을 연산 장치 구현 버전으로 재선정하고, 상기 재선정된 연장 차기라 장착된 노드를 선정하는 과정으로 복귀하는 과정;을 포함하는 것을 특징으로 하는 스트림 데이터 분산 처리 방법
|
