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

update node log

This commit is contained in:
sheyanjie-qq 2024-08-17 17:40:44 +08:00
parent 42c7b6ca33
commit a360240e78
5 changed files with 25 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
docs/examples/node/websocketexample/line_example.js
View File

@ -28,7 +28,7 @@ async function test() {
console.log("Inserted data with schemaless successfully.")
}
catch (err) {
console.error("Failed to insert data with schemaless, ErrCode: " + err.code + ", ErrMessage: " + err.message);
console.error(`Failed to insert data with schemaless, ErrCode: ${err.code}, ErrMessage: ${err.message}`);
}
finally {
if (wsRows) {

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

@ -35,7 +35,7 @@ async function createDbAndTable() {
console.log("Create stable power.meters successfully");
} catch (err) {
console.error("Failed to create database power or stable meters, ErrCode: " + err.code + ", ErrMessage: " + err.message);
console.error(`Failed to create database power or stable meters, ErrCode: ${err.code}, ErrMessage: ${err.message}`);
} finally {
if (wsSql) {
await wsSql.close();
@ -62,7 +62,7 @@ async function insertData() {
taosResult = await wsSql.exec(insertQuery);
console.log("Successfully inserted " + taosResult.getAffectRows() + " rows to power.meters.");
} catch (err) {
console.error("Failed to insert data to power.meters, ErrCode: " + err.code + ", ErrMessage: " + err.message);
console.error(`Failed to insert data to power.meters, sql: ${insertQuery}, ErrCode: ${err.code}, ErrMessage: ${err.message}`);
} finally {
if (wsSql) {
await wsSql.close();
@ -85,7 +85,7 @@ async function queryData() {
}
}
catch (err) {
console.error("Failed to query data from power.meters, sql: " + sql + ", ErrCode:" + err.code + ", ErrMessage: " + err.message);
console.error(`Failed to query data from power.meters, sql: ${sql}, ErrCode: ${err.code}, ErrMessage: ${err.message}`);
}
finally {
if (wsRows) {
@ -112,7 +112,7 @@ async function sqlWithReqid() {
}
}
catch (err) {
console.error("Failed to execute sql with reqId: " + reqId + ", ErrCode: " + err.code + ", ErrMessage: " + err.message);
console.error(`Failed to query data from power.meters, reqId: ${reqId}, ErrCode: ${err.code}, ErrMessage: ${err.message}`);
}
finally {
if (wsRows) {

2
docs/examples/node/websocketexample/stmt_example.js
View File

@ -59,7 +59,7 @@ async function prepare() {
}
}
catch (err) {
console.error("Failed to insert to table meters using stmt, ErrCode: " + err.code + ", ErrMessage: " + err.message);
console.error(`Failed to insert to table meters using stmt, ErrCode: ${err.code}, ErrMessage: ${err.message}`);
}
finally {
if (stmt) {

15
docs/examples/node/websocketexample/tmq_example.js
View File

@ -3,12 +3,16 @@ const taos = require("@tdengine/websocket");
// ANCHOR: create_consumer
const db = 'power';
const stable = 'meters';
const topics = ['power_meters_topic'];
const url = 'ws://localhost:6041';
const topic = 'topic_meters'
const topics = [topic];
const groupId = "group1";
const clientId = "client1";
async function createConsumer() {
let groupId = "group1";
let clientId = "1";
let clientId = "client1";
let configMap = new Map([
[taos.TMQConstants.GROUP_ID, groupId],
[taos.TMQConstants.CLIENT_ID, clientId],
@ -24,7 +28,7 @@ async function createConsumer() {
console.log(`Create consumer successfully, host: ${url}, groupId: ${groupId}, clientId: ${clientId}`)
return conn;
} catch (err) {
console.log("Failed to create websocket consumer, ErrCode:" + err.code + ", ErrMessage: " + err.message);
console.error(`Failed to create websocket consumer, topic: ${topic}, groupId: ${groupId}, clientId: ${clientId}, ErrCode: ${err.code}, ErrMessage: ${err.message}`);
throw err;
}
@ -60,13 +64,14 @@ async function subscribe(consumer) {
for (let i = 0; i < 50; i++) {
let res = await consumer.poll(100);
for (let [key, value] of res) {
// Add your data processing logic here
console.log(`data: ${key} ${value}`);
}
await consumer.commit();
console.log("Commit offset manually successfully.");
}
} catch (err) {
console.error("Failed to poll data, ErrCode: " + err.code + ", ErrMessage: " + err.message);
console.error(`Failed to poll data, topic: ${topic}, groupId: ${groupId}, clientId: ${clientId}, ErrCode: ${err.code}, ErrMessage: ${err.message}`);
throw err;
}
// ANCHOR_END: commit
@ -83,7 +88,7 @@ async function test() {
console.log("Consumer unsubscribed successfully.");
}
catch (err) {
console.error("Failed to unsubscribe consumer, ErrCode: " + err.code + ", ErrMessage: " + err.message);
console.error(`Failed to unsubscribe consumer, topic: ${topic}, groupId: ${groupId}, clientId: ${clientId}, ErrCode: ${err.code}, ErrMessage: ${err.message}`);
}
finally {
if (consumer) {

13
docs/examples/node/websocketexample/tmq_seek_example.js
View File

@ -2,7 +2,11 @@ const taos = require("@tdengine/websocket");
const db = 'power';
const stable = 'meters';
const topics = ['power_meters_topic'];
const topic = 'topic_meters'
const topics = [topic];
const groupId = "group1";
const clientId = "client1";
// ANCHOR: create_consumer
async function createConsumer() {
@ -19,7 +23,7 @@ async function createConsumer() {
try {
return await taos.tmqConnect(configMap);
} catch (err) {
console.log(err);
console.error(err);
throw err;
}
@ -55,11 +59,12 @@ async function subscribe(consumer) {
for (let i = 0; i < 50; i++) {
let res = await consumer.poll(100);
for (let [key, value] of res) {
// Add your data processing logic here
console.log(`data: ${key} ${value}`);
}
}
} catch (err) {
console.error("Failed to poll data, ErrCode: " + err.code + ", ErrMessage: " + err.message);
console.error(`Failed to poll data, topic: ${topic}, groupId: ${groupId}, clientId: ${clientId}, ErrCode: ${err.code}, ErrMessage: ${err.message}`);
throw err;
}
@ -83,7 +88,7 @@ async function test() {
console.log("Assignment seek to beginning successfully");
}
catch (err) {
console.error("Failed to execute seek example, ErrCode: " + err.code + ", ErrMessage: " + err.message);
console.error(`Failed to seek offset, topic: ${topic}, groupId: ${groupId}, clientId: ${clientId}, ErrCode: ${err.code}, ErrMessage: ${err.message}`);
}
finally {
if (consumer) {