opsx
02d1bd87a7
=== 一、致命 bug：Promtail 清单第 10 个 %s 缺参数（导致日志采集中断）=== go vet 报："format %s reads arg #10, but call has 9 args"。 模板里 DaemonSet 的 `namespace: %s`（第 9 个）和 `image: %s`（第 10 个） 是两个独立占位符，但 Sprintf 只传了 9 个参数，第 10 个变成 %!s(MISSING)， 整个多文档 YAML 解析失败： "解析 Kubernetes YAML: yaml: line 23: found character that cannot start any token" 而 installDaemonset 是「先删 daemonset/configmap/serviceaccount 再 apply」， 所以每次失败都会把上一份 Promtail 删掉却不重建 → 日志采集中断。 修复： 1) Sprintf 补上 DaemonSet 命名空间参数（第 9 位） 2) 新增 validateManifest()：在删旧资源之前先本地解析校验清单， 校验不过直接中止、不碰任何现有资源 —— 让模板错误永远不会再打断采集 3) 新增回归测试 promtail_manifest_test.go：用平台同一套 YAMLOrJSONDecoder 解析 3 种参数组合，断言各解析出 5 个对象且无 TAB === 二、快捷 LogQL：Ingress 访问日志不再跟随所选命名空间 === 原实现：next = applyLabelFilter(next,'namespace', namespace.trim() || 'ingress-nginx') → 选了 monitor 就生成 {namespace="monitor"} |= "HTTP/"，查不到任何日志 （ingress controller 的 Pod 只在 ingress-nginx 命名空间里） 修复：ingress 模板独立处理 - 固定用 ingress controller 命名空间（ingress-nginx，缺失则回退 ingress） - 不叠加当前选中的 app / pod 过滤（那些属于业务服务） - 结果是 {namespace="ingress-nginx"} |= "HTTP/" === 三、K8s 资源名去掉 opsxloki === ClusterRole / ClusterRoleBinding：opsxloki-promtail → loki-promtail - PromtailDaemonsetYAML 里 3 处 name 全部改名 - uninstallDaemonset 同步改名，并保留对旧名 opsxloki-promtail 的兼容清理， 避免升级后留下孤儿 ClusterRole - 集群侧已实测：新建 loki-promtail，旧的 opsxloki-promtail 已删除 保留的 opsxloki（有兼容性约束，改动会丢数据/掉登录）： - Go module 导入路径 opsxloki/xxx（149 处，纯内部包名） - 数据文件 opsxloki.json（改了读不到历史数据） - 前端 localStorage key opsxloki.auth.* / opsxloki.theme.* 等（改了在线用户掉登录） - Dockerfile 里的 opsxloki 系统用户/二进制名 镜像：lghost/lokistack:latest + v0.1 = sha256:4a5590580cbb
67 lines
1.7 KiB
Go
67 lines
1.7 KiB
Go
package services
|
|
|
|
import (
|
|
"bytes"
|
|
"io"
|
|
"strings"
|
|
"testing"
|
|
|
|
"k8s.io/apimachinery/pkg/util/yaml"
|
|
)
|
|
|
|
// 复现平台 install 时的 YAML 解析，定位非法 token
|
|
func TestPromtailManifestParses(t *testing.T) {
|
|
cases := []struct {
|
|
name string
|
|
labels string
|
|
ns []string
|
|
src string
|
|
inc []string
|
|
}{
|
|
{"空labels+空ns+空来源", "", nil, "", nil},
|
|
{"正常labels", `{"cluster":"pre-k8s"}`, []string{"astralx", "log"}, "k8s.kuboard.cn/name", []string{"cex-spot-api"}},
|
|
{"空labels但带ns", "", []string{"astralx"}, "controller_name", []string{"a", "b"}},
|
|
}
|
|
|
|
for _, c := range cases {
|
|
t.Run(c.name, func(t *testing.T) {
|
|
out := PromtailDaemonsetYAML("log", "http://loki.log.svc.cluster.local:3100", "pre-k8s", c.labels, c.ns, c.src, c.inc)
|
|
|
|
// 1) 扫控制字符
|
|
for i, line := range strings.Split(out, "\n") {
|
|
if strings.ContainsRune(line, '\t') {
|
|
t.Errorf("line %d contains TAB: %q", i+1, line)
|
|
}
|
|
}
|
|
|
|
// 2) 用平台同一套 decoder 解析
|
|
dec := yaml.NewYAMLOrJSONDecoder(bytes.NewReader([]byte(out)), 4096)
|
|
n := 0
|
|
for {
|
|
var raw map[string]interface{}
|
|
if err := dec.Decode(&raw); err == io.EOF {
|
|
break
|
|
} else if err != nil {
|
|
lines := strings.Split(out, "\n")
|
|
// 打印报错行附近
|
|
var from, to int
|
|
if len(lines) > 30 {
|
|
from, to = 1, 30
|
|
} else {
|
|
from, to = 1, len(lines)
|
|
}
|
|
for i := from - 1; i < to && i < len(lines); i++ {
|
|
t.Logf("%3d| %q", i+1, lines[i])
|
|
}
|
|
t.Fatalf("YAML decode failed: %v", err)
|
|
}
|
|
n++
|
|
}
|
|
t.Logf("解析出 %d 个对象", n)
|
|
if n < 4 {
|
|
t.Errorf("期望 >=4 个对象（SA/ClusterRole/CRB/ConfigMap/DaemonSet），实际 %d", n)
|
|
}
|
|
})
|
|
}
|
|
}
|