欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

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

 更新時(shí)間：2019年08月16日 14:21:31   作者：無(wú)亦情  
這篇文章主要介紹了小程序云開(kāi)發(fā) 數(shù)據(jù)庫(kù)自動(dòng)備份實(shí)現(xiàn)過(guò)程解析,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

前言

數(shù)據(jù)是無(wú)價(jià)的，我們通常會(huì)把重要的業(yè)務(wù)數(shù)據(jù)存放在數(shù)據(jù)庫(kù)中，并需要對(duì)數(shù)據(jù)庫(kù)做定時(shí)的自動(dòng)備份工作，防止數(shù)據(jù)異常丟失，造成無(wú)法挽回的損失。

小程序云開(kāi)發(fā)提供了方便的云數(shù)據(jù)庫(kù)供我們直接使用，云開(kāi)發(fā)使用了騰訊云提供的云數(shù)據(jù)庫(kù)，擁有完善的數(shù)據(jù)保障機(jī)制，無(wú)需擔(dān)心數(shù)據(jù)丟失。但是，我們還是不可避免的會(huì)擔(dān)心數(shù)據(jù)庫(kù)中數(shù)據(jù)的安全，比如不小心刪除了數(shù)據(jù)集合，寫(xiě)入了臟數(shù)據(jù)等。

還好，云開(kāi)發(fā)控制臺(tái)提供了數(shù)據(jù)集合的導(dǎo)出，導(dǎo)入功能，我們可以手動(dòng)備份數(shù)據(jù)庫(kù)。不過(guò)，總是手動(dòng)備份數(shù)據(jù)庫(kù)也太麻煩了點(diǎn)，所有重復(fù)的事情都應(yīng)該讓代碼去解決，下面我們就說(shuō)說(shuō)怎么搞定云開(kāi)發(fā)數(shù)據(jù)庫(kù)自動(dòng)備份。

通過(guò)查閱微信的文檔，可以發(fā)現(xiàn)云開(kāi)發(fā)提供了數(shù)據(jù)導(dǎo)出接口databaseMigrateExport

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

通過(guò)這個(gè)接口，結(jié)合云函數(shù)的定時(shí)觸發(fā)功能，我們就可以做數(shù)據(jù)庫(kù)定時(shí)自動(dòng)備份了。梳理一下大致的流程：

  • 創(chuàng)建一個(gè)定時(shí)觸發(fā)的云函數(shù)
  • 云函數(shù)調(diào)用接口，導(dǎo)出數(shù)據(jù)庫(kù)備份文件
  • 將備份文件上傳到云存儲(chǔ)中以供使用

1. 獲取 access_token

調(diào)用微信的接口需要 access_token，所以我們首先要獲取 access_token。通過(guò)文檔了解到使用 auth.getAccessToken 接口可以用小程序的 appid 和 secret 獲取 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
  }
);

2. 創(chuàng)建數(shù)據(jù)庫(kù)導(dǎo)出任務(wù)

獲取 access_token 后，就可以使用 databaseMigrateExport 接口導(dǎo)出數(shù)據(jù)進(jìn)行備份。

databaseMigrateExport 接口會(huì)創(chuàng)建一個(gè)數(shù)據(jù)庫(kù)導(dǎo)出任務(wù)，并返回一個(gè) job_id，這個(gè) job_id 怎么用我們下面再說(shuō)。顯然數(shù)據(jù)庫(kù)的數(shù)據(jù)導(dǎo)出并不是同步的，而是需要一定時(shí)間的，數(shù)據(jù)量越大導(dǎo)出所要花費(fèi)的時(shí)間就越多，個(gè)人實(shí)測(cè)，2W 條記錄，2M 大小，導(dǎo)出大概需要 3~5 S。

調(diào)用 databaseMigrateExport 接口需要傳入環(huán)境 Id，存儲(chǔ)文件路徑，導(dǎo)出文件類(lèi)型（1 為 JSON，2 為 CSV），以及一個(gè) query 查詢(xún)語(yǔ)句。

