|
| 1 | +{{- if and .Values.backup.enabled .Values.backup.files.enabled }} |
| 2 | +apiVersion: batch/v1 |
| 3 | +kind: CronJob |
| 4 | +metadata: |
| 5 | + name: {{ include "huly.fullname" . }}-backup-files |
| 6 | + labels: |
| 7 | + {{- include "huly.labels" . | nindent 4 }} |
| 8 | + app: backup-files |
| 9 | +spec: |
| 10 | + schedule: {{ .Values.backup.files.schedule | default .Values.backup.schedule | quote }} |
| 11 | + concurrencyPolicy: Forbid |
| 12 | + successfulJobsHistoryLimit: 3 |
| 13 | + failedJobsHistoryLimit: 3 |
| 14 | + jobTemplate: |
| 15 | + spec: |
| 16 | + backoffLimit: 2 |
| 17 | + template: |
| 18 | + metadata: |
| 19 | + labels: |
| 20 | + {{- include "huly.labels" . | nindent 12 }} |
| 21 | + app: backup-files |
| 22 | + spec: |
| 23 | + {{- include "huly.scheduling" . | nindent 10 }} |
| 24 | + restartPolicy: OnFailure |
| 25 | + containers: |
| 26 | + - name: rclone-sync |
| 27 | + image: {{ .Values.backup.rcloneImage }} |
| 28 | + env: |
| 29 | + {{- include "huly.envSecret" (dict "name" "STORAGE_CONFIG" "key" "STORAGE_CONFIG" "root" .) | nindent 16 }} |
| 30 | + {{- include "huly.envBackupSecret" (dict "name" "BACKUP_S3_ENDPOINT" "key" "BACKUP_S3_ENDPOINT" "root" .) | nindent 16 }} |
| 31 | + {{- include "huly.envBackupSecret" (dict "name" "BACKUP_S3_REGION" "key" "BACKUP_S3_REGION" "root" .) | nindent 16 }} |
| 32 | + {{- include "huly.envBackupSecret" (dict "name" "BACKUP_S3_BUCKET" "key" "BACKUP_S3_BUCKET" "root" .) | nindent 16 }} |
| 33 | + {{- include "huly.envBackupSecret" (dict "name" "BACKUP_S3_PATH_PREFIX" "key" "BACKUP_S3_PATH_PREFIX" "root" .) | nindent 16 }} |
| 34 | + {{- include "huly.envBackupSecret" (dict "name" "BACKUP_S3_ACCESS_KEY" "key" "BACKUP_S3_ACCESS_KEY" "root" .) | nindent 16 }} |
| 35 | + {{- include "huly.envBackupSecret" (dict "name" "BACKUP_S3_SECRET_KEY" "key" "BACKUP_S3_SECRET_KEY" "root" .) | nindent 16 }} |
| 36 | + command: |
| 37 | + - sh |
| 38 | + - -c |
| 39 | + - | |
| 40 | + set -e |
| 41 | +
|
| 42 | + # Parse STORAGE_CONFIG to extract source S3 details. |
| 43 | + # Format: s3|https://endpoint?accessKey=X&secretKey=Y®ion=Z&rootBucket=B |
| 44 | + # or: minio|minio?accessKey=X&secretKey=Y |
| 45 | +
|
| 46 | + PROTO=$(echo "$STORAGE_CONFIG" | cut -d'|' -f1) |
| 47 | + REST=$(echo "$STORAGE_CONFIG" | cut -d'|' -f2) |
| 48 | +
|
| 49 | + if [ "$PROTO" = "minio" ]; then |
| 50 | + # MinIO: host is "minio", creds in query string |
| 51 | + SRC_ENDPOINT="http://minio:9000" |
| 52 | + SRC_PROVIDER="Minio" |
| 53 | + else |
| 54 | + # External S3: endpoint is the URL before '?' |
| 55 | + SRC_ENDPOINT=$(echo "$REST" | cut -d'?' -f1) |
| 56 | + SRC_PROVIDER="Other" |
| 57 | + fi |
| 58 | +
|
| 59 | + PARAMS=$(echo "$REST" | cut -d'?' -f2) |
| 60 | + SRC_ACCESS_KEY=$(echo "$PARAMS" | tr '&' '\n' | grep '^accessKey=' | cut -d= -f2) |
| 61 | + SRC_SECRET_KEY=$(echo "$PARAMS" | tr '&' '\n' | grep '^secretKey=' | cut -d= -f2) |
| 62 | + SRC_REGION=$(echo "$PARAMS" | tr '&' '\n' | grep '^region=' | cut -d= -f2) |
| 63 | + SRC_ROOT_BUCKET=$(echo "$PARAMS" | tr '&' '\n' | grep '^rootBucket=' | cut -d= -f2) |
| 64 | + SRC_BUCKET_PREFIX=$(echo "$PARAMS" | tr '&' '\n' | grep '^bucketPrefix=' | cut -d= -f2) |
| 65 | +
|
| 66 | + # Configure source remote |
| 67 | + rclone config create source s3 \ |
| 68 | + provider="$SRC_PROVIDER" \ |
| 69 | + env_auth=false \ |
| 70 | + access_key_id="$SRC_ACCESS_KEY" \ |
| 71 | + secret_access_key="$SRC_SECRET_KEY" \ |
| 72 | + endpoint="$SRC_ENDPOINT" \ |
| 73 | + region="${SRC_REGION:-us-east-1}" \ |
| 74 | + --non-interactive |
| 75 | +
|
| 76 | + # Configure backup remote |
| 77 | + rclone config create backup s3 \ |
| 78 | + provider=Other \ |
| 79 | + env_auth=false \ |
| 80 | + access_key_id="$BACKUP_S3_ACCESS_KEY" \ |
| 81 | + secret_access_key="$BACKUP_S3_SECRET_KEY" \ |
| 82 | + endpoint="$BACKUP_S3_ENDPOINT" \ |
| 83 | + region="$BACKUP_S3_REGION" \ |
| 84 | + --non-interactive |
| 85 | +
|
| 86 | + # Determine source path |
| 87 | + if [ -n "$SRC_ROOT_BUCKET" ]; then |
| 88 | + SRC_PATH="source:${SRC_ROOT_BUCKET}" |
| 89 | + elif [ -n "$SRC_BUCKET_PREFIX" ]; then |
| 90 | + echo "Warning: bucketPrefix mode — syncing all buckets with prefix '${SRC_BUCKET_PREFIX}'" |
| 91 | + SRC_PATH="source:${SRC_BUCKET_PREFIX}" |
| 92 | + else |
| 93 | + echo "Error: cannot determine source bucket from STORAGE_CONFIG" |
| 94 | + exit 1 |
| 95 | + fi |
| 96 | +
|
| 97 | + DEST_PATH="backup:${BACKUP_S3_BUCKET}/${BACKUP_S3_PATH_PREFIX}/files/" |
| 98 | +
|
| 99 | + echo "Syncing files from ${SRC_PATH} to ${DEST_PATH}..." |
| 100 | + rclone sync "$SRC_PATH" "$DEST_PATH" \ |
| 101 | + --transfers 8 \ |
| 102 | + --checkers 16 \ |
| 103 | + --fast-list \ |
| 104 | + -v |
| 105 | +
|
| 106 | + echo "File sync complete." |
| 107 | +{{- end }} |
0 commit comments