mirror of
https://github.com/taosdata/TDengine
synced 2026-05-24 10:09:01 +00:00
6 lines
166 B
Python
6 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)
|