云函数代码⬇️

// 云函数入口文件

const cloud = require('wx-server-sdk')

​

cloud.init({

  env: 'iotclw-5gxxtdsoacf3a659'

})

const db = cloud.database()

const _ = db.command;

​

// 云函数入口函数

exports.main = async (event, context) => {

  var coll;

  // 获取collect集合名称

  await db.collection("keHu_sheBei")

    .where({

      _0_: "设备归属表"

    })

    .get().then(res => {

      coll = res.data[0].devices[event.serial].collect;

    })

    .then( colPush => {

      db.collection(coll)

      .where({

        'detail.serial': event.serial

      })

      .update({

        data: {

          'record_1.开机': _.push(event.message)

        }

      })

    })

  }

​

node.js代码⬇️

// 云函数初始化

const tcb = require('@cloudbase/node-sdk')

const app = tcb.init({

    secretId: secretId,

    secretKey: secretKey,

    env: env,

    traceUser: "true"

})

​

// 云函数

function cloudFunc(updata, serial) {

node.js代码⬇️

// 云函数初始化

const tcb = require('@cloudbase/node-sdk')

const app = tcb.init({

    secretId: secretId,

    secretKey: secretKey,

    env: env,

    traceUser: "true"

})

•

// 云函数

function cloudFunc(updata, serial) {

app

    .callFunction({

        name: 'mqtt-db',

        data: {

            message: updata,

            serial: 'D58UJHD'

        }

    })

    .then((res) => {

        console.log('云函数调用成功' + res)

    })

    .catch(e => {

        console.log('云函数调用出错' + e)

    })

}

      db.collection(coll)