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

modify alert sql

This commit is contained in:
menshibin 2024-08-12 19:33:50 +08:00
parent d72e0307f0
commit ffebe1d4c9
22 changed files with 38 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
docs/examples/node/websocketexample/sql_example.js
View File

@ -25,8 +25,10 @@ async function createDbAndTable() {
let wsSql = null;
try {
wsSql = await createConnect();
// create database
await wsSql.exec('CREATE DATABASE IF NOT EXISTS power');
console.log("Create database power successfully.");
// create table
await wsSql.exec('CREATE STABLE IF NOT EXISTS power.meters ' +
'(_ts timestamp, current float, voltage int, phase float) ' +
'TAGS (location binary(64), groupId int);');
@ -109,7 +111,7 @@ async function sqlWithReqid() {
}
}
catch (err) {
console.error("Failed to execute sql with reqId: " + reqId + "," + err.code + "; ErrMessage: " + err.message);
console.error("Failed to execute sql with reqId: " + reqId + ", ErrCode:" + err.code + "; ErrMessage: " + err.message);
}
finally {
if (wsRows) {

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

@ -14,7 +14,7 @@ def create_connection():
)
print(f"Connected to {host}:{port} successfully.");
except Exception as err:
print(f"Failed to connect to {host}:{port} ; err:{err}")
print(f"Failed to connect to {host}:{port} ; ErrMessage:{err}")
finally:
if conn:
conn.close()

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

@ -12,7 +12,7 @@ def create_connection():
print(f"Connected to {url} successfully.");
except Exception as err:
print(f"Failed to connect to {url} ; err:{err}")
print(f"Failed to connect to {url} ; ErrMessage:{err}")
finally:
if conn:
conn.close()

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

@ -14,7 +14,7 @@ def create_connection():
)
print(f"Connected to {host}:{port} successfully.");
except Exception as err:
print(f"Failed to connect to {host}:{port} ; Err:{err}")
print(f"Failed to connect to {host}:{port} ; ErrMessage:{err}")
return conn
# ANCHOR_END: connect

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

@ -20,7 +20,7 @@ try:
print(f"Create stable power.meters successfully, rowsAffected: {rowsAffected}");
except Exception as err:
print(f"Failed to create db and table, db addr:{host}:{port} ; err:{err}")
print(f"Failed to create db and table, db addr:{host}:{port} ; ErrMessage:{err}")
finally:
if conn:
conn.close()

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

@ -19,7 +19,7 @@ try:
print(f"Create stable power.meters successfully, rowsAffected: {rowsAffected}");
except Exception as err:
print(f"Failed to create db and table, url:{url} ; err:{err}")
print(f"Failed to create db and table, url:{url} ; ErrMessage:{err}")
finally:
if conn:
conn.close()

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

@ -20,7 +20,7 @@ try:
print(f"Create stable power.meters successfully, rowsAffected: {rowsAffected}");
except Exception as err:
print(f"Failed to create db and table, db addrr:{host}:{port} ; err:{err}")
print(f"Failed to create db and table, db addrr:{host}:{port} ; ErrMessage:{err}")
finally:
if conn:
conn.close()

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

@ -21,7 +21,7 @@ try:
print(f"Successfully inserted {affectedRows} rows to power.meters.")
except Exception as err:
print(f"Failed to insert data to power.meters, db addr:{host}:{port} ; err:{err}")
print(f"Failed to insert data to power.meters, db addr:{host}:{port} ; ErrMessage:{err}")
finally:
if conn:
conn.close()

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

@ -20,7 +20,7 @@ try:
print(f"Successfully inserted {affectedRows} rows to power.meters.")
except Exception as err:
print(f"Failed to insert data to power.meters, url:{url} ; err:{err}")
print(f"Failed to insert data to power.meters, url:{url} ; ErrMessage:{err}")
finally:
if conn:
conn.close()

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

@ -21,7 +21,7 @@ try:
print(f"Successfully inserted {affectedRows} rows to power.meters.")
except Exception as err:
print(f"Failed to insert data to power.meters, db addr:{host}:{port} ; err:{err}")
print(f"Failed to insert data to power.meters, db addr:{host}:{port} ; ErrMessage:{err}")
finally:
if conn:
conn.close()

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

@ -15,7 +15,7 @@ try:
print(f"ts: {row[0]}, current: {row[1]}, location: {row[2]}")
except Exception as err:
print(f"Failed to query data from power.meters, db addr:{host}:{port} ; err:{err}")
print(f"Failed to query data from power.meters, db addr:{host}:{port} ; ErrMessage:{err}")
finally:
if conn:
conn.close()

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

@ -14,4 +14,4 @@ try:
print(f"ts: {row[0]}, current: {row[1]}, location: {row[2]}")
except Exception as err:
print(f"Failed to query data from power.meters, url:{url} ; err:{err}")
print(f"Failed to query data from power.meters, url:{url} ; ErrMessage:{err}")

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

@ -14,7 +14,7 @@ try:
print(f"ts: {row[0]}, current: {row[1]}, location: {row[2]}")
except Exception as err:
print(f"Failed to query data from power.meters, db addr:{host}:{port} ; err:{err}")
print(f"Failed to query data from power.meters, db addr:{host}:{port} ; ErrMessage:{err}")
finally:
if conn:
conn.close()

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

@ -17,7 +17,7 @@ try:
print(f"ts: {row[0]}, current: {row[1]}, location: {row[2]}")
except Exception as err:
print(f"Failed to execute sql with reqId:{reqId}, db addr:{host}:{port} ; err:{err}")
print(f"Failed to execute sql with reqId:{reqId}, db addr:{host}:{port} ; ErrMessage:{err}")
finally:
if conn:

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

@ -15,4 +15,4 @@ try:
print(f"ts: {row[0]}, current: {row[1]}, location: {row[2]}")
except Exception as err:
print(f"Failed to execute sql with reqId:{reqId}, url:{url} ; err:{err}")
print(f"Failed to execute sql with reqId:{reqId}, url:{url} ; ErrMessage:{err}")

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

@ -18,7 +18,7 @@ try:
print(f"ts: {row[0]}, current: {row[1]}, location: {row[2]}")
except Exception as err:
print(f"Failed to execute sql with reqId:{reqId}, db addr:{host}:{port} ; err:{err}")
print(f"Failed to execute sql with reqId:{reqId}, db addr:{host}:{port} ; ErrMessage:{err}")
finally:
if conn:
conn.close()

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

@ -34,7 +34,7 @@ try:
)
print("Inserted data with schemaless successfully.");
except Exception as err:
print(f"Failed to insert data with schemaless, addr: {host}:{port} err:{err}")
print(f"Failed to insert data with schemaless, addr: {host}:{port} ErrMessage:{err}")
finally:
if conn:
conn.close()

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

