xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

modify exec error

This commit is contained in:
menshibin 2024-08-15 13:06:47 +08:00
parent 583c1e46d6
commit f4c1ad0fde
4 changed files with 12 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
docs/examples/python/schemaless_ws.py
View File

@ -1,19 +1,21 @@
import taosws import taosws
host = "localhost"
port = 6041
def prepare(): def prepare():
conn = None conn = None
try: try:
conn = taosws.connect(user="root", conn = taosws.connect(user="root",
password="taosdata", password="taosdata",
host="localhost", host=host,
port=6041) port=port)
# create database # create database
rowsAffected = conn.execute(f"CREATE DATABASE IF NOT EXISTS power") rowsAffected = conn.execute(f"CREATE DATABASE IF NOT EXISTS power")
assert rowsAffected == 0 assert rowsAffected == 0
except Exception as err: except Exception as err:
print(f"Failed to create db and table, err:{err}") print(f"Failed to create db and table, db addrr:{host}:{port} ; ErrMessage:{err}")
raise err raise err
finally: finally:
if conn: if conn:
@ -32,8 +34,7 @@ def schemaless_insert():
jsonDemo = [ jsonDemo = [
'{"metric": "metric_json","timestamp": 1626846400,"value": 10.3, "tags": {"groupid": 2, "location": "California.SanFrancisco", "id": "d1001"}}' '{"metric": "metric_json","timestamp": 1626846400,"value": 10.3, "tags": {"groupid": 2, "location": "California.SanFrancisco", "id": "d1001"}}'
] ]
host = "localhost"
port = 6041
try: try:
conn = taosws.connect(user="root", conn = taosws.connect(user="root",
password="taosdata", password="taosdata",
@ -76,6 +77,6 @@ def schemaless_insert():
if __name__ == "__main__": if __name__ == "__main__":
try: try:
prepare() prepare()
schemaless_insert schemaless_insert()
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}")

4
docs/examples/python/stmt_native.py
View File

@ -7,8 +7,8 @@ numOfRow = 10
conn = None conn = None
stmt = None stmt = None
host="localhost", host="localhost"
port=6030, port=6030
try: try:
conn = taos.connect( conn = taos.connect(
user="root", user="root",

4
docs/examples/python/stmt_ws.py
View File

@ -13,8 +13,8 @@ port=6041
try: try:
conn = taosws.connect(user="root", conn = taosws.connect(user="root",
password="taosdata", password="taosdata",
host="localhost", host=host,
port=6041) port=port)
conn.execute("CREATE DATABASE IF NOT EXISTS power") conn.execute("CREATE DATABASE IF NOT EXISTS power")
conn.execute("USE power") conn.execute("USE power")

2
docs/examples/python/tmq_native.py
View File

@ -50,7 +50,7 @@ from taos.tmq import Consumer
def create_consumer(): def create_consumer():
host = "localhost" host = "localhost"
port = 6030 port = "6030"
groupId = "group1" groupId = "group1"
clientId = "1" clientId = "1"
try: try: