Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

nodeset support and path-style s3 endpoint #2974

Open
wants to merge 2 commits into
base: master
Choose a base branch
from
Open

nodeset support and path-style s3 endpoint #2974

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
839b0ac
nodeset support and path-style s3 endpoint
michaelcourcy Jul 5, 2024
6211e65
Adapt to unique phase name constraint
michaelcourcy Jul 7, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
195 changes: 107 additions & 88 deletions examples/elasticsearch-incremental/elasticsearch-incremental-blueprint.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,23 +7,36 @@ actions:
outputArtifacts:
s3Snap:
keyValue:
repoPath: '{{ .Phases.setupNodeKeyStore.Output.repoPath }}'
snapshotName: '{{ .Phases.setupNodeKeyStore.Output.snapshotName }}'
esClusterName: '{{ .Phases.setupNodeKeyStore.Output.esClusterName }}'
repoPath: '{{ .Phases.setupNodeKeyStoreBackup.Output.repoPath }}'
snapshotName: '{{ .Phases.setupNodeKeyStoreBackup.Output.snapshotName }}'
esClusterName: '{{ .Phases.setupNodeKeyStoreBackup.Output.esClusterName }}'
esClusterNamespace: '{{ .Object.metadata.namespace }}'
phases:
phases:
- func: Wait
name: waitElasticGreenBackup
args:
timeout: 360s
conditions:
anyOf:
- condition: '{{ if or (eq "{ $.status.health }" "green") (eq "{ $.status.health }" "yellow")}}true{{ else }}false{{ end }}'
objectReference:
apiVersion: v1
group: elasticsearch.k8s.elastic.co
resource: elasticsearches
name: "{{ .Object.metadata.name }}"
namespace: "{{ .Object.metadata.namespace}}"
- func: KubeTask
name: setupNodeKeyStore
name: setupNodeKeyStoreBackup
objects:
elasticSecret:
kind: Secret
name: '{{ .Object.metadata.name }}-es-elastic-user'
namespace: '{{ .Object.metadata.namespace }}'
args:
image: ghcr.io/kanisterio/kanister-kubectl-1.18:0.81.0
image: ghcr.io/kanisterio/kanister-kubectl-1.18:0.109.0
command:
- bash
- +x
- -x
- -o
- errexit
- -o
Expand Down Expand Up @@ -54,48 +67,50 @@ actions:
AWS_SECRET_KEY="{{ .Profile.Credential.Secret.Data.aws_secret_access_key | toString }}"
AWS_ACCESS_KEY="{{ .Profile.Credential.Secret.Data.aws_access_key_id | toString }}"
{{- end }}
# No Support for more than one node set for the moment
NODE_SET_COUNT={{ len .Object.spec.nodeSets }}
if [[ $NODE_SET_COUNT -gt 1 ]]
then
echo "error, no Support for more than one node set for the moment, exiting"
exit 3
fi
NODE_SET_0_COUNT={{ (index .Object.spec.nodeSets 0).count }}
NODE_SET_0_COUNT=$((NODE_SET_0_COUNT-1))
NODE_SET_0_NAME={{ (index .Object.spec.nodeSets 0).name }}
for i in $(seq 0 $NODE_SET_0_COUNT)
do
pod="{{ .Object.metadata.name }}-es-$NODE_SET_0_NAME-$i"
echo "updating elasticsearch-keystore of $pod"
kubectl exec -it -n {{ .Object.metadata.namespace }} $pod -c elasticsearch -- bash -c "echo ${AWS_ACCESS_KEY} | /usr/share/elasticsearch/bin/elasticsearch-keystore add --stdin -f s3.client.default.access_key"
kubectl exec -it -n {{ .Object.metadata.namespace }} $pod -c elasticsearch -- bash -c "echo ${AWS_SECRET_KEY} | /usr/share/elasticsearch/bin/elasticsearch-keystore add --stdin -f s3.client.default.secret_key"
done