@ -66,7 +66,7 @@ def schemaless_insert():
)
print("Inserted data with schemaless successfully.");
except Exception as err:
print(f"Failed to insert data with schemaless, addr: {host}:{port} err:{err}")
print(f"Failed to insert data with schemaless, addr: {host}:{port} ErrMessage:{err}")
raise err
finally:

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

@ -56,7 +56,7 @@ try:
print(f"Successfully inserted to power.meters.")
except Exception as err:
print(f"Failed to insert to table meters using stmt, addr:{host}:{port} ; err:{err}")
print(f"Failed to insert to table meters using stmt, addr:{host}:{port} ; ErrMessage:{err}")
finally:
if stmt:
stmt.close()

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

@ -61,7 +61,7 @@ try:
print(f"Successfully inserted to power.meters.")
except Exception as err:
print(f"Failed to insert to table meters using stmt, addr:{host}:{port} ; err:{err}")
print(f"Failed to insert to table meters using stmt, addr:{host}:{port} ; ErrMessage:{err}")
finally:
if stmt:
stmt.close()

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

@ -39,7 +39,7 @@ def prepareMeta():
affectedRows = conn.execute(sql)
print(f"inserted into {affectedRows} rows to power.meters successfully.")
except Exception as err:
print(f"prepare meta err:{err}")
print(f"prepare meta ErrMessage:{err}")
raise err
finally:
if conn:
@ -70,7 +70,7 @@ def create_consumer():
print(f"Create consumer successfully, host: {host}:{port}, groupId: {groupId}, clientId: {clientId}");
return consumer
except Exception as err:
print(f"Failed to create websocket consumer, host: {host}:{port} ; err:{err}");
print(f"Failed to create websocket consumer, host: {host}:{port} ; ErrMessage:{err}");
raise err
# ANCHOR_END: create_consumer
@ -96,7 +96,7 @@ def subscribe(consumer):
print(f"data: {data}")
except Exception as err:
print(f"Failed to poll data, err:{err}")
print(f"Failed to poll data, ErrMessage:{err}")
raise err
@ -123,7 +123,7 @@ def commit_offset(consumer):
print("commit offset manually successfully.");
except Exception as err:
print(f"Failed to poll data, err:{err}")
print(f"Failed to poll data, ErrMessage:{err}")
raise err
# ANCHOR_END: commit_offset
@ -139,7 +139,7 @@ def seek_offset(consumer):
consumer.seek(partition)
print(f"assignment seek to beginning successfully");
except Exception as err:
print(f"seek example failed; err:{err}")
print(f"seek example failed; ErrMessage:{err}")
raise err
# ANCHOR_END: assignment
@ -150,7 +150,7 @@ def unsubscribe(consumer):
consumer.unsubscribe()
print("unsubscribe consumer successfully.");
except Exception as err:
print(f"Failed to unsubscribe consumer. err:{err}")
print(f"Failed to unsubscribe consumer. ErrMessage:{err}")
# ANCHOR_END: unsubscribe
@ -165,7 +165,7 @@ if __name__ == "__main__":
commit_offset(consumer)
unsubscribe(consumer)
except Exception as err:
print(f"Failed to stmt consumer. err:{err}")
print(f"Failed to stmt consumer. ErrMessage:{err}")
finally:
if consumer:
consumer.close()

