mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-23 19:56:01 +00:00
fix cluster/log-dump/log-dump.sh shellcheck failures
This commit is contained in:
parent
1c548c328a
commit
742701622a
@ -67,7 +67,7 @@ readonly max_dump_processes=25
|
|||||||
function setup() {
|
function setup() {
|
||||||
KUBE_ROOT=$(dirname "${BASH_SOURCE[0]}")/../..
|
KUBE_ROOT=$(dirname "${BASH_SOURCE[0]}")/../..
|
||||||
if [[ -z "${use_custom_instance_list}" ]]; then
|
if [[ -z "${use_custom_instance_list}" ]]; then
|
||||||
: ${KUBE_CONFIG_FILE:="config-test.sh"}
|
: "${KUBE_CONFIG_FILE:="config-test.sh"}"
|
||||||
echo "Sourcing kube-util.sh"
|
echo "Sourcing kube-util.sh"
|
||||||
source "${KUBE_ROOT}/cluster/kube-util.sh"
|
source "${KUBE_ROOT}/cluster/kube-util.sh"
|
||||||
echo "Detecting project"
|
echo "Detecting project"
|
||||||
@ -89,7 +89,7 @@ function setup() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
function log-dump-ssh() {
|
function log-dump-ssh() {
|
||||||
if [[ "${gcloud_supported_providers}" =~ "${KUBERNETES_PROVIDER}" ]]; then
|
if [[ "${gcloud_supported_providers}" =~ ${KUBERNETES_PROVIDER} ]]; then
|
||||||
ssh-to-node "$@"
|
ssh-to-node "$@"
|
||||||
return
|
return
|
||||||
fi
|
fi
|
||||||
@ -106,7 +106,7 @@ function log-dump-ssh() {
|
|||||||
function copy-logs-from-node() {
|
function copy-logs-from-node() {
|
||||||
local -r node="${1}"
|
local -r node="${1}"
|
||||||
local -r dir="${2}"
|
local -r dir="${2}"
|
||||||
local files=( ${3} )
|
while IFS= read -r line; do files+=("$line"); done <<< "$3"
|
||||||
# Append "*"
|
# Append "*"
|
||||||
# The * at the end is needed to also copy rotated logs (which happens
|
# The * at the end is needed to also copy rotated logs (which happens
|
||||||
# in large clusters and long runs).
|
# in large clusters and long runs).
|
||||||
@ -116,12 +116,13 @@ function copy-logs-from-node() {
|
|||||||
# Comma delimit (even the singleton, or scp does the wrong thing), surround by braces.
|
# Comma delimit (even the singleton, or scp does the wrong thing), surround by braces.
|
||||||
local -r scp_files="{$(printf "%s," "${files[@]}")}"
|
local -r scp_files="{$(printf "%s," "${files[@]}")}"
|
||||||
|
|
||||||
if [[ "${gcloud_supported_providers}" =~ "${KUBERNETES_PROVIDER}" ]]; then
|
if [[ "${gcloud_supported_providers}" =~ ${KUBERNETES_PROVIDER} ]]; then
|
||||||
# get-serial-port-output lets you ask for ports 1-4, but currently (11/21/2016) only port 1 contains useful information
|
# get-serial-port-output lets you ask for ports 1-4, but currently (11/21/2016) only port 1 contains useful information
|
||||||
gcloud compute instances get-serial-port-output --project "${PROJECT}" --zone "${ZONE}" --port 1 "${node}" > "${dir}/serial-1.log" || true
|
gcloud compute instances get-serial-port-output --project "${PROJECT}" --zone "${ZONE}" --port 1 "${node}" > "${dir}/serial-1.log" || true
|
||||||
gcloud compute scp --recurse --project "${PROJECT}" --zone "${ZONE}" "${node}:${scp_files}" "${dir}" > /dev/null || true
|
gcloud compute scp --recurse --project "${PROJECT}" --zone "${ZONE}" "${node}:${scp_files}" "${dir}" > /dev/null || true
|
||||||
elif [[ "${KUBERNETES_PROVIDER}" == "aws" ]]; then
|
elif [[ "${KUBERNETES_PROVIDER}" == "aws" ]]; then
|
||||||
local ip=$(get_ssh_hostname "${node}")
|
local ip
|
||||||
|
ip=$(get_ssh_hostname "${node}")
|
||||||
scp -oLogLevel=quiet -oConnectTimeout=30 -oStrictHostKeyChecking=no -i "${AWS_SSH_KEY}" "${SSH_USER}@${ip}:${scp_files}" "${dir}" > /dev/null || true
|
scp -oLogLevel=quiet -oConnectTimeout=30 -oStrictHostKeyChecking=no -i "${AWS_SSH_KEY}" "${SSH_USER}@${ip}:${scp_files}" "${dir}" > /dev/null || true
|
||||||
elif [[ -n "${use_custom_instance_list}" ]]; then
|
elif [[ -n "${use_custom_instance_list}" ]]; then
|
||||||
scp -oLogLevel=quiet -oConnectTimeout=30 -oStrictHostKeyChecking=no -i "${LOG_DUMP_SSH_KEY}" "${LOG_DUMP_SSH_USER}@${node}:${scp_files}" "${dir}" > /dev/null || true
|
scp -oLogLevel=quiet -oConnectTimeout=30 -oStrictHostKeyChecking=no -i "${LOG_DUMP_SSH_KEY}" "${LOG_DUMP_SSH_USER}@${node}:${scp_files}" "${dir}" > /dev/null || true
|
||||||
@ -138,26 +139,27 @@ function copy-logs-from-node() {
|
|||||||
function save-logs() {
|
function save-logs() {
|
||||||
local -r node_name="${1}"
|
local -r node_name="${1}"
|
||||||
local -r dir="${2}"
|
local -r dir="${2}"
|
||||||
local files="${3}"
|
local save_files="${3}"
|
||||||
local opt_systemd_services="${4:-""}"
|
local opt_systemd_services="${4:-""}"
|
||||||
local on_master="${5:-"false"}"
|
local on_master="${5:-"false"}"
|
||||||
|
|
||||||
files="${files} ${extra_log_files}"
|
save_files="${save_files} ${extra_log_files}"
|
||||||
if [[ -n "${use_custom_instance_list}" ]]; then
|
if [[ -n "${use_custom_instance_list}" ]]; then
|
||||||
if [[ -n "${LOG_DUMP_SAVE_LOGS:-}" ]]; then
|
if [[ -n "${LOG_DUMP_SAVE_LOGS:-}" ]]; then
|
||||||
files="${files} ${LOG_DUMP_SAVE_LOGS:-}"
|
save_files="${save_files} ${LOG_DUMP_SAVE_LOGS:-}"
|
||||||
fi
|
fi
|
||||||
else
|
else
|
||||||
case "${KUBERNETES_PROVIDER}" in
|
case "${KUBERNETES_PROVIDER}" in
|
||||||
gce|gke)
|
gce|gke)
|
||||||
files="${files} ${gce_logfiles}"
|
save_files="${save_files} ${gce_logfiles}"
|
||||||
;;
|
;;
|
||||||
aws)
|
aws)
|
||||||
files="${files} ${aws_logfiles}"
|
save_files="${save_files} ${aws_logfiles}"
|
||||||
;;
|
;;
|
||||||
esac
|
esac
|
||||||
fi
|
fi
|
||||||
local -r services=( ${systemd_services} ${opt_systemd_services} ${extra_systemd_services} )
|
|
||||||
|
read -r -a services <<< "${systemd_services} ${opt_systemd_services} ${extra_systemd_services}"
|
||||||
|
|
||||||
if log-dump-ssh "${node_name}" "command -v journalctl" &> /dev/null; then
|
if log-dump-ssh "${node_name}" "command -v journalctl" &> /dev/null; then
|
||||||
if [[ "${on_master}" == "true" ]]; then
|
if [[ "${on_master}" == "true" ]]; then
|
||||||
@ -177,7 +179,7 @@ function save-logs() {
|
|||||||
log-dump-ssh "${node_name}" "sudo journalctl --output=short-precise" > "${dir}/systemd.log" || true
|
log-dump-ssh "${node_name}" "sudo journalctl --output=short-precise" > "${dir}/systemd.log" || true
|
||||||
fi
|
fi
|
||||||
else
|
else
|
||||||
files="${kern_logfile} ${files} ${initd_logfiles} ${supervisord_logfiles}"
|
save_files="${kern_logfile} ${save_files} ${initd_logfiles} ${supervisord_logfiles}"
|
||||||
fi
|
fi
|
||||||
|
|
||||||
# Try dumping coverage profiles, if it looks like coverage is enabled in the first place.
|
# Try dumping coverage profiles, if it looks like coverage is enabled in the first place.
|
||||||
@ -198,8 +200,8 @@ function save-logs() {
|
|||||||
echo "Changing logfiles to be world-readable for download"
|
echo "Changing logfiles to be world-readable for download"
|
||||||
log-dump-ssh "${node_name}" "sudo chmod -R a+r /var/log" || true
|
log-dump-ssh "${node_name}" "sudo chmod -R a+r /var/log" || true
|
||||||
|
|
||||||
echo "Copying '${files}' from ${node_name}"
|
echo "Copying '${save_files}' from ${node_name}"
|
||||||
copy-logs-from-node "${node_name}" "${dir}" "${files}"
|
copy-logs-from-node "${node_name}" "${dir}" "${save_files}"
|
||||||
}
|
}
|
||||||
|
|
||||||
# Saves a copy of the Windows Docker event log to ${WINDOWS_LOGS_DIR}\docker.log
|
# Saves a copy of the Windows Docker event log to ${WINDOWS_LOGS_DIR}\docker.log
|
||||||
@ -245,8 +247,9 @@ function save-windows-logs-via-diagnostics-tool() {
|
|||||||
local node="${1}"
|
local node="${1}"
|
||||||
local dest_dir="${2}"
|
local dest_dir="${2}"
|
||||||
|
|
||||||
gcloud compute instances add-metadata ${node} --metadata enable-diagnostics=true --project=${PROJECT} --zone=${ZONE}
|
gcloud compute instances add-metadata "${node}" --metadata enable-diagnostics=true "--project=${PROJECT}" "--zone=${ZONE}"
|
||||||
local logs_archive_in_gcs=$(gcloud alpha compute diagnose export-logs ${node} --zone=${ZONE} --project=${PROJECT} | tail -n 1)
|
local logs_archive_in_gcs
|
||||||
|
logs_archive_in_gcs=$(gcloud alpha compute diagnose export-logs "${node}" "--zone=${ZONE}" "--project=${PROJECT}" | tail -n 1)
|
||||||
local temp_local_path="${node}.zip"
|
local temp_local_path="${node}.zip"
|
||||||
for retry in {1..20}; do
|
for retry in {1..20}; do
|
||||||
if gsutil mv "${logs_archive_in_gcs}" "${temp_local_path}" > /dev/null 2>&1; then
|
if gsutil mv "${logs_archive_in_gcs}" "${temp_local_path}" > /dev/null 2>&1; then
|
||||||
@ -258,8 +261,8 @@ function save-windows-logs-via-diagnostics-tool() {
|
|||||||
done
|
done
|
||||||
|
|
||||||
if [[ -f "${temp_local_path}" ]]; then
|
if [[ -f "${temp_local_path}" ]]; then
|
||||||
unzip ${temp_local_path} -d "${dest_dir}" > /dev/null
|
unzip "${temp_local_path}" -d "${dest_dir}" > /dev/null
|
||||||
rm -f ${temp_local_path}
|
rm -f "${temp_local_path}"
|
||||||
fi
|
fi
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -272,14 +275,14 @@ function save-windows-logs-via-ssh() {
|
|||||||
export-windows-docker-images-list "${node}"
|
export-windows-docker-images-list "${node}"
|
||||||
|
|
||||||
local remote_files=()
|
local remote_files=()
|
||||||
for file in ${windows_node_logfiles[@]}; do
|
for file in "${windows_node_logfiles[@]}"; do
|
||||||
remote_files+=( "${WINDOWS_LOGS_DIR}\\${file}" )
|
remote_files+=( "${WINDOWS_LOGS_DIR}\\${file}" )
|
||||||
done
|
done
|
||||||
remote_files+=( "${windows_node_otherfiles[@]}" )
|
remote_files+=( "${windows_node_otherfiles[@]}" )
|
||||||
|
|
||||||
# TODO(pjh, yujuhong): handle rotated logs and copying multiple files at the
|
# TODO(pjh, yujuhong): handle rotated logs and copying multiple files at the
|
||||||
# same time.
|
# same time.
|
||||||
for remote_file in ${remote_files[@]}; do
|
for remote_file in "${remote_files[@]}"; do
|
||||||
# Retry up to 3 times to allow ssh keys to be properly propagated and
|
# Retry up to 3 times to allow ssh keys to be properly propagated and
|
||||||
# stored.
|
# stored.
|
||||||
for retry in {1..3}; do
|
for retry in {1..3}; do
|
||||||
@ -301,7 +304,7 @@ function save-logs-windows() {
|
|||||||
local -r node="${1}"
|
local -r node="${1}"
|
||||||
local -r dest_dir="${2}"
|
local -r dest_dir="${2}"
|
||||||
|
|
||||||
if [[ ! "${gcloud_supported_providers}" =~ "${KUBERNETES_PROVIDER}" ]]; then
|
if [[ ! "${gcloud_supported_providers}" =~ ${KUBERNETES_PROVIDER} ]]; then
|
||||||
echo "Not saving logs for ${node}, Windows log dumping requires gcloud support"
|
echo "Not saving logs for ${node}, Windows log dumping requires gcloud support"
|
||||||
return
|
return
|
||||||
fi
|
fi
|
||||||
@ -323,14 +326,14 @@ function run-in-docker-container() {
|
|||||||
local node_name="$1"
|
local node_name="$1"
|
||||||
local container="$2"
|
local container="$2"
|
||||||
shift 2
|
shift 2
|
||||||
log-dump-ssh "${node_name}" "docker exec \"\$(docker ps -f label=io.kubernetes.container.name=${container} --format \"{{.ID}}\")\" $@"
|
log-dump-ssh "${node_name}" "docker exec \"\$(docker ps -f label=io.kubernetes.container.name=${container} --format \"{{.ID}}\")\" $*"
|
||||||
}
|
}
|
||||||
|
|
||||||
function dump_masters() {
|
function dump_masters() {
|
||||||
local master_names
|
local master_names
|
||||||
if [[ -n "${use_custom_instance_list}" ]]; then
|
if [[ -n "${use_custom_instance_list}" ]]; then
|
||||||
master_names=( $(log_dump_custom_get_instances master) )
|
while IFS='' read -r line; do master_names+=("$line"); done < <(log_dump_custom_get_instances master)
|
||||||
elif [[ ! "${master_ssh_supported_providers}" =~ "${KUBERNETES_PROVIDER}" ]]; then
|
elif [[ ! "${master_ssh_supported_providers}" =~ ${KUBERNETES_PROVIDER} ]]; then
|
||||||
echo "Master SSH not supported for ${KUBERNETES_PROVIDER}"
|
echo "Master SSH not supported for ${KUBERNETES_PROVIDER}"
|
||||||
return
|
return
|
||||||
elif [[ -n "${KUBEMARK_MASTER_NAME:-}" ]]; then
|
elif [[ -n "${KUBEMARK_MASTER_NAME:-}" ]]; then
|
||||||
@ -381,8 +384,8 @@ function dump_nodes() {
|
|||||||
node_names=( "$@" )
|
node_names=( "$@" )
|
||||||
elif [[ -n "${use_custom_instance_list}" ]]; then
|
elif [[ -n "${use_custom_instance_list}" ]]; then
|
||||||
echo "Dumping logs for nodes provided by log_dump_custom_get_instances() function"
|
echo "Dumping logs for nodes provided by log_dump_custom_get_instances() function"
|
||||||
node_names=( $(log_dump_custom_get_instances node) )
|
while IFS='' read -r line; do node_names+=("$line"); done < <(log_dump_custom_get_instances node)
|
||||||
elif [[ ! "${node_ssh_supported_providers}" =~ "${KUBERNETES_PROVIDER}" ]]; then
|
elif [[ ! "${node_ssh_supported_providers}" =~ ${KUBERNETES_PROVIDER} ]]; then
|
||||||
echo "Node SSH not supported for ${KUBERNETES_PROVIDER}"
|
echo "Node SSH not supported for ${KUBERNETES_PROVIDER}"
|
||||||
return
|
return
|
||||||
else
|
else
|
||||||
@ -409,7 +412,7 @@ function dump_nodes() {
|
|||||||
linux_nodes_selected_for_logs=()
|
linux_nodes_selected_for_logs=()
|
||||||
if [[ -n "${LOGDUMP_ONLY_N_RANDOM_NODES:-}" ]]; then
|
if [[ -n "${LOGDUMP_ONLY_N_RANDOM_NODES:-}" ]]; then
|
||||||
# We randomly choose 'LOGDUMP_ONLY_N_RANDOM_NODES' many nodes for fetching logs.
|
# We randomly choose 'LOGDUMP_ONLY_N_RANDOM_NODES' many nodes for fetching logs.
|
||||||
for index in `shuf -i 0-$(( ${#node_names[*]} - 1 )) -n ${LOGDUMP_ONLY_N_RANDOM_NODES}`
|
for index in $(shuf -i 0-$(( ${#node_names[*]} - 1 )) -n "${LOGDUMP_ONLY_N_RANDOM_NODES}")
|
||||||
do
|
do
|
||||||
linux_nodes_selected_for_logs+=("${node_names[$index]}")
|
linux_nodes_selected_for_logs+=("${node_names[$index]}")
|
||||||
done
|
done
|
||||||
@ -475,7 +478,7 @@ function find_non_logexported_nodes() {
|
|||||||
echo "Successfully listed marker files for successful nodes"
|
echo "Successfully listed marker files for successful nodes"
|
||||||
NON_LOGEXPORTED_NODES=()
|
NON_LOGEXPORTED_NODES=()
|
||||||
for node in "${NODE_NAMES[@]}"; do
|
for node in "${NODE_NAMES[@]}"; do
|
||||||
if [[ ! "${succeeded_nodes}" =~ "${node}" ]]; then
|
if [[ ! "${succeeded_nodes}" =~ ${node} ]]; then
|
||||||
NON_LOGEXPORTED_NODES+=("${node}")
|
NON_LOGEXPORTED_NODES+=("${node}")
|
||||||
fi
|
fi
|
||||||
done
|
done
|
||||||
@ -486,7 +489,8 @@ function find_non_logexported_nodes() {
|
|||||||
function dump_nodes_with_logexporter() {
|
function dump_nodes_with_logexporter() {
|
||||||
if [[ -n "${use_custom_instance_list}" ]]; then
|
if [[ -n "${use_custom_instance_list}" ]]; then
|
||||||
echo "Dumping logs for nodes provided by log_dump_custom_get_instances() function"
|
echo "Dumping logs for nodes provided by log_dump_custom_get_instances() function"
|
||||||
NODE_NAMES=( $(log_dump_custom_get_instances node) )
|
NODE_NAMES=()
|
||||||
|
while IFS='' read -r line; do NODE_NAMES+=("$line"); done < <(log_dump_custom_get_instances node)
|
||||||
else
|
else
|
||||||
echo "Detecting nodes in the cluster"
|
echo "Detecting nodes in the cluster"
|
||||||
detect-node-names &> /dev/null
|
detect-node-names &> /dev/null
|
||||||
@ -498,7 +502,7 @@ function dump_nodes_with_logexporter() {
|
|||||||
fi
|
fi
|
||||||
|
|
||||||
# Obtain parameters required by logexporter.
|
# Obtain parameters required by logexporter.
|
||||||
local -r service_account_credentials="$(cat ${GOOGLE_APPLICATION_CREDENTIALS} | base64 | tr -d '\n')"
|
local -r service_account_credentials="$(base64 <<< "${GOOGLE_APPLICATION_CREDENTIALS}" | tr -d '\n')"
|
||||||
local -r cloud_provider="${KUBERNETES_PROVIDER}"
|
local -r cloud_provider="${KUBERNETES_PROVIDER}"
|
||||||
local -r enable_hollow_node_logs="${ENABLE_HOLLOW_NODE_LOGS:-false}"
|
local -r enable_hollow_node_logs="${ENABLE_HOLLOW_NODE_LOGS:-false}"
|
||||||
local -r logexport_sleep_seconds="$(( 90 + NUM_NODES / 3 ))"
|
local -r logexport_sleep_seconds="$(( 90 + NUM_NODES / 3 ))"
|
||||||
@ -559,7 +563,6 @@ function dump_nodes_with_logexporter() {
|
|||||||
done; wait)
|
done; wait)
|
||||||
|
|
||||||
# List registry of marker files (of nodes whose logexporter succeeded) from GCS.
|
# List registry of marker files (of nodes whose logexporter succeeded) from GCS.
|
||||||
local nodes_succeeded
|
|
||||||
for retry in {1..10}; do
|
for retry in {1..10}; do
|
||||||
if find_non_logexported_nodes; then
|
if find_non_logexported_nodes; then
|
||||||
break
|
break
|
||||||
@ -589,28 +592,29 @@ function dump_nodes_with_logexporter() {
|
|||||||
"${KUBECTL}" get pods --namespace "${logexporter_namespace}" || true
|
"${KUBECTL}" get pods --namespace "${logexporter_namespace}" || true
|
||||||
"${KUBECTL}" delete namespace "${logexporter_namespace}" || true
|
"${KUBECTL}" delete namespace "${logexporter_namespace}" || true
|
||||||
if [[ "${#failed_nodes[@]}" != 0 ]]; then
|
if [[ "${#failed_nodes[@]}" != 0 ]]; then
|
||||||
echo -e "Dumping logs through SSH for the following nodes:\n${failed_nodes[@]}"
|
echo -e "Dumping logs through SSH for the following nodes:\n${failed_nodes[*]}"
|
||||||
dump_nodes "${failed_nodes[@]}"
|
dump_nodes "${failed_nodes[@]}"
|
||||||
fi
|
fi
|
||||||
}
|
}
|
||||||
|
|
||||||
function detect_node_failures() {
|
function detect_node_failures() {
|
||||||
if ! [[ "${gcloud_supported_providers}" =~ "${KUBERNETES_PROVIDER}" ]]; then
|
if ! [[ "${gcloud_supported_providers}" =~ ${KUBERNETES_PROVIDER} ]]; then
|
||||||
return
|
return
|
||||||
fi
|
fi
|
||||||
|
|
||||||
detect-node-names
|
detect-node-names
|
||||||
if [[ "${KUBERNETES_PROVIDER}" == "gce" ]]; then
|
if [[ "${KUBERNETES_PROVIDER}" == "gce" ]]; then
|
||||||
local all_instance_groups=(${INSTANCE_GROUPS[@]} ${WINDOWS_INSTANCE_GROUPS[@]})
|
local all_instance_groups=("${INSTANCE_GROUPS[@]}" "${WINDOWS_INSTANCE_GROUPS[@]}")
|
||||||
else
|
else
|
||||||
local all_instance_groups=(${INSTANCE_GROUPS[@]})
|
local all_instance_groups=("${INSTANCE_GROUPS[@]}")
|
||||||
fi
|
fi
|
||||||
|
|
||||||
if [ -z "${all_instance_groups:-}" ]; then
|
if [ -z "${all_instance_groups:-}" ]; then
|
||||||
return
|
return
|
||||||
fi
|
fi
|
||||||
for group in "${all_instance_groups[@]}"; do
|
for group in "${all_instance_groups[@]}"; do
|
||||||
local creation_timestamp=$(gcloud compute instance-groups managed describe \
|
local creation_timestamp
|
||||||
|
creation_timestamp=$(gcloud compute instance-groups managed describe \
|
||||||
"${group}" \
|
"${group}" \
|
||||||
--project "${PROJECT}" \
|
--project "${PROJECT}" \
|
||||||
--zone "${ZONE}" \
|
--zone "${ZONE}" \
|
||||||
|
@ -2,4 +2,3 @@
|
|||||||
./cluster/gce/gci/configure.sh
|
./cluster/gce/gci/configure.sh
|
||||||
./cluster/gce/gci/master-helper.sh
|
./cluster/gce/gci/master-helper.sh
|
||||||
./cluster/gce/util.sh
|
./cluster/gce/util.sh
|
||||||
./cluster/log-dump/log-dump.sh
|
|
||||||
|
Loading…
Reference in New Issue
Block a user