如何在GKE应用中自动获取标签至GCP Log Viewer（无需硬编码）

当然有办法不用硬编码这些值！GKE和Kubernetes本身就提供了原生方式来自动获取这些标签所需的信息，不用在代码里写死配置，下面是具体的实现方案：

核心思路 #

我们可以通过两种途径获取所需的标签值：

• Kubernetes自动注入的Pod环境变量，获取pod_name和namespace_name
• GCP元数据服务器，获取cluster_name和location（区域/可用区）
• project_id可以直接通过Cloud Logging客户端自动获取，无需额外配置

具体实现代码 #

import logging
import os
import requests
import google.cloud.logging
from google.cloud.logging.handlers import CloudLoggingHandler
from google.cloud.logging.resource import Resource

def get_gke_cluster_name():
    """从GCP元数据服务器获取集群名称"""
    try:
        url = "http://metadata.google.internal/computeMetadata/v1/instance/attributes/cluster-name"
        headers = {"Metadata-Flavor": "Google"}
        response = requests.get(url, headers=headers, timeout=5)
        response.raise_for_status()
        return response.text
    except Exception as e:
        logging.warning(f"无法获取集群名称: {str(e)}")
        return "unknown-cluster"

def get_gke_location():
    """从GCP元数据服务器获取区域（截取可用区的前半部分，比如us-west1-b -> us-west1）"""
    try:
        url = "http://metadata.google.internal/computeMetadata/v1/instance/zone"
        headers = {"Metadata-Flavor": "Google"}
        response = requests.get(url, headers=headers, timeout=5)
        response.raise_for_status()
        zone = response.text.split("/")[-1]
        # 从可用区提取符合要求的区域格式
        return "-".join(zone.split("-")[:3])
    except Exception as e:
        logging.warning(f"无法获取区域信息: {str(e)}")
        return "unknown-location"

# 初始化Cloud Logging客户端
client = google.cloud.logging.Client().from_service_account_json(os.environ.get("GOOGLE_SA_ACCOUNT"))

# 动态获取各标签值
pod_name = os.environ.get("POD_NAME", "unknown-pod")
namespace_name = os.environ.get("NAMESPACE", "unknown-namespace")
cluster_name = get_gke_cluster_name()
location = get_gke_location()
# 从客户端自动获取project_id，无需硬编码
project_id = client.project

# 创建k8s_container类型的Resource实例
resource = Resource(
    "k8s_container",
    labels={
        'namespace_name': namespace_name,
        'location': location,
        'cluster_name': cluster_name,
        'project_id': project_id,
        'pod_name': pod_name
    }
)

# 配置日志处理器
handler = CloudLoggingHandler(client, resource=resource)
google.cloud.logging.handlers.setup_logging(handler)
logging.getLogger().setLevel(logging.ERROR)

try:
    # 示例请求逻辑
    response = requests.head('https://www.exampleurladdress.com', timeout=10)
    if response.status_code != 200:
        logging.error(f"请求失败，状态码: {response.status_code}")
except requests.exceptions.RequestException as err:
    logging.error(f"请求异常: {str(err)}")

关键说明 #

• Kubernetes环境变量：POD_NAME和NAMESPACE是Kubernetes自动为每个Pod注入的环境变量，无需额外配置就能直接读取。
• 元数据服务器访问：GKE节点默认允许Pod访问元数据服务器，请求时必须携带Metadata-Flavor: Google请求头，否则会被拒绝。我们从可用区中提取标准区域格式，符合Cloud Logging对location字段的要求。
• 容错处理：代码中添加了异常捕获逻辑，避免因为元数据服务器访问失败导致应用崩溃，会返回带unknown-前缀的默认值。
• Project ID：通过Cloud Logging客户端的client.project属性自动获取，不需要硬编码或额外发起请求。

额外优化建议 #

如果你的GKE集群启用了Workload Identity，可以不用挂载服务账号密钥文件，直接用默认的应用身份认证Cloud Logging，代码中可以简化为client = google.cloud.logging.Client()，无需指定from_service_account_json参数。

内容的提问来源于stack exchange，提问作者pregot