kubernetes - 更新 Kubernetes 服务端点 IP
问题描述
我将 Kubernetes 应用程序与具有单个端点的服务一起使用。如果使用curl
我检索它,我会得到这样的东西:
{
"kind": "Endpoints",
"apiVersion": "v1",
"metadata": {
...
"subsets": [
{
"addresses": [
{
"ip": "172.16.235.204"
}
],
...
}
]
现在在给定的情况下,我的应用程序需要使用 curl PATCH 更改其 IP。我正在使用以下代码:
KUBE_SERVICE_DIR="/var/run/secrets/kubernetes.io/serviceaccount"
KUBE_TOKEN_FILENAME="${KUBE_SERVICE_DIR}/token"
KUBE_CA_CERT="${KUBE_SERVICE_DIR}/ca.crt"
KUBE_TOKEN=$(cat ${KUBE_TOKEN_FILENAME})
BODY='[{"op": "replace", "path": "subsets/0/addresses/0/ip", "value": "172.16.140.18"}]'
curl -XPATCH --cacert ${KUBE_CA_CERT} -H "Content-Type: application/json-patch+json" -H "Authorization: Bearer ${KUBE_TOKEN}" --data "${BODY}" "https://${KUBERNETES_API_HOST}:${KUBERNETES_API_PORT}/api/v1/namespaces/cf-db/endpoints/cfdb-ccdb"
如您所见,我的补丁 JSON 正在尝试在此路径上应用替换操作来subsets/0/addresses/0/ip
设置新 IP。但是当我运行它时,我得到了:
{
"kind": "Status",
"apiVersion": "v1",
"metadata": {
},
"status": "Failure",
"message": "the server rejected our request due to an error in our request",
"reason": "Invalid",
"details": {
},
"code": 422
有人可以帮我弄清楚我的代码有什么问题吗?我还使用 StackOverflow 上的示例尝试了很多变体,但没有运气。
解决方案
经过多次尝试和错误,我找到了下面的解决方案。
Patroni 中使用了这样的解决方案(但它是用 Python 编写的),其中服务有一个始终引用主节点的端点。当发生故障转移或切换时,Patroni 代码更新服务端点。每当您拥有 StatefulSet 并且即使在故障转移场景中也始终希望服务引用主节点时,都可以使用这样的代码。
KUBE_SERVICE_DIR="/var/run/secrets/kubernetes.io/serviceaccount"
KUBE_TOKEN_FILENAME="${KUBE_SERVICE_DIR}/token"
KUBE_CA_CERT="${KUBE_SERVICE_DIR}/ca.crt"
KUBE_TOKEN=$(cat ${KUBE_TOKEN_FILENAME})
KUBERNETES_API_HOST=${KUBERNETES_SERVICE_HOST}
KUBERNETES_API_PORT=${KUBERNETES_SERVICE_PORT}
generatePatchData()
{
local MASTER_IP=$1
local MASTER_PORT=$2
cat <<EOF
{"subsets": [{"addresses": [{"ip": "$MASTER_IP"}], "ports": [{"name": "postgresql", "port": $MASTER_PORT, "protocol": "TCP"}]}]}
EOF
}
patchEndpointIP() {
local MASTER_IP=$1
local MASTER_PORT=$2
curl -XPATCH --cacert ${KUBE_CA_CERT} -H "Content-Type: application/merge-patch+json" -H "Authorization: Bearer ${KUBE_TOKEN}" "https://${KUBERNETES_API_HOST}:${K
UBERNETES_API_PORT}/api/v1/namespaces/cf-db/endpoints/cfdb-ccdb" --data "$(generatePatchData $MASTER_IP $MASTER_PORT)"
}
getEndpointIP() {
curl -sSk -H "Authorization: Bearer ${KUBE_TOKEN}" "https://${KUBERNETES_API_HOST}:${KUBERNETES_API_PORT}/api/v1/namespaces/cf-db/endpoints/cfdb-ccdb"
}
patchEndpointIP "172.16.140.13" "5431"
getEndpointIP
推荐阅读
- python - Keras 中的“未知 RProp 优化器”
- python - 尝试使用 if/then 语句访问正确的列值时出现 RecursionError
- unix - awk 加入由多列组成的两个文件的第一列
- apache-kafka - 当所有 Kafka Broker 不可用时,Log4j2 kafka appender 故障转移处理?
- c# - ASP.NET - PartialView 继续使用布局
- flutter - 当我尝试将图像加载到容器中时出现错误 - Flutter
- javascript - 可以让事件处理函数返回一个函数吗?
- mysql - 对 SQL 中的两个单独列使用 Group By 来计算新列
- php - 如果产品类别等于“X”,则 Woocommerce 工作
- javascript - 从本地文件而不是从 vuejs 项目中的 url 路径动态显示图像