时间戳

首页 > 解决方案 > K8S Autoscaling 触发 Cloud Function

kubernetes - K8S Autoscaling 触发 Cloud Function

问题描述

当我的节点池在高性能条件下自动扩展时，是否可以在 GCloud 中触发 Pub/Sub 事件或 Google Cloud Function？

或者是否有任何其他可用于触发 Cloud Function 的分析事件？

标签： kubernetesgoogle-cloud-platformgoogle-cloud-functionsautoscaling

解决方案

通过在 Stackdriver logs 上设置接收器（以 Pub/Sub 主题作为目标）来扩展节点池时，您可以收到通知（在 Pub/Sub 中） 。

您必须听取与节点池扩展相对应的特定日志。有 2 个过滤器可用于您的水槽。与这些过滤器之一对应的任何消息都将发送到 Pub/Sub 主题，这意味着您可以在该主题中发布消息时触发云函数。

过滤实例组

您可以在实例组上使用此过滤器（GKE 节点池实际上是计算 VM 的托管实例组）：

resource.type="gce_instance_group_manager" AND
resource.labels.instance_group_manager_name:"gke-<cluster_name>-default-pool" AND
protoPayload.methodName="v1.compute.instanceGroupManagers.resize" AND
operation.last="true"

（请替换<cluster_name>为您的集群名称和<node_pool_name>节点池名称，如default-pool）。

过滤集群自动扩缩器日志

您也可以使用此过滤器：

resource.type="k8s_cluster" AND
logName="projects/<project_id>/logs/container.googleapis.com%2Fcluster-autoscaler-visibility" AND
jsonPayload.decision.scaleUp.increasedMigs.mig.nodepool="<node_pool_name>"

（请替换<project_id>为您的项目的 id 和<node_pool_name>节点池名称，如default-pool）。

这个过滤器的有趣之处在于，您可以通过查看以下内容来了解​​哪个 pod 导致了扩展，以及添加了多少节点jsonPayload：

jsonPayload: {
    decision: {
        eventId: "41ddc559-c616-4068-8ba2-2f26eadcc7bd"
        decideTime: "1620897027"
        scaleUp: {
            increasedMigs: [
                0: {
                    mig: {
                        name: "gke-<cluster_name>-<node_pool_name>-xxxxxxxx-grp"
                        nodepool: "<node_pool_name>"
                        zone: "<zone>"
                    }
                    requestedNodes: 1
                }
            ]
            triggeringPods: [
                0: {
                    name: "<pod_name_causing_the_scale_up>"
                    namespace: "<pod_namespace>"
                }
            ]
            triggeringPodsTotalCount: 1
        }
    }
}

推荐阅读