Node.js 每秒从套接字传来的数据有哪些存储方式

let tempValues = [];

setInterval(() => {
  tempValues.map(async (option, i) => {
    await pool.query(
      "INSERT INTO plc_options (name, value, date) VALUES ($1, $2, $3)",
      [option.name, option.value, option.timestamp]
    );
    if (i === tempValues.length - 1) tempValues = [];
  })

}, 60000);


socket.onAny((eventName, ...args) => {
  tempValues.push({ name: eventName, value: args[0], timestamp: new Date() })
});

let _tempValues = [];

function getTempValues() {
    return _tempValues;
}

function getAndClearTempValues() {
    let oldTempValues = _tempValues;
    _tempValues = [];
    return oldTempValues;
}

setInterval(() => {
  let values = getAndClearTempValues();
  values.map(async (option, i) => {
    await pool.query(
      "INSERT INTO plc_options (name, value, date) VALUES ($1, $2, $3)",
      [option.name, option.value, option.timestamp]
    );
  })

}, 60000);


socket.onAny((eventName, ...args) => {
  let values = getTempValues();   
  values.push({ name: eventName, value: args[0], timestamp: new Date() })
});

Node.js相关问答推荐

Twilio-获取呼叫录音不起作用的请求

我的 MERN 网站一直告诉我我的一个函数不是一个函数

更新 mongodb 中的交易值

如何使用包含条件正确分页的 sequelize 查询？

当其中一个端点不工作时，如何使用 axios.all() 调用多个 API？

npm chokidar 触发事件两次

fs.writefile 选项参数的可能值，尤其是只读文件的整数

使用 mongoose 查找过go 7 天的注册用户总数

file.slim.js 中的苗条是什么

如何使用 Mocha 测试正常(非 node 特定)JavaScript 函数？

什么使用/尊重 .node-version 文件？

Webpack TypeScript module.hot 不存在

Nodejs 随机免费 tcp 端口

如何监控 node.js 上的网络，类似于 chrome/firefox 开发者工具？

将变量传递给nodemailer中的html模板

为什么 Node 控制台不显示功能代码？

Node.js -Firebase 服务帐户私钥不会解析

如何在离线时安装 npm 包？

当进程被杀死时，如何优雅地关闭我的 Express 服务器？

Puppeteer 等待所有图像加载然后截图