NS_NAME={{ .Object.metadata.namespace }}
ES_CLUSTER_NAME={{ .Object.metadata.name }}
{{- range $index, $nodeSet := .Object.spec.nodeSets }}
NODE_SET_COUNT={{ $nodeSet.count }}
NODE_SET_COUNT=$((NODE_SET_COUNT-1))
NODE_SET_NAME={{ $nodeSet.name }}
for i in $(seq 0 $NODE_SET_COUNT)
do
pod="$ES_CLUSTER_NAME-es-$NODE_SET_NAME-$i"
echo "updating elasticsearch-keystore of $pod"
kubectl exec -it -n $NS_NAME $pod -c elasticsearch -- bash -c "echo ${AWS_ACCESS_KEY} | /usr/share/elasticsearch/bin/elasticsearch-keystore add --stdin -f s3.client.default.access_key"
kubectl exec -it -n $NS_NAME $pod -c elasticsearch -- bash -c "echo ${AWS_SECRET_KEY} | /usr/share/elasticsearch/bin/elasticsearch-keystore add --stdin -f s3.client.default.secret_key"
done
{{- end }}
- func: KubeTask
name: snapshotElastic
args:
namespace: "{{ .Object.metadata.namespace }}"
image: ghcr.io/kanisterio/kanister-kubectl-1.18:0.81.0
image: ghcr.io/kanisterio/kanister-kubectl-1.18:0.109.0
command:
- bash
- +x
- -x
- -o
- errexit
- -o
- pipefail
- -c
- |
ES_URL="https://{{ .Object.metadata.name }}-es-http:9200"
PASSWORD="{{ index .Phases.setupNodeKeyStore.Secrets.elasticSecret.Data "elastic" | toString }}"
PASSWORD="{{ index .Phases.setupNodeKeyStoreBackup.Secrets.elasticSecret.Data "elastic" | toString }}"
REGION="{{ .Profile.Location.Region }}"
BUCKET="{{ .Profile.Location.Bucket }}"
ENDPOINT="{{ .Profile.Location.Endpoint }}"
if [[ -z $ENDPOINT ]]
then
ENDPOINT="s3.amazonaws.com"
path_style_access="false"
else
# when using non amazon s3 endpoint, we need to use path style access
path_style_access="true"
fi
REPO_PATH="{{ .Phases.setupNodeKeyStore.Output.repoPath }}"
SNAPSHOT_NAME="{{ .Phases.setupNodeKeyStore.Output.snapshotName }}"
REPO_PATH="{{ .Phases.setupNodeKeyStoreBackup.Output.repoPath }}"
SNAPSHOT_NAME="{{ .Phases.setupNodeKeyStoreBackup.Output.snapshotName }}"
# reload the secure settings to access the S3 profile
curl -k -u "elastic:$PASSWORD" -X POST "${ES_URL}/_nodes/reload_secure_settings?pretty" -H 'Content-Type: application/json' -d'
{}
Expand All @@ -108,12 +123,20 @@ actions:
"bucket": "'$BUCKET'",
"endpoint": "'$ENDPOINT'",
"region": "'$REGION'",
"base_path": "'$REPO_PATH'"
"base_path": "'$REPO_PATH'",
"path_style_access": "'$path_style_access'"
}
}
'
echo "creating the snap $SNAPSHOT_NAME"
curl -k -u "elastic:$PASSWORD" -X PUT "${ES_URL}/_snapshot/k10_repo/$SNAPSHOT_NAME?pretty"
code=$(curl -o /dev/null -w "%{http_code}\n" -k -u "elastic:$PASSWORD" -X PUT "${ES_URL}/_snapshot/k10_repo/$SNAPSHOT_NAME?pretty")
if [[ $code -eq 200 ]]
then
echo "snapshot $SNAPSHOT_NAME was successful initiated"
else
echo "snapshot $SNAPSHOT_NAME was not successful initiated"
exit 1
fi

