add python example
This commit is contained in:
parent
5aa2d6993d
commit
35cccd2ab9
|
@ -41,9 +41,9 @@ def schemaless_insert():
|
||||||
database=db)
|
database=db)
|
||||||
|
|
||||||
conn.schemaless_insert(
|
conn.schemaless_insert(
|
||||||
lines=lineDemo,
|
lines = lineDemo,
|
||||||
protocol=taosws.PySchemalessProtocol.Line,
|
protocol = taosws.PySchemalessProtocol.Line,
|
||||||
precision=taosws.PySchemalessPrecision.Millisecond,
|
precision = taosws.PySchemalessPrecision.Millisecond,
|
||||||
ttl=1,
|
ttl=1,
|
||||||
req_id=1,
|
req_id=1,
|
||||||
)
|
)
|
||||||
|
|
|
@ -42,7 +42,7 @@ try:
|
||||||
for j in range (numOfRow):
|
for j in range (numOfRow):
|
||||||
timestamps.append(current + i)
|
timestamps.append(current + i)
|
||||||
currents.append(random.random() * 30)
|
currents.append(random.random() * 30)
|
||||||
voltages.append(random.random(100, 300))
|
voltages.append(random.randint(100, 300))
|
||||||
phases.append(random.random())
|
phases.append(random.random())
|
||||||
|
|
||||||
params = taos.new_bind_params(4)
|
params = taos.new_bind_params(4)
|
||||||
|
@ -52,8 +52,7 @@ try:
|
||||||
params[3].float(phases)
|
params[3].float(phases)
|
||||||
stmt.bind_param_batch(params)
|
stmt.bind_param_batch(params)
|
||||||
stmt.execute()
|
stmt.execute()
|
||||||
affected = stmt.affected_rows()
|
print(f"stmt insert successfully.")
|
||||||
print(f"table {tbname} insert {affected} rows.")
|
|
||||||
|
|
||||||
except Exception as err:
|
except Exception as err:
|
||||||
print(f"Failed to insert to table meters using stmt, error: {err}")
|
print(f"Failed to insert to table meters using stmt, error: {err}")
|
||||||
|
|
|
@ -41,7 +41,7 @@ try:
|
||||||
for j in range (numOfRow):
|
for j in range (numOfRow):
|
||||||
timestamps.append(current + i)
|
timestamps.append(current + i)
|
||||||
currents.append(random.random() * 30)
|
currents.append(random.random() * 30)
|
||||||
voltages.append(random.random(100, 300))
|
voltages.append(random.randint(100, 300))
|
||||||
phases.append(random.random())
|
phases.append(random.random())
|
||||||
|
|
||||||
stmt.bind_param(
|
stmt.bind_param(
|
||||||
|
@ -54,8 +54,9 @@ try:
|
||||||
)
|
)
|
||||||
|
|
||||||
stmt.add_batch()
|
stmt.add_batch()
|
||||||
rows = stmt.execute()
|
stmt.execute()
|
||||||
print(f"insert {rows} rows.")
|
|
||||||
|
print(f"stmt insert successfully.")
|
||||||
|
|
||||||
except Exception as err:
|
except Exception as err:
|
||||||
print(f"Failed to insert to table meters using stmt, error: {err}")
|
print(f"Failed to insert to table meters using stmt, error: {err}")
|
||||||
|
|
|
@ -1,5 +1,8 @@
|
||||||
#!/usr/bin/python3
|
#!/usr/bin/python3
|
||||||
import taosws
|
import taosws
|
||||||
|
|
||||||
|
topic = "topic_meters"
|
||||||
|
|
||||||
def prepareMeta():
|
def prepareMeta():
|
||||||
conn = None
|
conn = None
|
||||||
|
|
||||||
|
@ -29,6 +32,13 @@ def prepareMeta():
|
||||||
"CREATE TABLE IF NOT EXISTS `d0` USING `meters` (groupid, location) TAGS(0, 'Los Angles')")
|
"CREATE TABLE IF NOT EXISTS `d0` USING `meters` (groupid, location) TAGS(0, 'Los Angles')")
|
||||||
assert rowsAffected == 0
|
assert rowsAffected == 0
|
||||||
|
|
||||||
|
# ANCHOR: create_topic
|
||||||
|
# create topic
|
||||||
|
conn.execute(
|
||||||
|
f"CREATE TOPIC IF NOT EXISTS {topic} AS SELECT ts, current, voltage, phase, groupid, location FROM meters"
|
||||||
|
)
|
||||||
|
# ANCHOR_END: create_topic
|
||||||
|
|
||||||
sql = """
|
sql = """
|
||||||
INSERT INTO
|
INSERT INTO
|
||||||
power.d1001 USING power.meters (groupid, location) TAGS(2, 'California.SanFrancisco')
|
power.d1001 USING power.meters (groupid, location) TAGS(2, 'California.SanFrancisco')
|
||||||
|
@ -91,9 +101,9 @@ def seek_offset(consumer):
|
||||||
# ANCHOR: subscribe
|
# ANCHOR: subscribe
|
||||||
def subscribe(consumer):
|
def subscribe(consumer):
|
||||||
try:
|
try:
|
||||||
consumer.subscribe(["topic_meters"])
|
consumer.subscribe([topic])
|
||||||
print("subscribe topics successfully")
|
print("subscribe topics successfully")
|
||||||
for i in range(5):
|
for i in range(50):
|
||||||
records = consumer.poll(timeout=1.0)
|
records = consumer.poll(timeout=1.0)
|
||||||
if records:
|
if records:
|
||||||
for block in records:
|
for block in records:
|
||||||
|
@ -110,7 +120,7 @@ def subscribe(consumer):
|
||||||
# ANCHOR: commit_offset
|
# ANCHOR: commit_offset
|
||||||
def commit_offset(consumer):
|
def commit_offset(consumer):
|
||||||
try:
|
try:
|
||||||
for i in range(5):
|
for i in range(50):
|
||||||
records = consumer.poll(timeout=1.0)
|
records = consumer.poll(timeout=1.0)
|
||||||
if records:
|
if records:
|
||||||
for block in records:
|
for block in records:
|
||||||
|
|
Loading…
Reference in New Issue