鉆石有價，數(shù)據(jù)無價。我們通常會把重要的業(yè)務(wù)數(shù)據(jù)存放在數(shù)據(jù)庫中，并需要對數(shù)據(jù)庫做定時的自動備份工作，防止數(shù)據(jù)異常丟失，造成無法挽回的損失。

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

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

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

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

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

(1)創(chuàng)建一個定時觸發(fā)的云函數(shù)。

(2)云函數(shù)調(diào)用接口，導(dǎo)出數(shù)據(jù)庫備份文件。

(3)將備份文件上傳到云存儲中以供使用。

獲取 access_token

調(diào)用微信的接口需要 accesstoken，所以我們首先要獲取 accesstoken。通過文檔了解到使用 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) {

// 處理錯誤

return;

}

const data = JSON.parse(body);

// data.access_token

}

);

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

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

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

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

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

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) {

// 處理錯誤

return;

}

const data = JSON.parse(body);

// data.job_id

}

);

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

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

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

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

}

);

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

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

await db.collection('db_back_info').add({

data: {

date: new Date(),

jobId: job_id

}

});

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

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

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

{

"triggers": [

{

"name": "dbTrigger",

"type": "timer",

"config": "0 0 2 * * * *"

}

]

}

完整代碼

在源碼基礎(chǔ)上，只需要創(chuàng)建一個定時觸發(fā)的云函數(shù)，并設(shè)置好相關(guān)的環(huán)境變量即可使用：

• appid

• secret

• backupColl：需要備份的集合名稱，如 ‘data’

• backupInfoColl：存儲備份信息的集合名稱，如 ‘dbbackinfo’

注意，云函數(shù)的默認(rèn)超時時間是 3 秒，創(chuàng)建備份函數(shù)時，建議將超時時間設(shè)定到最大值 20S，留有足夠的時間查詢?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));

}

);

});

}

// 查詢導(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);

// 存儲到數(shù)據(jù)庫

await db

.collection(backupInfoColl)

.doc(res._id)

.update({

data: {

fileUrl

}

});

} catch (e) {

throw new Error(`導(dǎo)出數(shù)據(jù)庫異常：${e.message}`);

}

};

海量云開發(fā)實

?

?往期精彩?

點擊下方圖片即可閱讀

云開發(fā) · 不止于「快」

云開發(fā)

Tencent CloudBase

? ? ? 點擊在看讓更多人發(fā)現(xiàn)精彩

總結(jié)

以上是生活随笔為你收集整理的access 根据id删除数据_小程序云开发之数据库自动备份丨云开发101的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。