16
docs/examples/python/tmq_websocket_example.py
View File

@ -51,7 +51,7 @@ def prepareMeta():
print(f"inserted into {affectedRows} rows to power.meters successfully.")
except Exception as err:
print(f"Failed to prepareMeta {err}")
print(f"Failed to prepareMeta ErrMessage:{err}")
raise err
finally:
if conn:
@ -78,7 +78,7 @@ def create_consumer():
print(f"Create consumer successfully, host: {host}:{port}, groupId: {groupId}, clientId: {clientId}");
return consumer;
except Exception as err:
print(f"Failed to create websocket consumer, host: {host}:{port} ; err:{err}");
print(f"Failed to create websocket consumer, host: {host}:{port} ; ErrMessage:{err}");
raise err
@ -98,7 +98,7 @@ def seek_offset(consumer):
print("assignment seek to beginning successfully");
except Exception as err:
print(f"seek example failed; err:{err}")
print(f"seek example failed; ErrMessage:{err}")
raise err
# ANCHOR_END: assignment
@ -116,7 +116,7 @@ def subscribe(consumer):
print(f"data: {row}")
except Exception as err:
print(f"Failed to poll data, err:{err}")
print(f"Failed to poll data, ErrMessage:{err}")
raise err
@ -137,7 +137,7 @@ def commit_offset(consumer):
print("commit offset manually successfully.");
except Exception as err:
print(f"Failed to poll data, err:{err}")
print(f"Failed to poll data, ErrMessage:{err}")
raise err
@ -147,9 +147,9 @@ def commit_offset(consumer):
def unsubscribe(consumer):
try:
consumer.unsubscribe()
print("unsubscribe consumer successfully.");
print("consumer unsubscribed successfully.");
except Exception as err:
print("Failed to unsubscribe consumer. err:{err}")
print(f"Failed to unsubscribe consumer. ErrMessage:{err}")
# ANCHOR_END: unsubscribe
@ -164,7 +164,7 @@ if __name__ == "__main__":
commit_offset(consumer)
unsubscribe(consumer)
except Exception as err:
print(f"Failed to stmt consumer. err:{err}")
print(f"Failed to stmt consumer. ErrorMessage:{err}")
finally:
if consumer:
consumer.close()