python 으로 ksql 사용하기

사용에 앞서 필요한 lib

pip install ksql

 

from ksql import KSQLAPI
from pprint import pprint

client = KSQLAPI('http://127.0.0.1:8088', timeout=None)


result = client.ksql('show topics;')
pprint(result)

결과물

data = client.query("""SELECT * FROM `ksqlstudy`;""", use_http2=True)
for i in data:
    print(i)