支持配置文件进行配置

添加七牛云推送日志

Author: TryBin03

.gitignore

@@ -1,2 +1,5 @@
 node_modules
-package-lock.json
+package-lock.json
+backup-*.conf
+
+.idea

README.md

@@ -2,28 +2,46 @@
 在操作数据过程中，可能会导致数据错误，甚至数据库奔溃，而有效的定时备份能很好地保护数据库。使用本仓库加上`crontab`可以实现定时备份MySQL
 
 ## 配置
-### bf.sh
-```sh
-# 程序路径
-path=/backup
-# 备份数据保存地址
-backUpFolder="$path/data/$dbName"
+### 默认配置（`backup.conf`）
+修改成你的配置，还可以在通过传入配置文件名称的方式实现多配置（后面会讲到）。
+```
+# 需要备份的数据库名称
+dbName=bf_test
+# 文件路径（实际路径会加上dbName）
+dataPath=/bf/data
+# zip包密码，建议设置复杂一点
+zipPwd=myPassword
+
 # MySQL用户
-MySQLUser=MySQL 
+MySQLUser=root
 # MySQL用户密码
-MySQLPwd=MySQL
-# zip包密码，建议设置复杂一点
-zipPwd=password
+MySQLPwd=MySQLPwd
+
+# 桶名称
+bucketName=你的七牛云桶名称
+# 七牛云ak
+qiniuAccessKey=你的七牛云ak
+# 七牛云sk
+qiniuSecretKey=你的七牛云sk
 ```
-### qiniu_config.js
-```js
-//七牛云ak
-var accessKey = 'XXX';
-//七牛云sk
-var secretKey = 'XXX';
+## 使用
+### 默认配置
+默认使用 `backup.conf` 作为配置文件
+```sh
+bash bf.sh
 ```
