mirror of
https://github.com/taosdata/TDengine
synced 2026-05-24 10:09:01 +00:00
7 lines
166 B
Python
7 lines
166 B
Python
|
import taos
|
||
|
|
from taos.tmq import TaosConsumer
|
||
|
|
consumer = TaosConsumer('topic_ctb_column', group_id='vg2')
|
||
|
|
for msg in consumer:
|
||
|
|
for row in msg:
|
||
|
|
print(row)
|