微信小程序云開發(fā)如何實(shí)現(xiàn)數(shù)據(jù)庫自動(dòng)備份實(shí)現(xiàn)

POST https://api.weixin.qq.com/tcb/databasemigrateexport?access_token=ACCESS_TOKEN

// 獲取 access_token
request.get(
  `https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=${appid}&secret=${secret}`,
  (err, res, body) => {
    if (err) {
      // 處理錯(cuò)誤
      return;
    }
    const data = JSON.parse(body);
    // data.access_token
  }
);

request.post(
  `https://api.weixin.qq.com/tcb/databasemigrateexport?access_token=${accessToken}`,
  {
    body: JSON.stringify({
      env,
      file_path: `${date}.json`,
      file_type: '1',
      query: 'db.collection("data").get()'
    })
  },
  (err, res, body) => {
    if (err) {
      // 處理錯(cuò)誤
      return;
    }
    const data = JSON.parse(body);
    // data.job_id
  }
);

request.post(  `https://api.weixin.qq.com/tcb/databasemigratequeryinfo?access_token=${accessToken}`,
  {
    body: JSON.stringify({
      env,
      job_id: jobId
    })
  },
  (err, res, body) => {
    if (err) {
      reject(err);
    }

    const data = JSON.parse(body);
    // data.file_url
  }
);

await db.collection('db_back_info').add({
  data: {
    date: new Date(),
    jobId: job_id
  }
});

{
 "triggers": [
  {
   "name": "dbTrigger",
   "type": "timer",
   "config": "0 0 2 * * * *"
  }
 ]
}

/* eslint-disable */
const request = require('request');
const cloud = require('wx-server-sdk');

// 環(huán)境變量
const env = 'xxxx';

cloud.init({
  env
});

// 換取 access_token
async function getAccessToken(appid, secret) {
  return new Promise((resolve, reject) => {
    request.get(
      `https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=${appid}&secret=${secret}`,
      (err, res, body) => {
        if (err) {
          reject(err);
          return;
        }
        resolve(JSON.parse(body));
      }
    );
  });
}

// 創(chuàng)建導(dǎo)出任務(wù)
async function createExportJob(accessToken, collection) {
  const date = new Date().toISOString();

  return new Promise((resolve, reject) => {
    request.post(
      `https://api.weixin.qq.com/tcb/databasemigrateexport?access_token=${accessToken}`,
      {
        body: JSON.stringify({
          env,
          file_path: `${date}.json`,
          file_type: '1',
          query: `db.collection("${collection}").get()`
        })
      },
      (err, res, body) => {
        if (err) {
          reject(err);
        }

        resolve(JSON.parse(body));
      }
    );
  });
}

// 查詢導(dǎo)出任務(wù)狀態(tài)
async function waitJobFinished(accessToken, jobId) {
  return new Promise((resolve, reject) => {
    // 輪訓(xùn)任務(wù)狀態(tài)
    const timer = setInterval(() => {
      request.post(
        `https://api.weixin.qq.com/tcb/databasemigratequeryinfo?access_token=${accessToken}`,
        {
          body: JSON.stringify({
            env,
            job_id: jobId
          })
        },
        (err, res, body) => {
          if (err) {
            reject(err);
          }

          const { status, file_url } = JSON.parse(body);

          console.log('查詢');

          if (status === 'success') {
            clearInterval(timer);
            resolve(file_url);
          }
        }
      );
    }, 500);
  });
}
exports.main = async (event, context) => {
  // 從云函數(shù)環(huán)境變量中讀取 appid 和 secret 以及數(shù)據(jù)集合
  const { appid, secret, backupColl, backupInfoColl } = process.env;

  const db = cloud.database();

  try {
    // 獲取 access_token
    const { errmsg, access_token } = await getAccessToken(appid, secret);

    if (errmsg && errcode !== 0) {
      throw new Error(`獲取 access_token 失?。?{errmsg}` || '獲取 access_token 為空');
    }

    // 導(dǎo)出數(shù)據(jù)庫
    const { errmsg: jobErrMsg, errcode: jobErrCode, job_id } = await createExportJob(access_token, backupColl);

    // 打印到日志中
    console.log(job_id);

    if (jobErrCode !== 0) {
      throw new Error(`創(chuàng)建數(shù)據(jù)庫備份任務(wù)失?。?{jobErrMsg}`);
    }

    // 將任務(wù)數(shù)據(jù)存入數(shù)據(jù)庫
    const res = await db.collection('db_back_info').add({
      data: {
        date: new Date(),
        jobId: job_id
      }
    });

    // 等待任務(wù)完成
    const fileUrl = await waitJobFinished(access_token, job_id);

    console.log('導(dǎo)出成功', fileUrl);

    // 存儲(chǔ)到數(shù)據(jù)庫
    await db
      .collection(backupInfoColl)
      .doc(res._id)
      .update({
        data: {
          fileUrl
        }
      });
  } catch (e) {
    throw new Error(`導(dǎo)出數(shù)據(jù)庫異常：${e.message}`);
  }
};