-### upload.js
-```js
-// 桶名称
-const uploadToken = getToken("bucket")
+### 指定配置文件
+使用 `backup-test.conf` 作为配置文件
+```sh
+bash bf.sh backup-test.conf
 ```
+> ## 注意!!!：配置文件需要和`bf.sh`放在同一目录
+### 在`crontab`中使用
+```sh
+# 每天3点备份test数据库
+0 3 * * * bash bf.sh backup-test.conf
+# 每天3点15分备份dev数据库
+15 3 * * * bash bf.sh backup-dev.conf
+# 每天3点30分备份job数据库
+30 3 * * * bash bf.sh backup-job.conf
+```

backup.conf

@@ -0,0 +1,18 @@
+# 需要备份的数据库名称
+dbName=bf_test
+# 文件路径（实际路径会加上dbName）
+dataPath=/bf/data
+# zip包密码，建议设置复杂一点
+zipPwd=myPassword
+
+# MySQL用户
+MySQLUser=root
+# MySQL用户密码
+MySQLPwd=MySQLPwd
+
+# 桶名称
+bucketName=你的七牛云桶名称
+# 七牛云ak
+qiniuAccessKey=你的七牛云ak
+# 七牛云sk
+qiniuSecretKey=你的七牛云sk

bf.sh

@@ -1,16 +1,30 @@
-# 需要备份的数据库名称
-dbName=$1
-# 程序路径
-path=/backup
-# MySQL用户
-MySQLUser=MySQL 
-# MySQL用户密码
-MySQLPwd=MySQL
-# zip包密码，建议设置复杂一点
-zipPwd=password
+#!/bin/bash
+
+# 获取当前脚本的目录路径
+SCRIPT_DIR=$(cd "$(dirname "$0")" && pwd)
+
+DEFAULT_CONFIG="backup.conf"
+
+# 如果用户提供了配置文件路径，则使用用户的配置文件
+if [ "$1" ]; then
+  CONFIG_FILE="$1"
+else
+  CONFIG_FILE="$DEFAULT_CONFIG"
+fi
+
+CONFIG_FILE="$SCRIPT_DIR/$CONFIG_FILE"
+
+# 检查文件是否存在
+if [ ! -f "$CONFIG_FILE" ]; then
+  echo "错误: 配置文件 $CONFIG_FILE 不存在"
+  exit 1
+fi
+
+# 读取配置文件
+source $CONFIG_FILE
 
 # 设定 文件夹
-backUpFolder="$path/data/$dbName"  #定时保存打包数据库的文件 的位置
+backUpFolder="$dataPath/$dbName"  #定时保存打包数据库的文件 的位置
 date_now=`date +%Y_%m_%d_%H%M`
 backFileName=$dbName_$date_now
 
@@ -20,12 +34,16 @@ if [ ! -d $backUpFolder ];then
 fi
 cd $backUpFolder
 
-mysqldump -u$MySQLUser -p$MySQLPwd $dbName > $backFileName
+mysqldump -h 127.0.0.1 -P 33711 -u$MySQLUser -p$MySQLPwd $dbName > $backFileName
 
 #打包备份数据库 
-zip -rP $zipPwd  $backFileName.zip $backFileName
+zip -rP $zipPwd $backFileName.zip $backFileName
 
 # 移除临时文件
 rm -rf $backFileName
 
-NODE_ENV=$backUpFolder@$backFileName@$dbName node $path/start.js # 此程序位置
+# 备份文件位置@备份文件名称（无后缀）@数据库名称@桶名称@七牛云Ak@七牛云SK
+NODE_ENV=$backUpFolder@$backFileName@$dbName@$bucketName@$qiniuAccessKey@$qiniuSecretKey node $SCRIPT_DIR/src/start.js # 此程序位置
+
+# 删除90天前的备份文件
+find $backUpFolder -type f -name "*.zip" -mtime +90 -exec rm -f {} \;

package.json

@@ -1,14 +1,16 @@
 {
   "dependencies": {
     "bcryptjs": "^2.4.3",
-    "qiniu": "^7.9.0"
+    "qiniu": "^7.9.0",
+    "winston": "^3.17.0",
+    "winston-daily-rotate-file": "^5.0.0"
   },
   "devDependencies": {
     "babel-preset-env": "^1.7.0",
     "babel-register": "^6.26.0",
     "cross-env": "^7.0.3"
   },
   "scripts": {
-    "dev": "cross-env NODE_ENV=文件路径@文件名称不带后缀 node start.js"
+    "dev": "cross-env NODE_ENV=备份文件位置@备份文件名称(无后缀)@数据库名称@桶名称@七牛云Ak@七牛云SK node src/start.js"
   }
 }

bcrypt.js renamed to src/bcrypt.js

@@ -0,0 +1,79 @@
+const fs = require('fs'); // 添加这行代码
+const winston = require('winston');
+const DailyRotateFile = require('winston-daily-rotate-file');
+const path = require('path');
+
+class Logger {
+    constructor(options = {}) {
+        // 默认配置
+        const defaultOptions = {
+            level: 'info', // 默认日志级别
+            logDir: path.join(__dirname, '../logs'), // 默认日志目录
+            filename: 'app-%DATE%.log', // 默认日志文件名
+            datePattern: 'YYYY-MM-DD', // 按天分割日志
+            maxSize: '20m', // 每个文件最大 20MB
+            maxFiles: '14d', // 保留最近 14 天的日志
+            format: winston.format.combine(
+                winston.format.timestamp(), // 添加时间戳
+                winston.format.printf(({ level, message, timestamp }) => {
+                    return `${timestamp} [${level}]: ${message}`;
+                })
+            ),
+        };
+
+        // 合并用户配置和默认配置
+        this.options = Object.assign({}, defaultOptions, options);
+        // this.options = { ...defaultOptions, ...options };
+
+        // 确保日志目录存在
+        if (!fs.existsSync(this.options.logDir)) {
+            fs.mkdirSync(this.options.logDir, { recursive: true });
+        }
+
+        // 创建 Logger 实例
+        this.logger = winston.createLogger({
+            level: this.options.level,
+            format: this.options.format,
+            transports: [
+                new DailyRotateFile({
+                    dirname: this.options.logDir,
+                    filename: this.options.filename,
+                    datePattern: this.options.datePattern,
+                    maxSize: this.options.maxSize,
+                    maxFiles: this.options.maxFiles,
+                }),
+                new winston.transports.Console({ // 同时输出到控制台
+                    format: winston.format.combine(
+                        winston.format.colorize(), // 控制台日志添加颜色
+                        winston.format.simple() // 简单格式
+                    ),
+                }),
+            ],
+        });
+    }
+
+    // 记录日志的方法
+    log(level, message, meta = {}) {
+        this.logger.log(level, message, meta);
+    }
+
+    // 快捷方法
+    info(message, meta) {
+        this.log('info', message, meta);
+    }
+
+    warn(message, meta) {
+        this.log('warn', message, meta);
+    }
+
+    error(message, meta) {
+        this.log('error', message, meta);
+    }
+
+    debug(message, meta) {
+        this.log('debug', message, meta);
+    }
+}
+
+// 导出工具类
+module.exports = Logger;

src/log.js

@@ -1,8 +1,8 @@
 import * as qiniu from 'qiniu'
 
-export const getToken = (bucket) => {
-        var accessKey = 'XXX'; //七牛云ak
-        var secretKey = 'XXX'; //七牛云sk
+export const getToken = (bucket, ak, sk) => {
+        var accessKey = ak; //七牛云ak
+        var secretKey = sk; //七牛云sk
         var bucket = bucket
         var mac = new qiniu.auth.digest.Mac(accessKey, secretKey);
 

qiniu_config.js renamed to src/qiniu_config.js

@@ -1,34 +1,38 @@
 import * as qiniu from 'qiniu'
 
-import  {getToken} from  './qiniu_config.js'
+import  {getToken} from './qiniu_config.js'
+const Logger = require('./log'); // 使用 require 导入
+const logger = new Logger(); // 初始化日志对象
 
-const uploadToken = getToken("bucket") // 桶名称
 
-console.log(uploadToken)
+const parts = process.env.NODE_ENV.split('@')
+
+const uploadToken = getToken(parts[3], parts[4], parts[5]) // 桶名称
+
+logger.info(uploadToken)
 
 const config = new qiniu.conf.Config();
 config.zone = qiniu.zone.Zone_z2; // 空间对应的机房，需自行更改
 const formUploader = new qiniu.form_up.FormUploader(config);
 const putExtra = new qiniu.form_up.PutExtra();
 
-
-const parts  = process.env.NODE_ENV.split('@')
 const file = parts[1] + '.zip'
 const filePath = parts[0] + '/' + file
 
 const key=parts[2] + '/' + file;  //上传到服务器的名称
 const localFile = filePath; // 本地文件路径
+logger.info("上传文件【"+ localFile + "】...")
 formUploader.putFile(uploadToken, key, localFile, putExtra, function (respErr,
   respBody, respInfo) {
   if (respErr) {
     throw respErr;
   }
-  if (respInfo.statusCode == 200) {
-    console.log('上传成功')
-    console.log(respBody);
+  if (respInfo.statusCode === 200) {
+    logger.info('上传成功(' + respInfo.statusCode + ')');
+    logger.info(JSON.stringify(respInfo));
   } else {
-    console.log(respInfo.statusCode);
-    console.log(respBody);
+    logger.error('上传失败(' + respInfo.statusCode + ')');
+    logger.error(JSON.stringify(respInfo));
   }
 });