diff --git a/pkg/backup.go b/pkg/backup.go index 3bdc6d0..9861f46 100644 --- a/pkg/backup.go +++ b/pkg/backup.go @@ -261,6 +261,9 @@ func localBackup(db *dbConfig, config *BackupConfig) { func s3Backup(db *dbConfig, config *BackupConfig) { bucket := utils.GetEnvVariable("AWS_S3_BUCKET_NAME", "BUCKET_NAME") s3Path := utils.GetEnvVariable("AWS_S3_PATH", "S3_PATH") + if config.remotePath != "" { + s3Path = config.remotePath + } utils.Info("Backup database to s3 storage") startTime = time.Now().Format(utils.TimeFormat()) //Backup database @@ -305,7 +308,7 @@ func s3Backup(db *dbConfig, config *BackupConfig) { BackupSize: backupSize, Database: db.dbName, Storage: config.storage, - BackupLocation: filepath.Join(config.remotePath, finalFileName), + BackupLocation: filepath.Join(s3Path, finalFileName), StartTime: startTime, EndTime: time.Now().Format(utils.TimeFormat()), })