| 1 |
1
지능형 발전 시스템, 신재생 통합 모니터링 시스템 및 상태추론 기반 배전예지 시스템의 개발과 관련하여 데이터 생산자가 생산하는 데이터를 발행하고, 데이터 생산자 또는 데이터 소비자가 데이터를 구독할 수 있는 카탈로그 포탈; 상기 데이터 생산자가 생산한 데이터를 실시간으로 데이터 소비자에게 중개하는 데이터 브로커; 및상기 데이터 생산자가 생산한 데이터를 상기 데이터 브로커로 실시간으로 송신하거나, 상기 데이터 브로커로부터 데이터를 수신하여 데이터 생산자 또는 상기 데이터 소비자에게 전달하는 브로커 클라이언트; 를 포함하는 실시간 데이터 브로커 플랫폼
|
| 2 |
2
제1항에 있어서,상기 데이터 생산자는 상기 카탈로그 포털을 통하여 데이터 카탈로그를 생성하고,상기 데이터 카탈로그는 데이터 공개등급, 카테고리, 또는 데이터 브로커 종류 중 적어도 어느 하나 이상을 포함하는 것을 특징으로 하는 실시간 데이터 브로커 플랫폼
|
| 3 |
3
제2항에 있어서,상기 공개등급은상기 데이터 소비자가 구독 신청 시 데이터 생산자의 승인 없이 상기 데이터를 구독할 수 있는 전체 공개 등급,상기 데이터 소비자가 구독 신청 후 데이터 생산자의 승인 후에 상기 데이터를 구독할 수 있는 제한 공개 등급,상기 데이터 생산자만 상기 데이터를 구독할 수 있는 비공개 등급, 중 적어도 어느 하나 이상을 포함하는 것을 특징으로 하는 실시간 데이터 브로커 플랫폼
|
| 4 |
4
제1항에 있어서,상기 데이터 브로커는 다수의 클러스터로 구성되고,상기 데이터 생산자는 상기 카탈로그 포탈을 통하여 데이터 카탈로그를 생성하며,상기 실시간 데이터 플랫폼은 상기 카탈로그의 데이터 용량 또는 서비스 레벨에 따라 구분하여 상기 데이터 브로커의 클러스터 자원을 할당하는 것을 특징으로 하는 실시간 데이터 브로커 플랫폼
|
| 5 |
5
제4항에 있어서,상기 카탈로그 포털은 플랫폼 관리자에게 상기 데이터 브로커의 클러스터 자원을 모니터링, 신규 배포, 증설, 축소, 또는 삭제하여 상기 데이터 브로커 클러스터 자원을 관리할 수 있는 인터페이스를 제공하는 것을 특징으로 하는 실시간 데이터 브로커 플랫폼
|
| 6 |
6
제1항에 있어서,상기 데이터 브로커는 JSON(Java Script Object Notation) 형식의 데이터 모델을 상기 데이터 생산자와 상기 데이터 소비자간에 실시간으로 중개하고, 과거 이력 데이터 모델을 분산형 데이터 베이스로 관리하는 Context 브로커를 포함하는 실시간 데이터 브로커 플랫폼
|
| 7 |
7
제6항에 있어서,상기 브로커 클라이언트는 Context 기반의 시스템의 데이터를 추출하여 Context 브로커로 송신하는 Context 브로커 클라이언트; 를 포함하는 실시간 데이터 브로커 플랫폼
|
| 8 |
8
제6항에 있어서상기 브로커 클라이언트는 Context 데이터 모델이 아닌 시스템의 데이터를 Context 데이터 모델로 변환하여 Context 브로커로 송신하는 Context 브로커 클라이언트; 를 포함하는 실시간 데이터 브로커 플랫폼
|
| 9 |
9
제8항에 있어서,Context 브로커 클라이언트는관계형 데이터베이스 기반의 시스템의 데이터는 CDC(Changed Data Capture), JDBC, 또는 ODBC와 같은 DB Connection, CSV파일 형태의 SFTP 전송 방식으로 추출하여 Context 데이터 모델로 변환하는 것을 특징으로 하는 실시간 데이터 브로커 플랫폼
|
| 10 |
10
제1항에 있어서,상기 데이터 브로커는 다수의 브로커 노드를 포함하며,상기 데이터 브로커는 상기 브로커 클라이언트로부터 유입되는 다수의 API 요청을 다수의 브로커 노드로 분배하는 Load Balancer; 를 포함하는 실시간 데이터 브로커 플랫폼
|
| 11 |
11
제10항에 있어서상기 Load Balancer는 상기 API 호출의 증가 또는 축소에 따라 Context 브로커 노드를 자동으로 증설 또는 축소하는 것을 특징으로 하는 실시간 데이터 브로커 플랫폼
|
| 12 |
12
제6항에 있어서상기 데이터 브로커는 상기 Context 브로커에서 관리하는 실시간 데이터를 저장하는 In-Memory 데이터베이스를 포함하는 것을 특징으로 하는 실시간 데이터 브로커 플랫폼
|
| 13 |
13
제6항에 있어서상기 데이터 브로커는 과거 이력 데이터를 저장하는 History 분산 데이터베이스; 를 포함하고,상기 데이터 브로커에 Eintity가 생성 또는 갱신되는 경우, 그 데이터 모델의 현재 값은 상기 In-Memory 데이터베이스에 저장된 후에 이력 데이터 Message Queue와 이력 데이터 로더를 통하여 상기 History 분산 데이터베이스에 저장되는 것을 특징으로 하는 실시간 데이터 브로커 플랫폼
|
| 14 |
14
제1항에 있어서,상기 데이터 브로커는 관계형 데이터베이스 구조인 컬럼과 레코드로 구성된 테이블 데이터를 상기 데이터 생산자와 상기 데이터 소비자간에 실시간으로 중개하고, 과거 이력 데이터 모델을 분산형 데이터 베이스로 관리하는 TableData 브로커를 포함하는 실시간 데이터 브로커 플랫폼
|
| 15 |
15
제14항에 있어서,상기 브로커 클라이언트는 상기 데이터 생산자로부터 테이블 데이터를 추출하여 상기 TableData 브로커로 송신하는 TableData 브로커 클라이언트를 포함하는 실시간 데이터 브로커 플랫폼
|
| 16 |
16
제15항에 있어서,상기 TableData 브로커 클라이언트는추출한 데이터를 Table Data API Service에서 제공하는 Rest API를 통하여 송신하는 것을 특징으로 하는 실시간 데이터 브로커 플랫폼
|
| 17 |
17
제15항에 있어서,상기 TableData 브로커 클라이언트는Producer 시스템의 DB 테이블에 발생하는 Insert, Update, Delete 등 DML을 CDC(Changed Data Capture) 방식으로 추출하여 송신하는 것을 특징으로 하는 실시간 데이터 브로커 플랫폼
|
| 18 |
18
제15항에 있어서,상기 TableData 브로커 클라이언트는데이터 생산자 시스템의 DB 테이블에 DB Connection을 통하여 접속하여 데이터를 추출하여 송신하는 것을 특징으로 하는 실시간 데이터 브로커 플랫폼
|
| 19 |
19
제15항에 있어서,상기 TableData 브로커 클라이언트는DB 테이블의 데이터를 CSV 파일로 추출한 후 SFTP를 통하여 송신하는 것을 특징으로 하는 실시간 데이터 브로커 플랫폼
|
| 20 |
20
제1항에 있어서,상기 데이터 브로커는 OPC-UA 형식의 데이터 모델을 상기 데이터 생산자와 상기 데이터 소비자간에 실시간으로 중개하고, 과거 이력 데이터 모델을 분산형 데이터 베이스로 관리하는 OPC-UA 브로커를 포함하는 실시간 데이터 브로커 플랫폼
|
| 21 |
21
제20항에 있어서,상기 브로커 클라이언트는OPC-UA 기반의 시스템 또는 발전 설비로부터 데이터를 추출하여 상기 OPC-UA 브로커로 송신하는 OPC-UA 브로커 클라이언트를 포함하는 실시간 데이터 브로커 플랫폼
|
| 22 |
22
제20항에 있어서,상기 브로커 클라이언트는OPC-UA 모델이 아닌 시스템 또는 발전설비의 데이터를 OPC-UA 모델로 변환하여 상기 OPC-UA 브로커로 송신하는 OPC-UA 브로커 클라이언트를 포함하는 실시간 데이터 브로커 플랫폼
|
| 23 |
23
제1항에 있어서,상기 데이터 브로커는IEC61850 데이터 모델을 상기 데이터 생산자와 상기 데이터 소비자 간에 실시간으로 중개하고, 과거 이력 데이터 모델을 분산형 데이터 베이스로 관리하는 61850 브로커를 포함하는 실시간 데이터 브로커 플랫폼
|
| 24 |
24
제23항에 있어서,상기 브로커 클라이언트는MODBUS 또는 DNP3 통신방식의 송배전설비에서 데이터를 추출한 후 61850 데이터 모델로 변환하여 상기 61850 브로커로 송신하는 61850 브로커 클라이언트; 를 포함하는 실시간 데이터 브로커 플랫폼
|
