From a360240e780ec9b08ff007609e8cebff8a8c707e Mon Sep 17 00:00:00 2001
From: sheyanjie-qq <249478495@qq.com>
Date: Sat, 17 Aug 2024 17:40:44 +0800
Subject: [PATCH] update node log

---
 .../node/websocketexample/line_example.js         |  2 +-
 .../examples/node/websocketexample/sql_example.js |  8 ++++----
 .../node/websocketexample/stmt_example.js         |  2 +-
 .../examples/node/websocketexample/tmq_example.js | 15 ++++++++++-----
 .../node/websocketexample/tmq_seek_example.js     | 13 +++++++++----
 5 files changed, 25 insertions(+), 15 deletions(-)

diff --git a/docs/examples/node/websocketexample/line_example.js b/docs/examples/node/websocketexample/line_example.js
index 4fc5042f5a..ac3083d358 100644
--- a/docs/examples/node/websocketexample/line_example.js
+++ b/docs/examples/node/websocketexample/line_example.js
@@ -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) {
diff --git a/docs/examples/node/websocketexample/sql_example.js b/docs/examples/node/websocketexample/sql_example.js
index 8ef4dcb831..1f756c8a09 100644
--- a/docs/examples/node/websocketexample/sql_example.js
+++ b/docs/examples/node/websocketexample/sql_example.js
@@ -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) {
diff --git a/docs/examples/node/websocketexample/stmt_example.js b/docs/examples/node/websocketexample/stmt_example.js
index 6ca4959c48..e3bb3c4dda 100644
--- a/docs/examples/node/websocketexample/stmt_example.js
+++ b/docs/examples/node/websocketexample/stmt_example.js
@@ -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) {
diff --git a/docs/examples/node/websocketexample/tmq_example.js b/docs/examples/node/websocketexample/tmq_example.js
index fc9d2889e0..5097402e6a 100644
--- a/docs/examples/node/websocketexample/tmq_example.js
+++ b/docs/examples/node/websocketexample/tmq_example.js
@@ -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) {
diff --git a/docs/examples/node/websocketexample/tmq_seek_example.js b/docs/examples/node/websocketexample/tmq_seek_example.js
index 259614d5db..b2bd569d92 100644
--- a/docs/examples/node/websocketexample/tmq_seek_example.js
+++ b/docs/examples/node/websocketexample/tmq_seek_example.js
@@ -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) {