while curl -k -u "elastic:$PASSWORD" -X GET "${ES_URL}/_snapshot/k10_repo/$SNAPSHOT_NAME/_status?pretty" | grep -P "(IN_PROGRESS|STARTED)"
do
Expand All @@ -132,12 +155,13 @@ actions:
echo $reason
exit 1
fi
sleep 5
restore:
inputArtifactNames:
- s3Snap # use it with for instance {{ .ArtifactsIn.s3Snap.KeyValue.repoPath }} or {{ .ArtifactsIn.s3Snap.KeyValue.snapshotName }}
phases:
- func: Wait
name: waitElasticGreen
name: waitElasticGreenRestore
args:
timeout: 360s
conditions:
Expand All @@ -157,14 +181,14 @@ actions:
name: "{{ .Object.metadata.name }}-es-{{ (index .Object.spec.nodeSets 0).name }}"
replicas: "{{ (index .Object.spec.nodeSets 0).count }}"
- func: KubeTask
name: setupNodeKeyStore
name: setupNodeKeyStoreRestore
objects:
elasticSecret:
kind: Secret
name: '{{ .Object.metadata.name }}-es-elastic-user'
namespace: '{{ .Object.metadata.namespace }}'
args:
image: ghcr.io/kanisterio/kanister-kubectl-1.18:0.81.0
image: ghcr.io/kanisterio/kanister-kubectl-1.18:0.109.0
command:
- bash
- +x
Expand All @@ -188,28 +212,26 @@ actions:
AWS_SECRET_KEY="{{ .Profile.Credential.Secret.Data.aws_secret_access_key | toString }}"
AWS_ACCESS_KEY="{{ .Profile.Credential.Secret.Data.aws_access_key_id | toString }}"
{{- end }}
# No Support for more than one node set for the moment
NODE_SET_COUNT={{ len .Object.spec.nodeSets }}
if [[ $NODE_SET_COUNT -gt 1 ]]
then
echo "error, no Support for more than one node set for the moment, exiting"
exit 4
fi
NODE_SET_0_COUNT={{ (index .Object.spec.nodeSets 0).count }}
NODE_SET_0_COUNT=$((NODE_SET_0_COUNT-1))
NODE_SET_0_NAME={{ (index .Object.spec.nodeSets 0).name }}
for i in $(seq 0 $NODE_SET_0_COUNT)
do
pod="{{ .Object.metadata.name }}-es-$NODE_SET_0_NAME-$i"
echo "updating elasticsearch-keystore of $pod"
kubectl exec -it -n {{ .Object.metadata.namespace }} $pod -c elasticsearch -- bash -c "echo ${AWS_ACCESS_KEY} | /usr/share/elasticsearch/bin/elasticsearch-keystore add --stdin -f s3.client.default.access_key"
kubectl exec -it -n {{ .Object.metadata.namespace }} $pod -c elasticsearch -- bash -c "echo ${AWS_SECRET_KEY} | /usr/share/elasticsearch/bin/elasticsearch-keystore add --stdin -f s3.client.default.secret_key"
done

NS_NAME={{ .Object.metadata.namespace }}
ES_CLUSTER_NAME={{ .Object.metadata.name }}
{{- range $index, $nodeSet := .Object.spec.nodeSets }}
NODE_SET_COUNT={{ $nodeSet.count }}
NODE_SET_COUNT=$((NODE_SET_COUNT-1))
NODE_SET_NAME={{ $nodeSet.name }}
for i in $(seq 0 $NODE_SET_COUNT)
do
pod="$ES_CLUSTER_NAME-es-$NODE_SET_NAME-$i"
echo "updating elasticsearch-keystore of $pod"
kubectl exec -it -n $NS_NAME $pod -c elasticsearch -- bash -c "echo ${AWS_ACCESS_KEY} | /usr/share/elasticsearch/bin/elasticsearch-keystore add --stdin -f s3.client.default.access_key"
kubectl exec -it -n $NS_NAME $pod -c elasticsearch -- bash -c "echo ${AWS_SECRET_KEY} | /usr/share/elasticsearch/bin/elasticsearch-keystore add --stdin -f s3.client.default.secret_key"
done
{{- end }}
- func: KubeTask
name: restoreElastic
args:
namespace: "{{ .Object.metadata.namespace }}"
image: ghcr.io/kanisterio/kanister-kubectl-1.18:0.81.0
image: ghcr.io/kanisterio/kanister-kubectl-1.18:0.109.0
command:
- bash
- +x
Expand All @@ -220,24 +242,20 @@ actions:
- -c
- |
ES_URL="https://{{ .Object.metadata.name }}-es-http:9200"
PASSWORD="{{ index .Phases.setupNodeKeyStore.Secrets.elasticSecret.Data "elastic" | toString }}"
PASSWORD="{{ index .Phases.setupNodeKeyStoreRestore.Secrets.elasticSecret.Data "elastic" | toString }}"
REGION="{{ .Profile.Location.Region }}"
BUCKET="{{ .Profile.Location.Bucket }}"
ENDPOINT="{{ .Profile.Location.Endpoint }}"
if [[ -z $ENDPOINT ]]
then
ENDPOINT="s3.amazonaws.com"
path_style_access="false"
else
# when using non amazon s3 endpoint, we need to use path style access
path_style_access="true"
fi
REPO_PATH="{{ .ArtifactsIn.s3Snap.KeyValue.repoPath }}"
SNAPSHOT_NAME="{{ .ArtifactsIn.s3Snap.KeyValue.snapshotName }}"
bp_dbg "REGION=$REGION"
bp_dbg "BUCKET=$BUCKET"
bp_dbg "ENDPOINT=$ENDPOINT"
bp_dbg "PASSWORD=$PASSWORD"
bp_dbg "PROFILE_TYPE=$PROFILE_TYPE"
bp_dbg "REPO_PATH=$REPO_PATH"
bp_dbg "SNAPSHOT_NAME=$SNAPSHOT_NAME"

