|
|
|
|
@@ -94,7 +94,7 @@ bootstrap_variables() {
|
|
|
|
|
DB"${backup_instance_number}"_BLOBXFER_STORAGE_ACCOUNT_KEY \
|
|
|
|
|
DB"${backup_instance_number}"_BLOBXFER_REMOTE_PATH \
|
|
|
|
|
BLOBXFER_STORAGE_ACCOUNT \
|
|
|
|
|
BLOBXFER_STORAGE_KEY \
|
|
|
|
|
BLOBXFER_STORAGE_ACCOUNT_KEY \
|
|
|
|
|
DB_HOST \
|
|
|
|
|
DB_NAME \
|
|
|
|
|
DB_PORT \
|
|
|
|
|
@@ -153,6 +153,11 @@ bootstrap_variables() {
|
|
|
|
|
fi
|
|
|
|
|
##
|
|
|
|
|
|
|
|
|
|
if grep -qo ".*_NAME='.*'" "${backup_instance_vars}"; then
|
|
|
|
|
print_debug "[bootstrap_variables] [backup_init] Found _NAME variable with quotes"
|
|
|
|
|
sed -i "s|_NAME='\(.*\)'|_NAME=\1|g" "${backup_instance_vars}"
|
|
|
|
|
fi
|
|
|
|
|
|
|
|
|
|
if grep -qo ".*_PASS='.*'" "${backup_instance_vars}"; then
|
|
|
|
|
print_debug "[bootstrap_variables] [backup_init] Found _PASS variable with quotes"
|
|
|
|
|
sed -i "s|_PASS='\(.*\)'|_PASS=\1|g" "${backup_instance_vars}"
|
|
|
|
|
@@ -188,7 +193,7 @@ bootstrap_variables() {
|
|
|
|
|
transform_backup_instance_variable "${backup_instance_number}" BLACKOUT_END backup_job_snapshot_blackout_finish
|
|
|
|
|
transform_backup_instance_variable "${backup_instance_number}" BLOBXFER_REMOTE_PATH backup_job_blobxfer_remote_path
|
|
|
|
|
transform_backup_instance_variable "${backup_instance_number}" BLOBXFER_STORAGE_ACCOUNT backup_job_blobxfer_storage_account
|
|
|
|
|
transform_backup_instance_variable "${backup_instance_number}" BLOBXFER_STORAGE_KEY backup_job_blobxfer_storage_key
|
|
|
|
|
transform_backup_instance_variable "${backup_instance_number}" BLOBXFER_STORAGE_ACCOUNT_KEY backup_job_blobxfer_storage_account_key
|
|
|
|
|
transform_backup_instance_variable "${backup_instance_number}" CHECKSUM backup_job_checksum
|
|
|
|
|
transform_backup_instance_variable "${backup_instance_number}" CLEANUP_TIME backup_job_cleanup_time
|
|
|
|
|
transform_backup_instance_variable "${backup_instance_number}" COMPRESSION backup_job_compression
|
|
|
|
|
@@ -482,10 +487,11 @@ backup_couch() {
|
|
|
|
|
move_dbbackup
|
|
|
|
|
check_exit_code move "${backup_job_filename}"
|
|
|
|
|
post_dbbackup ${backup_job_db_name}
|
|
|
|
|
cleanup_old_data
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
backup_influx() {
|
|
|
|
|
if var_true "${DEBUG_BACKUP_INFLUX}" ; then debug on; fi
|
|
|
|
|
if var_true "${DEBUG_BACKUP_INFLUX}" ; then debug on; fi
|
|
|
|
|
if [ "${backup_job_db_name,,}" = "all" ] ; then
|
|
|
|
|
write_log debug "[backup_influx] Preparing to back up everything"
|
|
|
|
|
db_names=justbackupeverything
|
|
|
|
|
@@ -508,20 +514,19 @@ backup_influx() {
|
|
|
|
|
pre_dbbackup "${db}"
|
|
|
|
|
write_log notice "Dumping Influx database: '${db}'"
|
|
|
|
|
if var_true "${DEBUG_BACKUP_INFLUX}" ; then debug on; fi
|
|
|
|
|
run_as_user influxd backup ${influx_compression} ${bucket} -portable -host ${backup_job_db_host}:${backup_job_db_port} ${backup_job_extra_opts} ${backup_job_extra_dump_opts} "${TEMP_PATH}"/"${backup_job_filename_dir}"
|
|
|
|
|
run_as_user influxd backup ${influx_compression} ${bucket} -portable -host ${backup_job_db_host}:${backup_job_db_port} ${backup_job_extra_opts} ${backup_job_extra_dump_opts} "${temporary_directory}"/"${backup_job_filename}"
|
|
|
|
|
exit_code=$?
|
|
|
|
|
check_exit_code backup "${backup_job_filename_dir}"
|
|
|
|
|
write_log notice "Creating archive file of '${backup_job_filename_dir}' with tar ${compression_string}"
|
|
|
|
|
run_as_user tar cf - "${TEMP_PATH}"/"${backup_job_filename_dir}" | ${dir_compress_cmd} | run_as_user tee "${TEMP_PATH}"/"${backup_job_filename_dir}".tar"${extension}" > /dev/null
|
|
|
|
|
backup_job_filename=influx_${db}_${backup_job_db_host#*//}_${now}.tar${extension}
|
|
|
|
|
backup_job_filename_base=influx_${db}_${backup_job_db_host#*//}
|
|
|
|
|
check_exit_code backup "${backup_job_filename}"
|
|
|
|
|
create_archive
|
|
|
|
|
backup_job_filename=influx2_${db}_${backup_job_db_host#*//}_${now}.tar${extension}
|
|
|
|
|
if var_true "${DEBUG_BACKUP_INFLUX}" ; then debug off; fi
|
|
|
|
|
timer backup finish
|
|
|
|
|
file_encryption
|
|
|
|
|
generate_checksum
|
|
|
|
|
move_dbbackup
|
|
|
|
|
check_exit_code move "${backup_job_filename_dir}"
|
|
|
|
|
check_exit_code move "${backup_job_filename}"
|
|
|
|
|
post_dbbackup "${db}"
|
|
|
|
|
cleanup_old_data
|
|
|
|
|
done
|
|
|
|
|
;;
|
|
|
|
|
2 )
|
|
|
|
|
@@ -537,19 +542,19 @@ backup_influx() {
|
|
|
|
|
pre_dbbackup "${db}"
|
|
|
|
|
write_log notice "Dumping Influx2 database: '${db}'"
|
|
|
|
|
if var_true "${DEBUG_BACKUP_INFLUX}" ; then debug on; fi
|
|
|
|
|
run_as_user influx backup --org ${backup_job_db_user} ${bucket} --host ${backup_job_db_host}:${backup_job_db_port} --token ${backup_job_db_pass} ${backup_job_extra_opts} ${backup_job_extra_dump_opts} --compression none "${TEMP_PATH}"/"${backup_job_filename_dir}"
|
|
|
|
|
run_as_user influx backup --org ${backup_job_db_user} ${bucket} --host ${backup_job_db_host}:${backup_job_db_port} --token ${backup_job_db_pass} ${backup_job_extra_opts} ${backup_job_extra_dump_opts} --compression none "${temporary_directory}"/"${backup_job_filename}"
|
|
|
|
|
exit_code=$?
|
|
|
|
|
check_exit_code backup "${backup_job_filename_dir}"
|
|
|
|
|
if var_true "${DEBUG_BACKUP_INFLUX}" ; then debug off; fi
|
|
|
|
|
check_exit_code backup "${backup_job_filename}"
|
|
|
|
|
create_archive
|
|
|
|
|
backup_job_filename=influx2_${db}_${backup_job_db_host#*//}_${now}.tar${extension}
|
|
|
|
|
backup_job_filename_base=influx2_${db}_${backup_job_db_host#*//}
|
|
|
|
|
if var_true "${DEBUG_BACKUP_INFLUX}" ; then debug off; fi
|
|
|
|
|
timer backup finish
|
|
|
|
|
file_encryption
|
|
|
|
|
generate_checksum
|
|
|
|
|
move_dbbackup
|
|
|
|
|
check_exit_code move "${backup_job_filename_dir}"
|
|
|
|
|
check_exit_code move "${backup_job_filename}"
|
|
|
|
|
post_dbbackup "${db}"
|
|
|
|
|
cleanup_old_data
|
|
|
|
|
done
|
|
|
|
|
;;
|
|
|
|
|
esac
|
|
|
|
|
@@ -574,9 +579,9 @@ backup_mongo() {
|
|
|
|
|
fi
|
|
|
|
|
if var_true "${DEBUG_BACKUP_MONGO}" ; then debug off; fi
|
|
|
|
|
pre_dbbackup "${backup_job_db_name}"
|
|
|
|
|
write_log notice "Dumping MongoDB database: '${DB_NAME}' ${compression_string}"
|
|
|
|
|
write_log notice "Dumping MongoDB database: '${backup_job_db_name}' ${compression_string}"
|
|
|
|
|
if var_true "${DEBUG_BACKUP_MONGO}" ; then debug on; fi
|
|
|
|
|
silent run_as_user ${play_fair} mongodump --archive=${TEMP_PATH}/${backup_job_filename} ${mongo_compression} ${mongo_backup_parameter}
|
|
|
|
|
silent run_as_user ${play_fair} mongodump --archive=${temporary_directory}/${backup_job_filename} ${mongo_compression} ${mongo_backup_parameter}
|
|
|
|
|
exit_code=$?
|
|
|
|
|
if var_true "${DEBUG_BACKUP_MONGO}" ; then debug off; fi
|
|
|
|
|
check_exit_code backup "${backup_job_filename}"
|
|
|
|
|
@@ -586,6 +591,7 @@ backup_mongo() {
|
|
|
|
|
move_dbbackup
|
|
|
|
|
check_exit_code move "${backup_job_filename}"
|
|
|
|
|
post_dbbackup "${backup_job_db_name}"
|
|
|
|
|
cleanup_old_data
|
|
|
|
|
if var_true "${DEBUG_BACKUP_MONGO}" ; then debug off; fi
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@@ -596,16 +602,16 @@ backup_mssql() {
|
|
|
|
|
backup_job_filename=mssql_${backup_job_db_name,,}_${backup_job_db_host,,}_${now}.bak
|
|
|
|
|
backup_job_filename_base=mssql_${backup_job_db_name,,}_${backup_job_db_host,,}
|
|
|
|
|
pre_dbbackup "${backup_job_db_name}"
|
|
|
|
|
write_log notice "Dumping MSSQL database: '${DB_NAME}'"
|
|
|
|
|
write_log notice "Dumping MSSQL database: '${backup_job_db_name}'"
|
|
|
|
|
if var_true "${DEBUG_BACKUP_MSSQL}" ; then debug on; fi
|
|
|
|
|
silent run_as_user ${play_fair} /opt/mssql-tools18/bin/sqlcmd -C -S ${backup_job_db_host}\,${backup_job_db_port} -U ${backup_job_db_user} -P ${backup_job_db_pass} -Q "BACKUP DATABASE [${backup_job_db_name}] TO DISK = N'${TEMP_PATH}/${backup_job_filename}' WITH NOFORMAT, NOINIT, NAME = '${backup_job_db_name}-full', SKIP, NOREWIND, NOUNLOAD, STATS = 10"
|
|
|
|
|
silent run_as_user ${play_fair} /opt/mssql-tools18/bin/sqlcmd -C -S ${backup_job_db_host}\,${backup_job_db_port} -U ${backup_job_db_user} -P ${backup_job_db_pass} -Q "BACKUP DATABASE [${backup_job_db_name}] TO DISK = N'${temporary_directory}/${backup_job_filename}' WITH NOFORMAT, NOINIT, NAME = '${backup_job_db_name}-full', SKIP, NOREWIND, NOUNLOAD, STATS = 10"
|
|
|
|
|
exit_code=$?
|
|
|
|
|
if var_true "${DEBUG_BACKUP_MSSQL}" ; then debug off; fi
|
|
|
|
|
backup_job_filename_original=${backup_job_filename}
|
|
|
|
|
compression
|
|
|
|
|
pre_dbbackup all
|
|
|
|
|
if var_true "${DEBUG_BACKUP_MSSQL}" ; then debug on; fi
|
|
|
|
|
run_as_user ${compress_cmd} "${TEMP_PATH}/${backup_job_filename_original}"
|
|
|
|
|
run_as_user ${compress_cmd} "${temporary_directory}/${backup_job_filename_original}"
|
|
|
|
|
check_exit_code backup "${backup_job_filename}"
|
|
|
|
|
if var_true "${DEBUG_BACKUP_MSSQL}" ; then debug off; fi
|
|
|
|
|
timer backup finish
|
|
|
|
|
@@ -614,28 +620,30 @@ backup_mssql() {
|
|
|
|
|
move_dbbackup
|
|
|
|
|
check_exit_code move "${backup_job_filename}"
|
|
|
|
|
post_dbbackup "${backup_job_db_name}"
|
|
|
|
|
cleanup_old_data
|
|
|
|
|
;;
|
|
|
|
|
trn|transaction )
|
|
|
|
|
prepare_dbbackup
|
|
|
|
|
backup_job_filename=mssql_${backup_job_db_name,,}_${backup_job_db_host,,}_${now}.trn
|
|
|
|
|
backup_job_filename_base=mssql_${backup_job_db_name,,}_trn_${backup_job_db_host,,}
|
|
|
|
|
pre_dbbackup "${backup_job_db_name}"
|
|
|
|
|
write_log notice "Dumping MSSQL database: '${DB_NAME}'"
|
|
|
|
|
write_log notice "Dumping MSSQL database: '${backup_job_db_name}'"
|
|
|
|
|
if var_true "${DEBUG_BACKUP_MSSQL}" ; then debug on; fi
|
|
|
|
|
silent run_as_user ${play_fair} /opt/mssql-tools18/bin/sqlcmd -C -S ${backup_job_db_host}\,${backup_job_db_port} -U ${backup_job_db_user} -P ${backup_job_db_pass} -Q "BACKUP LOG [${backup_job_db_name}] TO DISK = N'${TEMP_PATH}/${backup_job_filename}' WITH NOFORMAT, NOINIT, NAME = '${backup_job_db_name}-log', SKIP, NOREWIND, NOUNLOAD, STATS = 10"
|
|
|
|
|
silent run_as_user ${play_fair} /opt/mssql-tools18/bin/sqlcmd -C -S ${backup_job_db_host}\,${backup_job_db_port} -U ${backup_job_db_user} -P ${backup_job_db_pass} -Q "BACKUP LOG [${backup_job_db_name}] TO DISK = N'${temporary_directory}/${backup_job_filename}' WITH NOFORMAT, NOINIT, NAME = '${backup_job_db_name}-log', SKIP, NOREWIND, NOUNLOAD, STATS = 10"
|
|
|
|
|
exit_code=$?
|
|
|
|
|
if var_true "${DEBUG_BACKUP_MSSQL}" ; then debug off; fi
|
|
|
|
|
backup_job_filename_original=${backup_job_filename}
|
|
|
|
|
compression
|
|
|
|
|
pre_dbbackup all
|
|
|
|
|
run_as_user ${compress_cmd} "${TEMP_PATH}/${backup_job_filename_original}"
|
|
|
|
|
check_exit_code backup "${backup_job_filename}"
|
|
|
|
|
run_as_user ${compress_cmd} "${temporary_directory}/${backup_job_filename_original}"
|
|
|
|
|
|
|
|
|
|
file_encryption
|
|
|
|
|
timer backup finish
|
|
|
|
|
generate_checksum
|
|
|
|
|
move_dbbackup
|
|
|
|
|
check_exit_code move "${backup_job_filename}"
|
|
|
|
|
post_dbbackup "${backup_job_db_name}"
|
|
|
|
|
cleanup_old_data
|
|
|
|
|
;;
|
|
|
|
|
esac
|
|
|
|
|
}
|
|
|
|
|
@@ -677,7 +685,7 @@ backup_mysql() {
|
|
|
|
|
pre_dbbackup "${db}"
|
|
|
|
|
write_log notice "Dumping MySQL/MariaDB database: '${db}' ${compression_string}"
|
|
|
|
|
if var_true "${DEBUG_BACKUP_MYSQL}" ; then debug on; fi
|
|
|
|
|
run_as_user ${play_fair} mysqldump --max-allowed-packet=${backup_job_mysql_max_allowed_packet} -h ${backup_job_db_host} -P ${backup_job_db_port} -u${backup_job_db_user} ${events} ${single_transaction} ${stored_procedures} ${mysql_tls_args} ${backup_job_extra_opts} ${backup_job_extra_dump_opts} $db | ${compress_cmd} | run_as_user tee "${TEMP_PATH}"/"${backup_job_filename}" > /dev/null
|
|
|
|
|
run_as_user ${play_fair} mysqldump --max-allowed-packet=${backup_job_mysql_max_allowed_packet} -h ${backup_job_db_host} -P ${backup_job_db_port} -u${backup_job_db_user} ${events} ${single_transaction} ${stored_procedures} ${mysql_tls_args} ${backup_job_extra_opts} ${backup_job_extra_dump_opts} $db | ${compress_cmd} | run_as_user tee "${temporary_directory}"/"${backup_job_filename}" > /dev/null
|
|
|
|
|
exit_code=$?
|
|
|
|
|
if var_true "${DEBUG_BACKUP_MYSQL}" ; then debug off; fi
|
|
|
|
|
check_exit_code backup "${backup_job_filename}"
|
|
|
|
|
@@ -687,6 +695,7 @@ backup_mysql() {
|
|
|
|
|
move_dbbackup
|
|
|
|
|
check_exit_code move "${backup_job_filename}"
|
|
|
|
|
post_dbbackup "${db}"
|
|
|
|
|
cleanup_old_data
|
|
|
|
|
done
|
|
|
|
|
else
|
|
|
|
|
write_log debug "Not splitting database dumps into their own files"
|
|
|
|
|
@@ -697,7 +706,7 @@ backup_mysql() {
|
|
|
|
|
pre_dbbackup all
|
|
|
|
|
write_log notice "Dumping all MySQL / MariaDB databases: '$(echo ${db_names} | xargs | tr ' ' ',')' ${compression_string}"
|
|
|
|
|
if var_true "${DEBUG_BACKUP_MYSQL}" ; then debug on; fi
|
|
|
|
|
run_as_user ${play_fair} mysqldump --max-allowed-packet=${backup_job_mysql_max_allowed_packet} -h ${backup_job_db_host} -P ${backup_job_db_port} -u${backup_job_db_user} ${events} ${single_transaction} ${stored_procedures} ${mysql_tls_args} ${backup_job_extra_opts} ${backup_job_extra_dump_opts} --databases $(echo ${db_names} | xargs) | ${compress_cmd} | run_as_user tee "${TEMP_PATH}"/"${backup_job_filename}" > /dev/null
|
|
|
|
|
run_as_user ${play_fair} mysqldump --max-allowed-packet=${backup_job_mysql_max_allowed_packet} -h ${backup_job_db_host} -P ${backup_job_db_port} -u${backup_job_db_user} ${events} ${single_transaction} ${stored_procedures} ${mysql_tls_args} ${backup_job_extra_opts} ${backup_job_extra_dump_opts} --databases $(echo ${db_names} | xargs) | ${compress_cmd} | run_as_user tee "${temporary_directory}"/"${backup_job_filename}" > /dev/null
|
|
|
|
|
exit_code=$?
|
|
|
|
|
if var_true "${DEBUG_BACKUP_MYSQL}" ; then debug off; fi
|
|
|
|
|
check_exit_code backup "${backup_job_filename}"
|
|
|
|
|
@@ -707,6 +716,7 @@ backup_mysql() {
|
|
|
|
|
move_dbbackup
|
|
|
|
|
check_exit_code move "${backup_job_filename}"
|
|
|
|
|
post_dbbackup all
|
|
|
|
|
cleanup_old_data
|
|
|
|
|
fi
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@@ -718,7 +728,7 @@ backup_pgsql() {
|
|
|
|
|
pre_dbbackup "globals"
|
|
|
|
|
print_notice "Dumping PostgresSQL globals: with 'pg_dumpall -g' ${compression_string}"
|
|
|
|
|
if var_true "${DEBUG_BACKUP_PGSQL}" ; then debug on; fi
|
|
|
|
|
run_as_user ${play_fair} pg_dumpall -h "${backup_job_db_host}" -U "${backup_job_db_user}" -p "${backup_job_db_port}" -g ${backup_job_extra_opts} ${backup_job_extra_dump_opts} | ${compress_cmd} | run_as_user tee "${TEMP_PATH}"/"${backup_job_filename}" > /dev/null
|
|
|
|
|
run_as_user ${play_fair} pg_dumpall -h "${backup_job_db_host}" -U "${backup_job_db_user}" -p "${backup_job_db_port}" -g ${backup_job_extra_opts} ${backup_job_extra_dump_opts} | ${compress_cmd} | run_as_user tee "${temporary_directory}"/"${backup_job_filename}" > /dev/null
|
|
|
|
|
exit_code=$?
|
|
|
|
|
if var_true "${DEBUG_BACKUP_PGSQL}" ; then debug off; fi
|
|
|
|
|
check_exit_code "${backup_job_filename}"
|
|
|
|
|
@@ -728,6 +738,7 @@ backup_pgsql() {
|
|
|
|
|
move_dbbackup
|
|
|
|
|
check_exit_code move "${backup_job_filename}"
|
|
|
|
|
post_dbbackup "globals"
|
|
|
|
|
cleanup_old_data
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if var_true "${DEBUG_BACKUP_PGSQL}" ; then debug on; fi
|
|
|
|
|
@@ -766,7 +777,7 @@ backup_pgsql() {
|
|
|
|
|
pre_dbbackup "${db}"
|
|
|
|
|
write_log notice "Dumping PostgresSQL database: '${db}' ${compression_string}"
|
|
|
|
|
if var_true "${DEBUG_BACKUP_PGSQL}" ; then debug on; fi
|
|
|
|
|
run_as_user ${play_fair} pg_dump -h "${backup_job_db_host}" -p "${backup_job_db_port}" -U "${backup_job_db_user}" $db ${backup_job_extra_opts} ${backup_job_extra_dump_opts} | ${compress_cmd} | run_as_user tee "${TEMP_PATH}"/"${backup_job_filename}" > /dev/null
|
|
|
|
|
run_as_user ${play_fair} pg_dump -h "${backup_job_db_host}" -p "${backup_job_db_port}" -U "${backup_job_db_user}" $db ${backup_job_extra_opts} ${backup_job_extra_dump_opts} | ${compress_cmd} | run_as_user tee "${temporary_directory}"/"${backup_job_filename}" > /dev/null
|
|
|
|
|
exit_code=$?
|
|
|
|
|
if var_true "${DEBUG_BACKUP_PGSQL}" ; then debug off; fi
|
|
|
|
|
check_exit_code backup "${backup_job_filename}"
|
|
|
|
|
@@ -776,6 +787,7 @@ backup_pgsql() {
|
|
|
|
|
move_dbbackup
|
|
|
|
|
check_exit_code move "${backup_job_filename}"
|
|
|
|
|
post_dbbackup "${db}"
|
|
|
|
|
cleanup_old_data
|
|
|
|
|
done
|
|
|
|
|
if var_true "${_postgres_backup_globals}" ; then backup_pgsql_globals; fi
|
|
|
|
|
else
|
|
|
|
|
@@ -795,7 +807,7 @@ backup_pgsql() {
|
|
|
|
|
for x_db_name in ${tmp_db_names} ; do
|
|
|
|
|
pgexclude_arg=$(echo ${pgexclude_arg} --exclude-database=${x_db_name})
|
|
|
|
|
done
|
|
|
|
|
run_as_user ${play_fair} pg_dumpall -h ${backup_job_db_host} -p ${backup_job_db_port} -U ${backup_job_db_user} ${pgexclude_arg} ${backup_job_extra_opts} ${backup_job_extra_dump_opts} | ${compress_cmd} | run_as_user tee "${TEMP_PATH}"/"${backup_job_filename}" > /dev/null
|
|
|
|
|
run_as_user ${play_fair} pg_dumpall -h ${backup_job_db_host} -p ${backup_job_db_port} -U ${backup_job_db_user} ${pgexclude_arg} ${backup_job_extra_opts} ${backup_job_extra_dump_opts} | ${compress_cmd} | run_as_user tee "${temporary_directory}"/"${backup_job_filename}" > /dev/null
|
|
|
|
|
exit_code=$?
|
|
|
|
|
if var_true "${DEBUG_BACKUP_PGSQL}" ; then debug off; fi
|
|
|
|
|
check_exit_code backup "${backup_job_filename}"
|
|
|
|
|
@@ -805,6 +817,7 @@ backup_pgsql() {
|
|
|
|
|
move_dbbackup
|
|
|
|
|
check_exit_code move "${backup_job_filename}"
|
|
|
|
|
post_dbbackup all
|
|
|
|
|
cleanup_old_data
|
|
|
|
|
if var_true "${_postgres_backup_globals}" ; then backup_pgsql_globals; fi
|
|
|
|
|
fi
|
|
|
|
|
}
|
|
|
|
|
@@ -815,7 +828,7 @@ backup_redis() {
|
|
|
|
|
backup_job_filename=redis_all_${backup_job_db_host,,}_${now}.rdb
|
|
|
|
|
backup_job_filename_base=redis_${backup_job_db_host,,}
|
|
|
|
|
if var_true "${DEBUG_BACKUP_REDIS}" ; then debug on; fi
|
|
|
|
|
echo bgsave | silent run_as_user ${play_fair} redis-cli -h ${backup_job_db_host} -p ${backup_job_db_port} ${REDIS_PASS_STR} --rdb ${TEMP_PATH}/${backup_job_filename} ${backup_job_extra_opts} ${backup_job_extra_dump_opts}
|
|
|
|
|
echo bgsave | silent run_as_user ${play_fair} redis-cli -h ${backup_job_db_host} -p ${backup_job_db_port} ${REDIS_PASS_STR} --rdb ${temporary_directory}/${backup_job_filename} ${backup_job_extra_opts} ${backup_job_extra_dump_opts}
|
|
|
|
|
sleep 10
|
|
|
|
|
try=5
|
|
|
|
|
while [ $try -gt 0 ] ; do
|
|
|
|
|
@@ -835,7 +848,7 @@ backup_redis() {
|
|
|
|
|
compression
|
|
|
|
|
pre_dbbackup all
|
|
|
|
|
if var_true "${DEBUG_BACKUP_REDIS}" ; then debug on; fi
|
|
|
|
|
run_as_user ${compress_cmd} "${TEMP_PATH}/${backup_job_filename_original}"
|
|
|
|
|
run_as_user ${compress_cmd} "${temporary_directory}/${backup_job_filename_original}"
|
|
|
|
|
if var_true "${DEBUG_BACKUP_REDIS}" ; then debug off; fi
|
|
|
|
|
timer backup finish
|
|
|
|
|
check_exit_code backup "${backup_job_filename}"
|
|
|
|
|
@@ -844,6 +857,7 @@ backup_redis() {
|
|
|
|
|
move_dbbackup
|
|
|
|
|
check_exit_code move "${backup_job_filename}"
|
|
|
|
|
post_dbbackup all
|
|
|
|
|
cleanup_old_data
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
backup_sqlite3() {
|
|
|
|
|
@@ -851,20 +865,20 @@ backup_sqlite3() {
|
|
|
|
|
db=$(basename "${backup_job_db_host}")
|
|
|
|
|
db="${db%.*}"
|
|
|
|
|
backup_job_filename=sqlite3_${db}_${now}.sqlite3
|
|
|
|
|
backup_job_filename_base=sqlite3_${db}.sqlite3
|
|
|
|
|
backup_job_filename_base=sqlite3_${db}
|
|
|
|
|
pre_dbbackup "${db}"
|
|
|
|
|
write_log notice "Dumping sqlite3 database: '${backup_job_db_host}' ${compression_string}"
|
|
|
|
|
if var_true "${DEBUG_BACKUP_SQLITE3}" ; then debug on; fi
|
|
|
|
|
silent ${play_fair} sqlite3 "${backup_job_db_host}" ".backup '${TEMP_PATH}/backup_${now}.sqlite3'"
|
|
|
|
|
silent ${play_fair} sqlite3 "${backup_job_db_host}" ".backup '${temporary_directory}/backup_${now}.sqlite3'"
|
|
|
|
|
exit_code=$?
|
|
|
|
|
check_exit_code backup "${backup_job_filename}"
|
|
|
|
|
if [ ! -f "${TEMP_PATH}"/backup_${now}.sqlite3 ] ; then
|
|
|
|
|
if [ ! -f "${temporary_directory}"/backup_${now}.sqlite3 ] ; then
|
|
|
|
|
print_error "SQLite3 backup failed! Exitting"
|
|
|
|
|
return 1
|
|
|
|
|
fi
|
|
|
|
|
compression
|
|
|
|
|
run_as_user ${play_fair} cat "${TEMP_PATH}"/backup_${now}.sqlite3 | ${dir_compress_cmd} | run_as_user tee "${TEMP_PATH}/${backup_job_filename}" > /dev/null
|
|
|
|
|
rm -rf "${TEMP_PATH}"/backup_${now}.sqlite3
|
|
|
|
|
run_as_user ${play_fair} cat "${temporary_directory}"/backup_${now}.sqlite3 | ${dir_compress_cmd} | run_as_user tee "${temporary_directory}/${backup_job_filename}" > /dev/null
|
|
|
|
|
rm -rf "${temporary_directory}"/backup_${now}.sqlite3
|
|
|
|
|
if var_true "${DEBUG_BACKUP_SQLITE3}" ; then debug off; fi
|
|
|
|
|
timer backup finish
|
|
|
|
|
file_encryption
|
|
|
|
|
@@ -872,6 +886,7 @@ backup_sqlite3() {
|
|
|
|
|
move_dbbackup
|
|
|
|
|
check_exit_code move "${backup_job_filename}"
|
|
|
|
|
post_dbbackup "${db}"
|
|
|
|
|
cleanup_old_data
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
check_availability() {
|
|
|
|
|
@@ -1030,8 +1045,12 @@ cleanup_old_data() {
|
|
|
|
|
write_log info "Cleaning up old backups on filesystem"
|
|
|
|
|
run_as_user mkdir -p "${backup_job_filesystem_path}"
|
|
|
|
|
find "${backup_job_filesystem_path}"/ -type f -mmin +"${backup_job_cleanup_time}" -iname "${backup_job_filename_base}*" -exec rm -f {} \;
|
|
|
|
|
write_log info "Syncing changes via blobxfer"
|
|
|
|
|
silent run_as_user blobxfer upload --mode file --remote-path ${backup_job_blobxfer_remote_path} --local-path ${backup_job_filesystem_path} --delete --delete-only
|
|
|
|
|
if [ -z "${backup_job_blobxfer_storage_account}" ] || [ -z "${backup_job_blobxfer_storage_account_key}" ]; then
|
|
|
|
|
write_log warn "Variable _BLOBXFER_STORAGE_ACCOUNT or _BLOBXFER_STORAGE_ACCOUNT_KEY is not set. Skipping blobxfer functions"
|
|
|
|
|
else
|
|
|
|
|
write_log info "Syncing changes via blobxfer"
|
|
|
|
|
silent run_as_user blobxfer upload --mode file --remote-path ${backup_job_blobxfer_remote_path} --storage-account ${backup_job_blobxfer_storage_account} --storage-account-key ${backup_job_blobxfer_storage_account_key} --local-path ${backup_job_filesystem_path} --delete --delete-only
|
|
|
|
|
fi
|
|
|
|
|
;;
|
|
|
|
|
"file" | "filesystem" )
|
|
|
|
|
write_log info "Cleaning up old backups on filesystem"
|
|
|
|
|
@@ -1136,8 +1155,9 @@ compression() {
|
|
|
|
|
create_archive() {
|
|
|
|
|
if var_true "${DEBUG_CREATE_ARCHIVE}" ; then debug on; fi
|
|
|
|
|
if [ "${exit_code}" = "0" ] ; then
|
|
|
|
|
write_log notice "Creating archive file of '${backup_job_filename_dir}' with tar ${compression_string}"
|
|
|
|
|
run_as_user tar cf - "${TEMP_PATH}"/"${backup_job_filename_dir}" | ${dir_compress_cmd} | run_as_user tee "${TEMP_PATH}"/"${backup_job_filename_dir}".tar"${extension}" > /dev/null
|
|
|
|
|
write_log notice "Creating archive file of '${backup_job_filename}' with tar ${compression_string}"
|
|
|
|
|
run_as_user tar cf - "${temporary_directory}"/"${backup_job_filename}" | ${dir_compress_cmd} | run_as_user tee "${temporary_directory}"/"${backup_job_filename}".tar"${extension}" > /dev/null
|
|
|
|
|
rm -rf "${temporary_directory}"/"${backup_job_filename}"
|
|
|
|
|
else
|
|
|
|
|
write_log error "Skipping creating archive file because backup did not complete successfully"
|
|
|
|
|
fi
|
|
|
|
|
@@ -1160,13 +1180,14 @@ create_schedulers() {
|
|
|
|
|
instance=$(printf "%02d" $instance)
|
|
|
|
|
cp -R /assets/dbbackup/template-dbbackup /etc/services.available/dbbackup-"${instance}"
|
|
|
|
|
sed -i "s|{{BACKUP_NUMBER}}|${instance}|g" /etc/services.available/dbbackup-"${instance}"/run
|
|
|
|
|
|
|
|
|
|
if [ "${MODE,,}" = "manual" ] ; then service_stop dbbackup-"${instance}" ; fi
|
|
|
|
|
cat <<EOF >> /usr/bin/backup"${instance}"-now
|
|
|
|
|
#!/bin/bash
|
|
|
|
|
source /assets/functions/00-container
|
|
|
|
|
PROCESS_NAME=db-backup${instance}
|
|
|
|
|
print_info "Starting Manual Backup for db-backup${instance}"
|
|
|
|
|
/var/run/s6/legacy-services/dbbackup-${instance}/run now
|
|
|
|
|
#/var/run/s6/legacy-services/dbbackup-${instance}/run now
|
|
|
|
|
/etc/services.available/dbbackup-${instance}/run now
|
|
|
|
|
|
|
|
|
|
EOF
|
|
|
|
|
chmod +x /usr/bin/backup"${instance}"-now
|
|
|
|
|
@@ -1176,11 +1197,11 @@ EOF
|
|
|
|
|
cat <<EOF > /usr/bin/backup-now
|
|
|
|
|
#!/bin/bash
|
|
|
|
|
|
|
|
|
|
/usr/bin/backup${instance}-now
|
|
|
|
|
/usr/bin/backup${instance}-now now
|
|
|
|
|
|
|
|
|
|
EOF
|
|
|
|
|
else
|
|
|
|
|
echo "/usr/bin/backup${instance}-now" >> /usr/bin/backup-now
|
|
|
|
|
echo "/usr/bin/backup${instance}-now now" >> /usr/bin/backup-now
|
|
|
|
|
fi
|
|
|
|
|
|
|
|
|
|
instance=$(echo "${instance} +1" | bc)
|
|
|
|
|
@@ -1258,7 +1279,7 @@ file_encryption() {
|
|
|
|
|
print_notice "Encrypting with GPG Passphrase"
|
|
|
|
|
encrypt_routines_start_time=$(date +'%s')
|
|
|
|
|
encrypt_tmp_dir=$(run_as_user mktemp -d)
|
|
|
|
|
echo "${backup_job_encrypt_passphrase}" | silent run_as_user ${play_fair} gpg --batch --home ${encrypt_tmp_dir} --yes --passphrase-fd 0 -c "${TEMP_PATH}"/"${backup_job_filename}"
|
|
|
|
|
echo "${backup_job_encrypt_passphrase}" | silent run_as_user ${play_fair} gpg --batch --home ${encrypt_tmp_dir} --yes --passphrase-fd 0 -c "${temporary_directory}"/"${backup_job_filename}"
|
|
|
|
|
rm -rf "${encrypt_tmp_dir}"
|
|
|
|
|
elif [ -z "${backup_job_encrypt_passphrase}" ] && [ -n "${backup_job_encrypt_public_key}" ] && [ -n "${backup_job_encrypt_private_key}" ]; then
|
|
|
|
|
if [ -f "${backup_job_encrypt_private_key}" ]; then
|
|
|
|
|
@@ -1270,13 +1291,13 @@ file_encryption() {
|
|
|
|
|
silent run_as_user gpg --home ${encrypt_tmp_dir} --batch --import "${encrypt_tmp_dir}"/private_key.asc
|
|
|
|
|
print_debug "[file_encryption] [key] Encrypting to Public Key"
|
|
|
|
|
cat "${backup_job_encrypt_public_key}" | run_as_user tee "${encrypt_tmp_dir}"/public_key.asc > /dev/null
|
|
|
|
|
silent run_as_user ${play_fair} gpg --batch --yes --home "${encrypt_tmp_dir}" --encrypt --recipient-file "${encrypt_tmp_dir}"/public_key.asc "${TEMP_PATH}"/"${backup_job_filename}"
|
|
|
|
|
silent run_as_user ${play_fair} gpg --batch --yes --home "${encrypt_tmp_dir}" --encrypt --recipient-file "${encrypt_tmp_dir}"/public_key.asc "${temporary_directory}"/"${backup_job_filename}"
|
|
|
|
|
rm -rf "${encrypt_tmp_dir}"
|
|
|
|
|
fi
|
|
|
|
|
fi
|
|
|
|
|
if [ -f "${TEMP_PATH}"/"${backup_job_filename}".gpg ]; then
|
|
|
|
|
if [ -f "${temporary_directory}"/"${backup_job_filename}".gpg ]; then
|
|
|
|
|
print_debug "[file_encryption] Deleting original file"
|
|
|
|
|
rm -rf "${TEMP_PATH:?}"/"${backup_job_filename:?}"
|
|
|
|
|
rm -rf "${temporary_directory:?}"/"${backup_job_filename:?}"
|
|
|
|
|
backup_job_filename="${backup_job_filename}.gpg"
|
|
|
|
|
|
|
|
|
|
encrypt_routines_finish_time=$(date +'%s')
|
|
|
|
|
@@ -1315,7 +1336,7 @@ generate_checksum() {
|
|
|
|
|
|
|
|
|
|
checksum_routines_start_time=$(date +'%s')
|
|
|
|
|
write_log notice "Generating ${checksum_extension^^} sum for '${backup_job_filename}'"
|
|
|
|
|
cd "${TEMP_PATH}"
|
|
|
|
|
cd "${temporary_directory}"
|
|
|
|
|
run_as_user ${checksum_command} "${backup_job_filename}" | run_as_user tee "${backup_job_filename}"."${checksum_extension}" > /dev/null
|
|
|
|
|
chmod ${backup_job_filesystem_permission} "${backup_job_filename}"."${checksum_extension}"
|
|
|
|
|
checksum_value=$(run_as_user cat "${backup_job_filename}"."${checksum_extension}" | awk '{print $1}')
|
|
|
|
|
@@ -1337,20 +1358,20 @@ EOF
|
|
|
|
|
notify() {
|
|
|
|
|
if var_true "${DEBUG_NOTIFY}" ; then debug on; fi
|
|
|
|
|
notification_custom() {
|
|
|
|
|
if [ -n "${NOTIFICATION_SCRIPT}" ] ; then
|
|
|
|
|
if var_true "${NOTIFICATION_SCRIPT_SKIP_X_VERIFY}" ; then
|
|
|
|
|
eval "${NOTIFICATION_SCRIPT}" "${1}" "${2}" "${3}" "${4}" "${5}"
|
|
|
|
|
if [ -n "${NOTIFICATION_CUSTOM_SCRIPT}" ] ; then
|
|
|
|
|
if var_true "${NOTIFICATION_CUSTOM_SCRIPT_SKIP_X_VERIFY}" ; then
|
|
|
|
|
eval "${NOTIFICATION_CUSTOM_SCRIPT}" "${1}" "${2}" "${3}" "${4}" "${5}"
|
|
|
|
|
else
|
|
|
|
|
if [ -x "${NOTIFICATION_SCRIPT}" ] ; then
|
|
|
|
|
write_log notice "Found NOTIFICATION_SCRIPT environment variable. Executing '${NOTIFICATION_SCRIPT}"
|
|
|
|
|
if [ -x "${NOTIFICATION_CUSTOM_SCRIPT}" ] ; then
|
|
|
|
|
write_log notice "Found NOTIFICATION_CUSTOM_SCRIPT environment variable. Executing '${NOTIFICATION_CUSTOM_SCRIPT}"
|
|
|
|
|
# script timestamp logfile errorcode subject body
|
|
|
|
|
eval "${NOTIFICATION_SCRIPT}" "${1}" "${2}" "${3}" "${4}" "${5}"
|
|
|
|
|
eval "${NOTIFICATION_CUSTOM_SCRIPT}" "${1}" "${2}" "${3}" "${4}" "${5}"
|
|
|
|
|
else
|
|
|
|
|
write_log error "Can't execute NOTIFICATION_SCRIPT environment variable '${NOTIFICATION_SCRIPT}' as its filesystem bit is not executible!"
|
|
|
|
|
write_log error "Can't execute NOTIFICATION_CUSTOM_SCRIPT environment variable '${NOTIFICATION_CUSTOM_SCRIPT}' as its filesystem bit is not executible!"
|
|
|
|
|
fi
|
|
|
|
|
fi
|
|
|
|
|
else
|
|
|
|
|
print_error "[notifications] No NOTIFICATION_SCRIPT variable set - Skipping sending Custom notifications"
|
|
|
|
|
print_error "[notifications] No NOTIFICATION_CUSTOM_SCRIPT variable set - Skipping sending Custom notifications"
|
|
|
|
|
fi
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@@ -1363,18 +1384,20 @@ notify() {
|
|
|
|
|
if [ -z "${SMTP_HOST}" ] ; then write_log error "[notifications] No SMTP_HOST variable set - Skipping sending Email notifications" ; skip_mail=true ; fi
|
|
|
|
|
if [ -z "${SMTP_PORT}" ] ; then write_log error "[notifications] No SMTP_PORT variable set - Skipping sending Email notifications" ; skip_mail=true ; fi
|
|
|
|
|
if var_nottrue "${skip_mail}" ; then
|
|
|
|
|
if ! grep -q ^from /etc/msmptrc ; then
|
|
|
|
|
echo "from ${MAIL_FROM}" >> /etc/msmtprc
|
|
|
|
|
fi
|
|
|
|
|
mail_recipients=$(echo "${MAIL_TO}" | tr "," "\n")
|
|
|
|
|
for mail_recipient in $mail_recipients ; do
|
|
|
|
|
cat <<EOF | s-nail -v \
|
|
|
|
|
-r "${MAIL_FROM}" \
|
|
|
|
|
-s "[db-backup] [${DOMAIN}] ${3}" \
|
|
|
|
|
-S smtp="${SMTP_HOST}":"${SMTP_PORT}" \
|
|
|
|
|
"${mail_recipient}"
|
|
|
|
|
cat <<EOF | msmtp -t "${mail_recipient}" -C /etc/msmtprc
|
|
|
|
|
To: ${mail_recipient}
|
|
|
|
|
Subject: [db-backup] ${4}
|
|
|
|
|
|
|
|
|
|
Time: ${1}
|
|
|
|
|
Log File: {2}
|
|
|
|
|
Error Code: ${3}
|
|
|
|
|
|
|
|
|
|
${4}
|
|
|
|
|
${5}
|
|
|
|
|
EOF
|
|
|
|
|
done
|
|
|
|
|
fi
|
|
|
|
|
@@ -1390,7 +1413,7 @@ EOF
|
|
|
|
|
if [ -z "${MATTERMOST_WEBHOOK_URL}" ] ; then write_log error "[notifications] No MATTERMOST_WEBHOOK_URL variable set - Skipping sending Mattermost notifications" ; skip_mattermost=true ; fi
|
|
|
|
|
if var_nottrue "${skip_mattermost}" ; then
|
|
|
|
|
emoji=":bomb:"
|
|
|
|
|
message="*[db-backup] ${3}*\n${4}\n*Timestamp:* ${1}\n*Logfile:* ${2}\n*Error Code: ${3}"
|
|
|
|
|
message="*[db-backup] ${4}*\n${5}\n*Timestamp:* ${1}\n*Logfile:* ${2}\n*Error Code: ${3}"
|
|
|
|
|
mattermost_recipients=$(echo "${MATTERMOST_RECIPIENT}" | tr "," "\n")
|
|
|
|
|
for mattermost_recipient in $mattermost_recipients ; do
|
|
|
|
|
payload="payload={\"channel\": \"${mattermost_recipient//\"/\\\"}\", \"username\": \"${MATTERMOST_USERNAME//\"/\\\"}\", \"text\": \"${message//\"/\\\"}\", \"icon_emoji\": \"${emoji}\"}"
|
|
|
|
|
@@ -1415,7 +1438,7 @@ EOF
|
|
|
|
|
for matrix_room in $matrix_rooms ; do
|
|
|
|
|
curl \
|
|
|
|
|
-XPOST \
|
|
|
|
|
-d "{\"msgtype\":\"m.text\", \"body\":\"*[db-backup] ${3}*\n${4}\n*Timestamp:* ${1}\n*Logfile:* ${2}\n*Error Code: ${3}*\"}" \
|
|
|
|
|
-d "{\"msgtype\":\"m.text\", \"body\":\"*[db-backup] ${4}*\n${5}\n*Timestamp:* ${1}\n*Logfile:* ${2}\n*Error Code: ${3}*\"}" \
|
|
|
|
|
"${MATRIX_HOST}/_matrix/client/r0/rooms/${matrix_room}/send/m.room.message?access_token=${MATRIX_ACCESS_TOKEN}"
|
|
|
|
|
done
|
|
|
|
|
fi
|
|
|
|
|
@@ -1431,7 +1454,7 @@ EOF
|
|
|
|
|
if [ -z "${ROCKETCHAT_WEBHOOK_URL}" ] ; then write_log error "[notifications] No ROCKETCHAT_WEBHOOK_URL variable set - Skipping sending Rocket.Chat notifications" ; skip_rocketchat=true ; fi
|
|
|
|
|
if var_nottrue "${skip_rocketchat}" ; then
|
|
|
|
|
emoji=":bomb:"
|
|
|
|
|
message="*[db-backup] ${3}*\n${4}\n*Timestamp:* ${1}\n*Logfile:* ${2}\n*Error Code: ${3}"
|
|
|
|
|
message="*[db-backup] ${4}*\n${5}\n*Timestamp:* ${1}\n*Logfile:* ${2}\n*Error Code: ${3}"
|
|
|
|
|
rocketchat_recipients=$(echo "${ROCKETCHAT_RECIPIENT}" | tr "," "\n")
|
|
|
|
|
for rocketchat_recipient in $rocketchat_recipients ; do
|
|
|
|
|
payload="payload={\"channel\": \"${rocketchat_recipient//\"/\\\"}\", \"username\": \"${ROCKETCHAT_USERNAME//\"/\\\"}\", \"text\": \"${message//\"/\\\"}\", \"icon_emoji\": \"${emoji}\"}"
|
|
|
|
|
@@ -1450,7 +1473,7 @@ EOF
|
|
|
|
|
# $4 body
|
|
|
|
|
|
|
|
|
|
if var_true "${ENABLE_NOTIFICATIONS}" ; then
|
|
|
|
|
notification_types=$(echo "${NOTIIFICATION_TYPE}" | tr "," "\n")
|
|
|
|
|
notification_types=$(echo "${NOTIFICATION_TYPE}" | tr "," "\n")
|
|
|
|
|
for notification_type in $notification_types ; do
|
|
|
|
|
case "${notification_type,,}" in
|
|
|
|
|
"custom" )
|
|
|
|
|
@@ -1485,8 +1508,8 @@ EOF
|
|
|
|
|
move_dbbackup() {
|
|
|
|
|
if var_true "${DEBUG_MOVE_DBBACKUP}" ; then debug on; fi
|
|
|
|
|
if [ "${exit_code}" = "0" ] ; then
|
|
|
|
|
dbbackup_size="$(run_as_user stat -c%s "${TEMP_PATH}"/"${backup_job_filename}")"
|
|
|
|
|
dbbackup_date="$(run_as_user date -r "${TEMP_PATH}"/"${backup_job_filename}" +'%s')"
|
|
|
|
|
dbbackup_size="$(run_as_user stat -c%s "${temporary_directory}"/"${backup_job_filename}")"
|
|
|
|
|
dbbackup_date="$(run_as_user date -r "${temporary_directory}"/"${backup_job_filename}" +'%s')"
|
|
|
|
|
|
|
|
|
|
case "${backup_job_size_value,,}" in
|
|
|
|
|
"b" | "bytes" )
|
|
|
|
|
@@ -1500,37 +1523,37 @@ move_dbbackup() {
|
|
|
|
|
;;
|
|
|
|
|
esac
|
|
|
|
|
if [ "${backup_job_size_value}" = "1" ] ; then
|
|
|
|
|
filesize=$(run_as_user stat -c%s "${TEMP_PATH}"/"${backup_job_filename}")
|
|
|
|
|
filesize=$(run_as_user stat -c%s "${temporary_directory}"/"${backup_job_filename}")
|
|
|
|
|
write_log notice "Backup of '${backup_job_filename}' created with the size of ${filesize} bytes"
|
|
|
|
|
else
|
|
|
|
|
filesize=$(run_as_user du -h "${TEMP_PATH}"/"${backup_job_filename}" | awk '{ print $1}')
|
|
|
|
|
filesize=$(run_as_user du -h "${temporary_directory}"/"${backup_job_filename}" | awk '{ print $1}')
|
|
|
|
|
write_log notice "Backup of '${backup_job_filename}' created with the size of ${filesize}"
|
|
|
|
|
fi
|
|
|
|
|
|
|
|
|
|
chmod "${backup_job_filesystem_permission}" "${TEMP_PATH}"/"${backup_job_filename}"
|
|
|
|
|
chmod "${backup_job_filesystem_permission}" "${temporary_directory}"/"${backup_job_filename}"
|
|
|
|
|
case "${backup_job_backup_location,,}" in
|
|
|
|
|
"file" | "filesystem" )
|
|
|
|
|
write_log debug "Moving backup to filesystem"
|
|
|
|
|
run_as_user mkdir -p "${backup_job_filesystem_path}"
|
|
|
|
|
if [ "${backup_job_checksum,,}" != "none" ] ; then run_as_user mv "${TEMP_PATH}"/*."${checksum_extension}" "${backup_job_filesystem_path}"/ ; fi
|
|
|
|
|
if [ "${backup_job_checksum,,}" != "none" ] ; then run_as_user mv "${temporary_directory}"/*."${checksum_extension}" "${backup_job_filesystem_path}"/ ; fi
|
|
|
|
|
if var_true "${DEBUG_MOVE_DBBACKUP}"; then
|
|
|
|
|
cat <<EOF
|
|
|
|
|
## BEGIN Before Moving file from TEMP_PATH $(TZ=${TIMEZONE} date)
|
|
|
|
|
## BEGIN Before Moving file from temporary_directory $(TZ=${TIMEZONE} date)
|
|
|
|
|
##
|
|
|
|
|
|
|
|
|
|
$(ls -l "${TEMP_PATH}"/*)
|
|
|
|
|
$(ls -l "${temporary_directory}"/*)
|
|
|
|
|
|
|
|
|
|
## END
|
|
|
|
|
EOF
|
|
|
|
|
fi
|
|
|
|
|
run_as_user mv "${TEMP_PATH}"/"${backup_job_filename}" "${backup_job_filesystem_path}"/"${backup_job_filename}"
|
|
|
|
|
run_as_user mv "${temporary_directory}"/"${backup_job_filename}" "${backup_job_filesystem_path}"/"${backup_job_filename}"
|
|
|
|
|
move_exit_code=$?
|
|
|
|
|
if var_true "${DEBUG_MOVE_DBBACKUP}"; then
|
|
|
|
|
cat <<EOF
|
|
|
|
|
## BEGIN After Moving file from TEMP_PATH $(TZ=${TIMEZONE} date)
|
|
|
|
|
## BEGIN After Moving file from temporary_directory $(TZ=${TIMEZONE} date)
|
|
|
|
|
##
|
|
|
|
|
|
|
|
|
|
$(ls -l "${TEMP_PATH}"/*)
|
|
|
|
|
$(ls -l "${temporary_directory}"/*)
|
|
|
|
|
|
|
|
|
|
## END
|
|
|
|
|
|
|
|
|
|
@@ -1572,43 +1595,49 @@ EOF
|
|
|
|
|
|
|
|
|
|
[[ ( -n "${backup_job_s3_host}" ) ]] && PARAM_AWS_ENDPOINT_URL=" --endpoint-url ${backup_job_s3_protocol}://${backup_job_s3_host}"
|
|
|
|
|
|
|
|
|
|
silent aws ${PARAM_AWS_ENDPOINT_URL} s3 cp ${TEMP_PATH}/${backup_job_filename} s3://${backup_job_s3_bucket}/${backup_job_s3_path}/${backup_job_filename} ${s3_ssl} ${s3_ca_cert} ${backup_job_s3_extra_opts}
|
|
|
|
|
silent aws ${PARAM_AWS_ENDPOINT_URL} s3 cp ${temporary_directory}/${backup_job_filename} s3://${backup_job_s3_bucket}/${backup_job_s3_path}/${backup_job_filename} ${s3_ssl} ${s3_ca_cert} ${backup_job_s3_extra_opts}
|
|
|
|
|
move_exit_code=$?
|
|
|
|
|
if [ "${backup_job_checksum}" != "none" ] ; then
|
|
|
|
|
silent run_as_user ${play_fair} aws ${PARAM_AWS_ENDPOINT_URL} s3 cp ${TEMP_PATH}/*.${checksum_extension} s3://${backup_job_s3_bucket}/${backup_job_s3_path}/ ${s3_ssl} ${s3_ca_cert} ${backup_job_s3_extra_opts}
|
|
|
|
|
run_as_user rm -rf "${TEMP_PATH}"/"${backup_job_filename}"."${checksum_extension}"
|
|
|
|
|
silent run_as_user ${play_fair} aws ${PARAM_AWS_ENDPOINT_URL} s3 cp ${temporary_directory}/*.${checksum_extension} s3://${backup_job_s3_bucket}/${backup_job_s3_path}/ ${s3_ssl} ${s3_ca_cert} ${backup_job_s3_extra_opts}
|
|
|
|
|
run_as_user rm -rf "${temporary_directory}"/"${backup_job_filename}"."${checksum_extension}"
|
|
|
|
|
fi
|
|
|
|
|
|
|
|
|
|
run_as_user rm -rf "${TEMP_PATH}"/"${backup_job_filename}"
|
|
|
|
|
run_as_user rm -rf "${temporary_directory}"/"${backup_job_filename}"
|
|
|
|
|
;;
|
|
|
|
|
"blobxfer" )
|
|
|
|
|
write_log info "Synchronize local storage from S3 Bucket with blobxfer"
|
|
|
|
|
${play_fair} blobxfer download --mode file --remote-path ${backup_job_blobxfer_remote_path} --local-path ${backup_job_filesystem_path} --delete
|
|
|
|
|
if [ -z "${backup_job_blobxfer_storage_account}" ] || [ -z "${backup_job_blobxfer_storage_account_key}" ]; then
|
|
|
|
|
write_log warn "Variable _BLOBXFER_STORAGE_ACCOUNT or _BLOBXFER_STORAGE_ACCOUNT_KEY is not set. Skipping blobxfer functions"
|
|
|
|
|
else
|
|
|
|
|
write_log info "Synchronize local storage from S3 Bucket with blobxfer"
|
|
|
|
|
${play_fair} blobxfer download --mode file --remote-path ${backup_job_blobxfer_remote_path} --storage-account ${backup_job_blobxfer_storage_account} --storage-account-key ${backup_job_blobxfer_storage_account_key} --local-path ${backup_job_filesystem_path} --delete
|
|
|
|
|
|
|
|
|
|
write_log info "Moving backup to external storage with blobxfer"
|
|
|
|
|
mkdir -p "${backup_job_filesystem_path}"
|
|
|
|
|
if [ "${backup_job_checksum}" != "none" ] ; then run_as_user mv "${TEMP_PATH}"/*."${checksum_extension}" "${backup_job_filesystem_path}"/; fi
|
|
|
|
|
write_log info "Moving backup to external storage with blobxfer"
|
|
|
|
|
mkdir -p "${backup_job_filesystem_path}"
|
|
|
|
|
if [ "${backup_job_checksum}" != "none" ] ; then run_as_user mv "${temporary_directory}"/*."${checksum_extension}" "${backup_job_filesystem_path}"/; fi
|
|
|
|
|
|
|
|
|
|
run_as_user mv "${TEMP_PATH}"/"${backup_job_filename}" "${backup_job_filesystem_path}"/"${backup_job_filename}"
|
|
|
|
|
run_as_user mv "${temporary_directory}"/"${backup_job_filename}" "${backup_job_filesystem_path}"/"${backup_job_filename}"
|
|
|
|
|
|
|
|
|
|
silent run_as_user ${play_fair} blobxfer upload --mode file --remote-path ${backup_job_blobxfer_remote_path} --local-path ${backup_job_filesystem_path}
|
|
|
|
|
move_exit_code=$?
|
|
|
|
|
silent run_as_user ${play_fair} blobxfer upload --mode file --remote-path ${backup_job_blobxfer_remote_path} --storage-account ${backup_job_blobxfer_storage_account} --storage-account-key ${backup_job_blobxfer_storage_account_key} --local-path ${backup_job_filesystem_path}
|
|
|
|
|
move_exit_code=$?
|
|
|
|
|
|
|
|
|
|
if [ "${backup_job_checksum}" != "none" ] ; then run_as_user rm -rf "${TEMP_PATH}"/"${backup_job_filename}"."${checksum_extension}" ; fi
|
|
|
|
|
run_as_user rm -rf "${TEMP_PATH}"/"${backup_job_filename}"
|
|
|
|
|
if [ "${backup_job_checksum}" != "none" ] ; then run_as_user rm -rf "${temporary_directory}"/"${backup_job_filename}"."${checksum_extension}" ; fi
|
|
|
|
|
run_as_user rm -rf "${temporary_directory}"/"${backup_job_filename}"
|
|
|
|
|
fi
|
|
|
|
|
;;
|
|
|
|
|
esac
|
|
|
|
|
else
|
|
|
|
|
write_log error "Skipping moving DB Backup to final location because backup did not complete successfully"
|
|
|
|
|
fi
|
|
|
|
|
|
|
|
|
|
run_as_user rm -rf "${TEMP_PATH}"/"${backup_job_filename}"
|
|
|
|
|
run_as_user rm -rf "${temporary_directory}"/"${backup_job_filename}"
|
|
|
|
|
if var_true "${DEBUG_MOVE_DBBACKUP}" ; then debug off; fi
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
prepare_dbbackup() {
|
|
|
|
|
timer backup start
|
|
|
|
|
now=$(run_as_user date +"%Y%m%d-%H%M%S")
|
|
|
|
|
temporary_directory=$(mktemp -d -p "${TEMP_PATH}" -t ${backup_instance_number}_dbbackup.XXXXXX)
|
|
|
|
|
chown -R "${DBBACKUP_USER}":"${DBBACKUP_GROUP}" "${temporary_directory}"
|
|
|
|
|
backup_job_filename_base=${dbtype}_${backup_job_db_name,,}_${backup_job_db_host,,}
|
|
|
|
|
backup_job_filename=${dbtype}_${backup_job_db_name,,}_${backup_job_db_host,,}_${now}.sql
|
|
|
|
|
}
|
|
|
|
|
@@ -1631,7 +1660,7 @@ pre_dbbackup() {
|
|
|
|
|
|
|
|
|
|
### Pre Backup Custom Script Support
|
|
|
|
|
if [ -d "/assets/custom-scripts/pre" ] && dir_notempty "/assets/custom-scripts/pre" ; then
|
|
|
|
|
write_log warning "Found Custom Post Scripts in /assets/custom-scripts/pre - Automatically moving them to '${backup_job_script_location_pre}'"
|
|
|
|
|
write_log warn "Found Custom Post Scripts in /assets/custom-scripts/pre - Automatically moving them to '${backup_job_script_location_pre}'"
|
|
|
|
|
mkdir -p "${backup_job_script_location_pre}"
|
|
|
|
|
silent cp -aR /assets/custom-scripts/pre/* "${backup_job_script_location_pre}"
|
|
|
|
|
fi
|
|
|
|
|
@@ -1700,7 +1729,7 @@ EOZP
|
|
|
|
|
|
|
|
|
|
### Post Backup Custom Script Support
|
|
|
|
|
if [ -d "/assets/custom-scripts/" ] && dir_notempty "/assets/custom-scripts" ; then
|
|
|
|
|
write_log warning "Found Custom Post Scripts in /assets/custom-scripts/ - Automatically moving them to '${backup_job_script_location_post}'"
|
|
|
|
|
write_log warn "Found Custom Post Scripts in /assets/custom-scripts/ - Automatically moving them to '${backup_job_script_location_post}'"
|
|
|
|
|
mkdir -p "${backup_job_script_location_post}"
|
|
|
|
|
cp -aR /assets/custom-scripts/* "${backup_job_script_location_post}"
|
|
|
|
|
fi
|
|
|
|
|
@@ -1723,6 +1752,8 @@ EOZP
|
|
|
|
|
|
|
|
|
|
write_log notice "DB Backup for '${1}' time taken: $(echo ${dbbackup_total_time} | awk '{printf "Hours: %d Minutes: %02d Seconds: %02d", $1/3600, ($1/60)%60, $1%60}')"
|
|
|
|
|
if var_true "${DEBUG_POST_DBBACKUP}" ; then debug on; fi
|
|
|
|
|
cd "${TEMP_PATH}"
|
|
|
|
|
rm -rf "${temporary_directory}"
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
process_limiter() {
|
|
|
|
|
@@ -1841,7 +1872,7 @@ timer() {
|
|
|
|
|
if [ "${expression_step}" != "${expression}" ]; then
|
|
|
|
|
for step in ${validate_temp}; do
|
|
|
|
|
if [ $(( ( step - expression_start ) % expression_step )) -eq 0 ]; then
|
|
|
|
|
validate_all="$validate_all ${step}"
|
|
|
|
|
validate_all="${validate_all} ${step}"
|
|
|
|
|
fi
|
|
|
|
|
done
|
|
|
|
|
else
|
|
|
|
|
@@ -1849,15 +1880,16 @@ timer() {
|
|
|
|
|
fi
|
|
|
|
|
done
|
|
|
|
|
|
|
|
|
|
validate_all=$(echo "${validate_all}" | tr ' ' '\n' | sort -n -u | tr '\n' ' ')
|
|
|
|
|
validate_all=$(echo "${validate_all}" | tr ' ' '\n' | sort -g -u | tr '\n' ' ')
|
|
|
|
|
for entry in $validate_all; do
|
|
|
|
|
if [ "${entry}" -ge "${3}" ]; then
|
|
|
|
|
if [ ${entry} -ge ${3} ]; then
|
|
|
|
|
echo "${entry}"
|
|
|
|
|
return 0
|
|
|
|
|
fi
|
|
|
|
|
done
|
|
|
|
|
|
|
|
|
|
echo "${validate_all%% *}"
|
|
|
|
|
echo "${validate_all// /}"
|
|
|
|
|
#echo "${validate_all%% *}"
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
local cron_compare="${3}"
|
|
|
|
|
@@ -1865,18 +1897,21 @@ timer() {
|
|
|
|
|
local cron_compare_difference=$(( cron_compare - ${4} ))
|
|
|
|
|
|
|
|
|
|
if [ "${cron_compare_difference}" -lt 60 ]; then
|
|
|
|
|
cron_compare=$((${cron_compare} + $(( 60 - cron_compare_difference )) ))
|
|
|
|
|
cron_compare=$((cron_compare + $(( 60 - cron_compare_difference )) ))
|
|
|
|
|
fi
|
|
|
|
|
|
|
|
|
|
local cron_current_seconds="$(date --date=@"${cron_compare_seconds}" +"%-S")"
|
|
|
|
|
if [ "${cron_current_seconds}" -ne 0 ]; then
|
|
|
|
|
cron_compare_seconds=$(( cron_compare_seconds - cron_current_seconds ))
|
|
|
|
|
cron_compare=$(( cron_compare_seconds - cron_current_seconds ))
|
|
|
|
|
fi
|
|
|
|
|
|
|
|
|
|
local cron_minute="$(echo -n "${2}" | awk '{print $1}')"
|
|
|
|
|
local cron_hour="$(echo -n "${2}" | awk '{print $2}')"
|
|
|
|
|
local cron_day_of_month="$(echo -n "${2}" | awk '{print $3}')"
|
|
|
|
|
local cron_month="$(echo -n "${2}" | awk '{print $4}')"Generating
|
|
|
|
|
local cron_month="$(echo -n "${2}" | awk '{print $4}')"
|
|
|
|
|
local cron_day_of_week="$(echo -n "${2}" | awk '{print $5}')"
|
|
|
|
|
|
|
|
|
|
local cron_next_minute="$(date --date=@"${cron_compare}" +"%-M")"
|
|
|
|
|
local cron_next_hour="$(date --date=@"${cron_compare}" +"%-H")"
|
|
|
|
|
local cron_next_day_of_month="$(date --date=@"${cron_compare}" +"%-d")"
|
|
|
|
|
local cron_next_month="$(date --date=@"${cron_compare}" +"%-m")"
|
|
|
|
|
@@ -1885,8 +1920,10 @@ timer() {
|
|
|
|
|
local cron_next_year="$(date --date=@"${cron_compare}" +"%-Y")"
|
|
|
|
|
|
|
|
|
|
local cron_next=
|
|
|
|
|
local cron_parsed=1
|
|
|
|
|
|
|
|
|
|
while [ "$cron_parsed" != "0" ]; do
|
|
|
|
|
while [ "${cron_parsed}" != "0" ]; do
|
|
|
|
|
print_debug "[timer] [cron] Parse Minute"
|
|
|
|
|
cron_next=$(parse_expression "${cron_minute}" 59 "${cron_next_minute}")
|
|
|
|
|
if [ "${cron_next}" != "${cron_next_minute}" ]; then
|
|
|
|
|
if [ "${cron_next_minute}" -gt "${cron_next}" ]; then
|
|
|
|
|
@@ -1896,20 +1933,23 @@ timer() {
|
|
|
|
|
cron_next_minute="${cron_next}"
|
|
|
|
|
fi
|
|
|
|
|
|
|
|
|
|
print_debug "[timer] [cron] Parse Hour"
|
|
|
|
|
cron_next=$(parse_expression "${cron_hour}" 23 "${cron_next_hour}")
|
|
|
|
|
if [ "${cron_next}" != "${cron_next_hour}" ]; then
|
|
|
|
|
if [ "${cron_next_hour}" -gt "${cron_next}" ]; then
|
|
|
|
|
cron_next_day_of_month=$(( cron_next_day_of_month + 1 ))
|
|
|
|
|
fi
|
|
|
|
|
|
|
|
|
|
cron_next_hour="${cron_next}"
|
|
|
|
|
#cron_next_minute=0
|
|
|
|
|
cron_next_minute=0
|
|
|
|
|
fi
|
|
|
|
|
|
|
|
|
|
print_debug "[timer] [cron] Parse Day of Week"
|
|
|
|
|
cron_next=$(parse_expression "${cron_day_of_week}" 6 "${cron_next_day_of_week}")
|
|
|
|
|
if [ "${cron_next}" != "${cron_next_day_of_week}" ]; then
|
|
|
|
|
day_of_week_difference=$(( ${cron_next} - ${cron_next_day_of_week} ))
|
|
|
|
|
day_of_week_difference=$(( cron_next - cron_next_day_of_week ))
|
|
|
|
|
|
|
|
|
|
if [ "${day_of_week_difference}" -lt "0" ]; then
|
|
|
|
|
if [ "${day_of_week_difference}" -lt 0 ]; then
|
|
|
|
|
day_of_week_difference=$(( day_of_week_difference + 7 ))
|
|
|
|
|
fi
|
|
|
|
|
|
|
|
|
|
@@ -1918,6 +1958,7 @@ timer() {
|
|
|
|
|
cron_next_minute=0
|
|
|
|
|
fi
|
|
|
|
|
|
|
|
|
|
print_debug "[timer] [cron] Parse day of month"
|
|
|
|
|
case "${cron_next_month}" in
|
|
|
|
|
1|3|5|7|8|10|12)
|
|
|
|
|
last_day_of_month="31"
|
|
|
|
|
@@ -1957,6 +1998,7 @@ timer() {
|
|
|
|
|
cron_next_day_of_month=$cron_next
|
|
|
|
|
fi
|
|
|
|
|
|
|
|
|
|
print_debug "[timer] [cron] Parse Next Month"
|
|
|
|
|
cron_next=$(parse_expression "${cron_month}" 12 "${cron_next_month}")
|
|
|
|
|
if [ "${cron_next}" != "${cron_next_month}" ]; then
|
|
|
|
|
if [ "${cron_next}" -gt "12" ]; then
|
|
|
|
|
@@ -1973,7 +2015,6 @@ timer() {
|
|
|
|
|
fi
|
|
|
|
|
cron_parsed=0
|
|
|
|
|
done
|
|
|
|
|
|
|
|
|
|
local cron_future=$(date --date="${cron_next_year}-$(printf "%02d" ${cron_next_month})-$(printf "%02d" ${cron_next_day_of_month})T$(printf "%02d" ${cron_next_hour}):$(printf "%02d" ${cron_next_minute}):00" "+%s")
|
|
|
|
|
local cron_future_difference=$(( cron_future - cron_compare_seconds ))
|
|
|
|
|
time_cron=true
|
|
|
|
|
@@ -2068,4 +2109,4 @@ write_log() {
|
|
|
|
|
print_${_arg_log_level} "${_arg_log_message}"
|
|
|
|
|
output_on
|
|
|
|
|
if var_true "${DEBUG_WRITE_LOG}" ; then debug off; fi
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|