BWControl Plugin Flow

BWControl Plugin - Flow¶

1.카프카 연결 설정¶

Synopsis¶

Postgresql의 동기화 테이블 정보로부터 Kafka Topic의 맵핑정보를 Kafka Connect와 공유하기위한 연결설정으로
 Kafka connect에 Connection을 생성/삭제하여 Bigdata 연결 정보 및 Kafka Broker의 Topic 정보등을 전달

Prototype¶

pg_create_ingest_table(text connection name);
pg_delete_ingest_table(text connection name);

API정의서 참조

Flow chart¶

2.동기화 테이블 매핑¶

Synopsis¶

Postgresql의 동기화 테이블 정보를 설정하고 Replication client(bottledwater process)을 
 실행/중지하거나 변경된 테이블 리스트를 갱신 요청 Kafka connect에 Connection URL에 PUT request를 
 이용하여 변경된 동기화 테이블 리스트 및 기타 Kafka connect의 설정정보를 반영.

Prototype¶

pg_add_ingest_table(text table name, int db_type, int operation, text option);
pg_del_ingest_table(text table name);

Parameter, Return value¶

API정의서 참조

Flow chart¶

3.동기화 중단/실행¶

Synopsis¶

Database내의 매핑된 테이블의 변경 데이터를 동기화 중지 또는 재시작

Prototype¶

pg_suspend_ingest();
pg_resume_ingest();

Parameter, Return value¶

API정의서 참조

Flow chart¶

4.동기화 상태 확인¶

Synopsis¶

실시간 변경데이터 Streaming의 진행 상태를 확인

Prototype¶

pg_get_status_ingest()

Parameter, Return value¶

API정의서 참조

Flow chart¶