因?yàn)槲覀兪亲鰯?shù)據(jù)庫(kù)備份，所以這里就導(dǎo)出 JSON 類(lèi)型的數(shù)據(jù)，兼容性更好。需要備份的數(shù)據(jù)可以用 query 來(lái)約束，這里還是很靈活的，既可以是整個(gè)集合的數(shù)據(jù)，也可以是指定的部分?jǐn)?shù)據(jù)，這里我們就使用 db.collection('data').get() 備份 data 集合的全部數(shù)據(jù)。同時(shí)我們使用當(dāng)前時(shí)間作為文件名，方便以后使用時(shí)查找。

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
  }
);

3. 查詢(xún)?nèi)蝿?wù)狀態(tài)，獲取文件地址

在創(chuàng)建號(hào)數(shù)據(jù)庫(kù)導(dǎo)出任務(wù)后，我們會(huì)得到一個(gè) job_id，如果導(dǎo)出集合比較大，就會(huì)花費(fèi)較長(zhǎng)時(shí)間，這時(shí)我們可以使用 databaseMigrateQueryInfo 接口查詢(xún)數(shù)據(jù)庫(kù)導(dǎo)出的進(jìn)度。

當(dāng)導(dǎo)出完成后，會(huì)返回一個(gè) file_url，即可以下載數(shù)據(jù)庫(kù)導(dǎo)出文件的臨時(shí)鏈接。

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
  }
);

獲取到文件下載鏈接之后，我們可以將文件下載下來(lái)，存入到自己的云存儲(chǔ)中，做備份使用。如果不需要長(zhǎng)時(shí)間的保留備份，就可以不用下載文件，只需要將 job_id 存儲(chǔ)起來(lái)，當(dāng)需要恢復(fù)備份的時(shí)候，通過(guò) job_id 查詢(xún)到新的鏈接，下載數(shù)據(jù)恢復(fù)即可。

至于 job_id 存在哪，就看個(gè)人想法了，這里就選擇存放在數(shù)據(jù)庫(kù)里。

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

4. 函數(shù)定時(shí)觸發(fā)器

云函數(shù)支持定時(shí)觸發(fā)器，可以按照設(shè)定的時(shí)間自動(dòng)執(zhí)行。云開(kāi)發(fā)的定時(shí)觸發(fā)器采用的 Cron 表達(dá)式語(yǔ)法，最大精度可以做的秒級(jí)，詳細(xì)的使用方法可以參考官方文檔：定時(shí)觸發(fā)器 | 微信開(kāi)放文檔

這里我們配置函數(shù)每天凌晨 2 點(diǎn)觸發(fā)，這樣就可以每天都對(duì)數(shù)據(jù)庫(kù)進(jìn)行備份。在云函數(shù)目錄下新建 config.json文件，寫(xiě)入如下內(nèi)容：

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

完整代碼

最后，貼出可以在云函數(shù)中使用的完整代碼，只需要?jiǎng)?chuàng)建一個(gè)定時(shí)觸發(fā)的云函數(shù)，并設(shè)置好相關(guān)的環(huán)境變量即可使用

  • appid
  • secret
  • backupColl：需要備份的集合名稱(chēng)，如 ‘data'
  • backupInfoColl：存儲(chǔ)備份信息的集合名稱(chēng)，如 ‘db_back_info'

注意，云函數(shù)的默認(rèn)超時(shí)時(shí)間是 3 秒，創(chuàng)建備份函數(shù)時(shí)，建議將超時(shí)時(shí)間設(shè)定到最大值 20S，留有足夠的時(shí)間查詢(xún)?nèi)蝿?wù)結(jié)果。

/* 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));
      }
    );
  });
}

// 查詢(xún)導(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('查詢(xún)');

          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ù)庫(kù)
    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ù)庫(kù)備份任務(wù)失敗：${jobErrMsg}`);
    }

    // 將任務(wù)數(shù)據(jù)存入數(shù)據(jù)庫(kù)
    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ù)庫(kù)
    await db
      .collection(backupInfoColl)
      .doc(res._id)
      .update({
        data: {
          fileUrl
        }
      });
  } catch (e) {
    throw new Error(`導(dǎo)出數(shù)據(jù)庫(kù)異常：${e.message}`);
  }
};

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

相關(guān)文章

最新評(píng)論