# reload the secure settings to access the S3 profile
curl -k -u "elastic:$PASSWORD" -X POST "${ES_URL}/_nodes/reload_secure_settings?pretty" -H 'Content-Type: application/json' -d'
{}
Expand All @@ -251,7 +269,8 @@ actions:
"bucket": "'$BUCKET'",
"endpoint": "'$ENDPOINT'",
"region": "'$REGION'",
"base_path": "'$REPO_PATH'"
"base_path": "'$REPO_PATH'",
"path_style_access": "'$path_style_access'"
}
}
'
Expand Down Expand Up @@ -329,14 +348,14 @@ actions:
- s3Snap
phases:
- func: KubeTask
name: setupNodeKeyStore
name: setupNodeKeyStoreDelete
objects:
elasticSecret:
kind: Secret
name: '{{ .ArtifactsIn.s3Snap.KeyValue.esClusterName }}-es-elastic-user'
namespace: '{{ .ArtifactsIn.s3Snap.KeyValue.esClusterNamespace }}'
args:
image: ghcr.io/kanisterio/kanister-kubectl-1.18:0.81.0
image: ghcr.io/kanisterio/kanister-kubectl-1.18:0.109.0
command:
- bash
- +x
Expand Down Expand Up @@ -370,21 +389,25 @@ actions:
echo "error, we don't have an es cluster $ES_CLUSTER_NAME in ns $NAMESPACE"
exit 5
fi
NODE_SET_0_COUNT=$(kubectl get elasticsearch $ES_CLUSTER_NAME -n $NAMESPACE -o jsonpath='{.spec.nodeSets[0].count}')
NODE_SET_0_COUNT=$((NODE_SET_0_COUNT-1))
NODE_SET_0_NAME=$(kubectl get elasticsearch $ES_CLUSTER_NAME -n $NAMESPACE -o jsonpath='{.spec.nodeSets[0].name}')
for i in $(seq 0 $NODE_SET_0_COUNT)
do
pod="$ES_CLUSTER_NAME-es-$NODE_SET_0_NAME-$i"
echo "updating elasticsearch-keystore of $pod"
kubectl exec -it -n $NAMESPACE $pod -c elasticsearch -- bash -c "echo ${AWS_ACCESS_KEY} | /usr/share/elasticsearch/bin/elasticsearch-keystore add --stdin -f s3.client.default.access_key"
kubectl exec -it -n $NAMESPACE $pod -c elasticsearch -- bash -c "echo ${AWS_SECRET_KEY} | /usr/share/elasticsearch/bin/elasticsearch-keystore add --stdin -f s3.client.default.secret_key"
done
NS_NAME=$NAMESPACE
for NODE_SET_NAME in $(kubectl get elasticsearch -n $NS_NAME $ES_CLUSTER_NAME -o jsonpath='{.spec.nodeSets[*].name}')
do
NODE_SET_COUNT=$(kubectl get elasticsearch -n $NS_NAME $ES_CLUSTER_NAME -o jsonpath="{.spec.nodeSets[?(@.name == '$NODE_SET_NAME')].count}")
NODE_SET_COUNT=$((NODE_SET_COUNT-1))
echo "$NODE_SET_NAME $NODE_SET_COUNT"
for i in $(seq 0 $NODE_SET_COUNT)
do
pod="$ES_CLUSTER_NAME-es-$NODE_SET_NAME-$i"
echo "updating elasticsearch-keystore of $pod"
kubectl exec -it -n $NS_NAME $pod -c elasticsearch -- bash -c "echo ${AWS_ACCESS_KEY} | /usr/share/elasticsearch/bin/elasticsearch-keystore add --stdin -f s3.client.default.access_key"
kubectl exec -it -n $NS_NAME $pod -c elasticsearch -- bash -c "echo ${AWS_SECRET_KEY} | /usr/share/elasticsearch/bin/elasticsearch-keystore add --stdin -f s3.client.default.secret_key"
done
done
- func: KubeTask
name: deleteSnapshot
args:
namespace: '{{ .ArtifactsIn.s3Snap.KeyValue.esClusterNamespace }}'
image: ghcr.io/kanisterio/kanister-kubectl-1.18:0.81.0
image: ghcr.io/kanisterio/kanister-kubectl-1.18:0.109.0
command:
- bash
- +x
Expand All @@ -395,24 +418,20 @@ actions:
- -c
- |
ES_URL="https://{{ .ArtifactsIn.s3Snap.KeyValue.esClusterName }}-es-http:9200"
PASSWORD="{{ index .Phases.setupNodeKeyStore.Secrets.elasticSecret.Data "elastic" | toString }}"
PASSWORD="{{ index .Phases.setupNodeKeyStoreDelete.Secrets.elasticSecret.Data "elastic" | toString }}"
REGION="{{ .Profile.Location.Region }}"
BUCKET="{{ .Profile.Location.Bucket }}"
ENDPOINT="{{ .Profile.Location.Endpoint }}"
if [[ -z $ENDPOINT ]]
then
ENDPOINT="s3.amazonaws.com"
path_style_access="false"
else
# when using non amazon s3 endpoint, we need to use path style access
path_style_access="true"
fi
REPO_PATH="{{ .ArtifactsIn.s3Snap.KeyValue.repoPath }}"
SNAPSHOT_NAME="{{ .ArtifactsIn.s3Snap.KeyValue.snapshotName }}"
bp_dbg "REGION=$REGION"
bp_dbg "BUCKET=$BUCKET"
bp_dbg "ENDPOINT=$ENDPOINT"
bp_dbg "PASSWORD=$PASSWORD"
bp_dbg "PROFILE_TYPE=$PROFILE_TYPE"
bp_dbg "REPO_PATH=$REPO_PATH"
bp_dbg "SNAPSHOT_NAME=$SNAPSHOT_NAME"

SNAPSHOT_NAME="{{ .ArtifactsIn.s3Snap.KeyValue.snapshotName }}"
# reload the secure settings to access the S3 profile
curl -k -u "elastic:$PASSWORD" -X POST "${ES_URL}/_nodes/reload_secure_settings?pretty" -H 'Content-Type: application/json' -d'
{}
Expand All @@ -426,12 +445,12 @@ actions:
"bucket": "'$BUCKET'",
"endpoint": "'$ENDPOINT'",
"region": "'$REGION'",
"base_path": "'$REPO_PATH'"
"base_path": "'$REPO_PATH'",
"path_style_access": "'$path_style_access'"
}
}
'

echo "delete the snap $SNAPSHOT_NAME"
curl -k -u "elastic:$PASSWORD" -X DELETE "${ES_URL}/_snapshot/k10_repo/$SNAPSHOT_NAME?pretty"
echo "Deletion of $SNAPSHOT_NAME was successful"

echo "Deletion of $SNAPSHOT_NAME was successful"
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
echo "Deletion of $SNAPSHOT_NAME was successful"
echo "Deletion of $SNAPSHOT_NAME was successful"

Loading