前言
專注于為中小企業(yè)提供網(wǎng)站建設、網(wǎng)站制作服務,電腦端+手機端+微信端的三站合一,更高效的管理,為中小企業(yè)溫江免費做網(wǎng)站提供優(yōu)質的服務。我們立足成都，凝聚了一批互聯(lián)網(wǎng)行業(yè)人才，有力地推動了上千余家企業(yè)的穩(wěn)健成長，幫助中小企業(yè)通過網(wǎng)站建設實現(xiàn)規(guī)模擴充和轉變。
數(shù)據(jù)是無價的，我們通常會把重要的業(yè)務數(shù)據(jù)存放在數(shù)據(jù)庫中，并需要對數(shù)據(jù)庫做定時的自動備份工作，防止數(shù)據(jù)異常丟失，造成無法挽回的損失。
小程序云開發(fā)提供了方便的云數(shù)據(jù)庫供我們直接使用，云開發(fā)使用了騰訊云提供的云數(shù)據(jù)庫，擁有完善的數(shù)據(jù)保障機制，無需擔心數(shù)據(jù)丟失。但是，我們還是不可避免的會擔心數(shù)據(jù)庫中數(shù)據(jù)的安全，比如不小心刪除了數(shù)據(jù)集合，寫入了臟數(shù)據(jù)等。
還好，云開發(fā)控制臺提供了數(shù)據(jù)集合的導出，導入功能，我們可以手動備份數(shù)據(jù)庫。不過，總是手動備份數(shù)據(jù)庫也太麻煩了點，所有重復的事情都應該讓代碼去解決，下面我們就說說怎么搞定云開發(fā)數(shù)據(jù)庫自動備份。
通過查閱微信的文檔，可以發(fā)現(xiàn)云開發(fā)提供了數(shù)據(jù)導出接口databaseMigrateExport
POST https://api.weixin.qq.com/tcb/databasemigrateexport?access_token=ACCESS_TOKEN
通過這個接口，結合云函數(shù)的定時觸發(fā)功能，我們就可以做數(shù)據(jù)庫定時自動備份了。梳理一下大致的流程：
1. 獲取 access_token
調用微信的接口需要 access_token，所以我們首先要獲取 access_token。通過文檔了解到使用 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
}
);2. 創(chuàng)建數(shù)據(jù)庫導出任務
獲取 access_token 后，就可以使用 databaseMigrateExport 接口導出數(shù)據(jù)進行備份。
databaseMigrateExport 接口會創(chuàng)建一個數(shù)據(jù)庫導出任務，并返回一個 job_id，這個 job_id 怎么用我們下面再說。顯然數(shù)據(jù)庫的數(shù)據(jù)導出并不是同步的，而是需要一定時間的，數(shù)據(jù)量越大導出所要花費的時間就越多，個人實測，2W 條記錄，2M 大小，導出大概需要 3~5 S。
調用 databaseMigrateExport 接口需要傳入環(huán)境 Id，存儲文件路徑，導出文件類型（1 為 JSON，2 為 CSV），以及一個 query 查詢語句。
因為我們是做數(shù)據(jù)庫備份，所以這里就導出 JSON 類型的數(shù)據(jù)，兼容性更好。需要備份的數(shù)據(jù)可以用 query 來約束，這里還是很靈活的，既可以是整個集合的數(shù)據(jù)，也可以是指定的部分數(shù)據(jù)，這里我們就使用 db.collection('data').get() 備份 data 集合的全部數(shù)據(jù)。同時我們使用當前時間作為文件名，方便以后使用時查找。
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
}
);3. 查詢任務狀態(tài)，獲取文件地址
在創(chuàng)建號數(shù)據(jù)庫導出任務后，我們會得到一個 job_id，如果導出集合比較大，就會花費較長時間，這時我們可以使用 databaseMigrateQueryInfo 接口查詢數(shù)據(jù)庫導出的進度。
當導出完成后，會返回一個 file_url，即可以下載數(shù)據(jù)庫導出文件的臨時鏈接。
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
}
);獲取到文件下載鏈接之后，我們可以將文件下載下來，存入到自己的云存儲中，做備份使用。如果不需要長時間的保留備份，就可以不用下載文件，只需要將 job_id 存儲起來，當需要恢復備份的時候，通過 job_id 查詢到新的鏈接，下載數(shù)據(jù)恢復即可。
至于 job_id 存在哪，就看個人想法了，這里就選擇存放在數(shù)據(jù)庫里。
await db.collection('db_back_info').add({
data: {
date: new Date(),
jobId: job_id
}
});4. 函數(shù)定時觸發(fā)器
云函數(shù)支持定時觸發(fā)器，可以按照設定的時間自動執(zhí)行。云開發(fā)的定時觸發(fā)器采用的 Cron 表達式語法，最大精度可以做的秒級，詳細的使用方法可以參考官方文檔：定時觸發(fā)器 | 微信開放文檔
這里我們配置函數(shù)每天凌晨 2 點觸發(fā)，這樣就可以每天都對數(shù)據(jù)庫進行備份。在云函數(shù)目錄下新建 config.json文件，寫入如下內容：
{
"triggers": [
{
"name": "dbTrigger",
"type": "timer",
"config": "0 0 2 * * * *"
}
]
}完整代碼
最后，貼出可以在云函數(shù)中使用的完整代碼，只需要創(chuàng)建一個定時觸發(fā)的云函數(shù)，并設置好相關的環(huán)境變量即可使用
注意，云函數(shù)的默認超時時間是 3 秒，創(chuàng)建備份函數(shù)時，建議將超時時間設定到最大值 20S，留有足夠的時間查詢任務結果。
/* 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)建導出任務
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));
}
);
});
}
// 查詢導出任務狀態(tài)
async function waitJobFinished(accessToken, jobId) {
return new Promise((resolve, reject) => {
// 輪訓任務狀態(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 為空');
}
// 導出數(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ù)庫備份任務失敗：${jobErrMsg}`);
}
// 將任務數(shù)據(jù)存入數(shù)據(jù)庫
const res = await db.collection('db_back_info').add({
data: {
date: new Date(),
jobId: job_id
}
});
// 等待任務完成
const fileUrl = await waitJobFinished(access_token, job_id);
console.log('導出成功', fileUrl);
// 存儲到數(shù)據(jù)庫
await db
.collection(backupInfoColl)
.doc(res._id)
.update({
data: {
fileUrl
}
});
} catch (e) {
throw new Error(`導出數(shù)據(jù)庫異常：${e.message}`);
}
};以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持創(chuàng)新互聯(lián)。
