TDengine/docs/examples/python/tmq_example.py

mirror of https://github.com/taosdata/TDengine synced 2026-05-24 10:09:01 +00:00
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)
docs: add tmq example in python 2022-08-12 08:07:00 +00:00			`import taos`
docs: refine python tmq doc 2022-08-16 04:06:35 +00:00			`from taos.tmq import TaosConsumer`
			`consumer = TaosConsumer('topic_ctb_column', group_id='vg2')`
			`for msg in consumer:`
			`for row in msg:`
			`print(row)`