K8S Autoscaling 触发 Cloud Function 按实例组过滤过滤集群自动扩缩器日志

如何解决K8S Autoscaling 触发 Cloud Function 按实例组过滤过滤集群自动扩缩器日志

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

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

解决方法

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

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

按实例组过滤

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

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）。

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

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
        }
    }
}