add python example

This commit is contained in:
menshibin 2024-08-05 11:26:59 +08:00 committed by gccgdb1234
parent 709c0b9743
commit 6f828bfe4f
3 changed files with 63 additions and 39 deletions

View File

@ -15,8 +15,7 @@ try:
assert rowsAffected == 0 assert rowsAffected == 0
# change database. same as execute "USE db" # change database. same as execute "USE db"
rowsAffected = conn.select_db(db) conn.select_db(db)
assert rowsAffected == 0
# create super table # create super table
rowsAffected = conn.execute( rowsAffected = conn.execute(

View File

@ -1,5 +1,26 @@
import taosws import taosws
db = "power"
def prepare():
conn = None
try:
conn = taosws.connect(user="root",
password="taosdata",
host="localhost",
port=6041)
# create database
rowsAffected = conn.execute(f"CREATE DATABASE IF NOT EXISTS {db}")
assert rowsAffected == 0
except Exception as err:
print(f"Failed to create db and table, err:{err}")
finally:
if conn:
conn.close()
def schemaless_insert():
conn = None conn = None
lineDemo = [ lineDemo = [
@ -16,32 +37,36 @@ try:
conn = taosws.connect(user="root", conn = taosws.connect(user="root",
password="taosdata", password="taosdata",
host="localhost", host="localhost",
port=6041) port=6041,
database=db)
conn.execute("CREATE DATABASE IF NOT EXISTS power")
conn = conn.execute("USE power")
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,
req_id=1,
) )
conn.schemaless_insert( conn.schemaless_insert(
lines=telnetDemo, lines=telnetDemo,
protocol=taosws.PySchemalessProtocol.Telnet, protocol=taosws.PySchemalessProtocol.Telnet,
precision=taosws.PySchemalessPrecision.Microsecond precision=taosws.PySchemalessPrecision.Microsecond,
ttl=1,
req_id=2,
) )
conn.schemaless_insert( conn.schemaless_insert(
lines=jsonDemo, lines=jsonDemo,
protocol=taosws.PySchemalessProtocol.Json, protocol=taosws.PySchemalessProtocol.Json,
precision=taosws.PySchemalessPrecision.Millisecond precision=taosws.PySchemalessPrecision.Millisecond,
ttl=1,
req_id=3,
) )
except Exception as err: except Exception as err:
print(f"Failed to insert data with schemaless, err:{err}") print(f"Failed to insert data with schemaless, err:{err}")
finally: finally:
if conn: if conn:
conn.close() conn.close()