modify node ci example
This commit is contained in:
parent
a4b35af11b
commit
b5f1b0dcd3
|
@ -1,59 +0,0 @@
|
||||||
const taos = require("@tdengine/websocket");
|
|
||||||
|
|
||||||
var host = null;
|
|
||||||
for(var i = 2; i < global.process.argv.length; i++){
|
|
||||||
var key = global.process.argv[i].split("=")[0];
|
|
||||||
var value = global.process.argv[i].split("=")[1];
|
|
||||||
if("host" == key){
|
|
||||||
host = value;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if(host == null){
|
|
||||||
host = 'localhost'
|
|
||||||
}
|
|
||||||
|
|
||||||
let dbData = ["{\"metric\": \"meter_current\",\"timestamp\": 1626846402,\"value\": 10.3, \"tags\": {\"groupid\": 2, \"location\": \"California.SanFrancisco\", \"id\": \"d1001\"}}",
|
|
||||||
"{\"metric\": \"meter_current\",\"timestamp\": 1626846403,\"value\": 10.3, \"tags\": {\"groupid\": 2, \"location\": \"California.SanFrancisco\", \"id\": \"d1002\"}}",
|
|
||||||
"{\"metric\": \"meter_current\",\"timestamp\": 1626846404,\"value\": 10.3, \"tags\": {\"groupid\": 2, \"location\": \"California.SanFrancisco\", \"id\": \"d1003\"}}"]
|
|
||||||
|
|
||||||
async function createConnect() {
|
|
||||||
let dsn = 'ws://' + host + ':6041'
|
|
||||||
let conf = new taos.WSConfig(dsn);
|
|
||||||
conf.setUser('root');
|
|
||||||
conf.setPwd('taosdata');
|
|
||||||
conf.setDb('power');
|
|
||||||
return await taos.sqlConnect(conf);
|
|
||||||
}
|
|
||||||
|
|
||||||
async function schemalessInsert() {
|
|
||||||
let wsSql = null;
|
|
||||||
let wsRows = null;
|
|
||||||
let reqId = 0;
|
|
||||||
try {
|
|
||||||
wsSql = await createConnect()
|
|
||||||
await wsSql.exec('CREATE DATABASE IF NOT EXISTS power KEEP 3650 DURATION 10 BUFFER 16 WAL_LEVEL 1;', reqId++);
|
|
||||||
await wsSql.schemalessInsert([dbData], taos.SchemalessProto.OpenTSDBJsonFormatProtocol, taos.Precision.SECONDS, 0);
|
|
||||||
}
|
|
||||||
catch (err) {
|
|
||||||
console.error(err.code, err.message);
|
|
||||||
throw err
|
|
||||||
}
|
|
||||||
finally {
|
|
||||||
if (wsRows) {
|
|
||||||
await wsRows.close();
|
|
||||||
}
|
|
||||||
if (wsSql) {
|
|
||||||
await wsSql.close();
|
|
||||||
}
|
|
||||||
taos.destroy();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
async function test() {
|
|
||||||
console.log("begin json_line_example")
|
|
||||||
await schemalessInsert();
|
|
||||||
console.log("end json_line_example")
|
|
||||||
}
|
|
||||||
|
|
||||||
test()
|
|
|
@ -1,66 +0,0 @@
|
||||||
const taos = require("@tdengine/websocket");
|
|
||||||
|
|
||||||
var host = null;
|
|
||||||
for(var i = 2; i < global.process.argv.length; i++){
|
|
||||||
var key = global.process.argv[i].split("=")[0];
|
|
||||||
var value = global.process.argv[i].split("=")[1];
|
|
||||||
if("host" == key){
|
|
||||||
host = value;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if(host == null){
|
|
||||||
console.log("Usage: node nodejsChecker.js host=<hostname> port=<port>");
|
|
||||||
process.exit(1);
|
|
||||||
}
|
|
||||||
|
|
||||||
let dbData = ["meters.current 1648432611249 10.3 location=California.SanFrancisco groupid=2",
|
|
||||||
"meters.current 1648432611250 12.6 location=California.SanFrancisco groupid=2",
|
|
||||||
"meters.current 1648432611249 10.8 location=California.LosAngeles groupid=3",
|
|
||||||
"meters.current 1648432611250 11.3 location=California.LosAngeles groupid=3",
|
|
||||||
"meters.voltage 1648432611249 219 location=California.SanFrancisco groupid=2",
|
|
||||||
"meters.voltage 1648432611250 218 location=California.SanFrancisco groupid=2",
|
|
||||||
"meters.voltage 1648432611249 221 location=California.LosAngeles groupid=3",
|
|
||||||
"meters.voltage 1648432611250 217 location=California.LosAngeles groupid=3",];
|
|
||||||
|
|
||||||
async function createConnect() {
|
|
||||||
let dsn = 'ws://' + host + ':6041'
|
|
||||||
let conf = new taos.WSConfig(dsn);
|
|
||||||
conf.setUser('root');
|
|
||||||
conf.setPwd('taosdata');
|
|
||||||
|
|
||||||
return await taos.sqlConnect(conf);
|
|
||||||
}
|
|
||||||
|
|
||||||
async function schemalessInsert() {
|
|
||||||
let wsSql = null;
|
|
||||||
let wsRows = null;
|
|
||||||
let reqId = 0;
|
|
||||||
try {
|
|
||||||
wsSql = await createConnect()
|
|
||||||
await wsSql.exec('create database if not exists power KEEP 3650 DURATION 10 BUFFER 16 WAL_LEVEL 1;', reqId++);
|
|
||||||
await wsSql.exec('use power', reqId++);
|
|
||||||
await wsSql.schemalessInsert(dbData, taos.SchemalessProto.OpenTSDBTelnetLineProtocol, taos.Precision.MILLI_SECONDS, 0);
|
|
||||||
}
|
|
||||||
catch (err) {
|
|
||||||
console.error(err.code, err.message);
|
|
||||||
process.exitCode = 1;
|
|
||||||
}
|
|
||||||
finally {
|
|
||||||
if (wsRows) {
|
|
||||||
await wsRows.close();
|
|
||||||
}
|
|
||||||
if (wsSql) {
|
|
||||||
await wsSql.close();
|
|
||||||
}
|
|
||||||
taos.destroy();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
async function test() {
|
|
||||||
console.log("begin telnet_line_example")
|
|
||||||
await schemalessInsert();
|
|
||||||
console.log("end telnet_line_example")
|
|
||||||
}
|
|
||||||
|
|
||||||
test()
|
|
|
@ -85,8 +85,6 @@ Node.js 连接器目前仅支持 Websocket 连接器, 其通过 taosAdapter
|
||||||
| [sql_example](https://github.com/taosdata/TDengine/tree/main/docs/examples/node/websocketexample/sql_example.js) | 基本的使用如如建立连接,执行 SQL 等操作。 |
|
| [sql_example](https://github.com/taosdata/TDengine/tree/main/docs/examples/node/websocketexample/sql_example.js) | 基本的使用如如建立连接,执行 SQL 等操作。 |
|
||||||
| [stmt_example](https://github.com/taosdata/TDengine/tree/main/docs/examples/node/websocketexample/stmt_example.js) | 绑定参数插入的示例。 | |
|
| [stmt_example](https://github.com/taosdata/TDengine/tree/main/docs/examples/node/websocketexample/stmt_example.js) | 绑定参数插入的示例。 | |
|
||||||
| [line_example](https://github.com/taosdata/TDengine/tree/main/docs/examples/node/websocketexample/line_example.js) | 行协议写入示例。 |
|
| [line_example](https://github.com/taosdata/TDengine/tree/main/docs/examples/node/websocketexample/line_example.js) | 行协议写入示例。 |
|
||||||
| [telnet_line_example](https://github.com/taosdata/TDengine/tree/main/docs/examples/node/websocketexample/telnet_line_example.js) | OpenTSDB Telnet 行协议写入示例。 |
|
|
||||||
| [json_line_example](https://github.com/taosdata/TDengine/tree/main/docs/examples/node/websocketexample/json_line_example.js) | OpenTSDB JSON 行协议写入示例。 |
|
|
||||||
| [tmq_example](https://github.com/taosdata/TDengine/tree/main/docs/examples/node/websocketexample/tmq_example.js) | 订阅的使用示例。 |
|
| [tmq_example](https://github.com/taosdata/TDengine/tree/main/docs/examples/node/websocketexample/tmq_example.js) | 订阅的使用示例。 |
|
||||||
| [all_type_query](https://github.com/taosdata/TDengine/tree/main/docs/examples/node/websocketexample/all_type_query.js) | 支持全部类型示例。 |
|
| [all_type_query](https://github.com/taosdata/TDengine/tree/main/docs/examples/node/websocketexample/all_type_query.js) | 支持全部类型示例。 |
|
||||||
| [all_type_stmt](https://github.com/taosdata/TDengine/tree/main/docs/examples/node/websocketexample/all_type_stmt.js) | 参数绑定支持全部类型示例。 |
|
| [all_type_stmt](https://github.com/taosdata/TDengine/tree/main/docs/examples/node/websocketexample/all_type_stmt.js) | 参数绑定支持全部类型示例。 |
|
||||||
|
|
|
@ -17,8 +17,7 @@ node all_type_query.js
|
||||||
|
|
||||||
node all_type_stmt.js
|
node all_type_stmt.js
|
||||||
|
|
||||||
node json_line_example.js
|
taos -s "drop database if exists power"
|
||||||
|
|
||||||
node line_example.js
|
node line_example.js
|
||||||
|
|
||||||
node nodejsChecker.js
|
node nodejsChecker.js
|
||||||
|
@ -27,8 +26,6 @@ node sql_example.js
|
||||||
|
|
||||||
node stmt_example.js
|
node stmt_example.js
|
||||||
|
|
||||||
node telnet_line_example.js
|
|
||||||
|
|
||||||
node tmq_example.js
|
node tmq_example.js
|
||||||
|
|
||||||
node tmq_seek_example.js
|
node tmq_seek_example.js
|
Loading…
Reference in New Issue