[[processors.starlark]]
    namepass = ["${TEMPLATE_NAME}"]
    alias = "${TEMPLATE_NAME}@starting"
    order = ${order@54}
    source = '''
load("logging.star", "log")
load("json.star", "json")
def apply(metric):
    log.info("metricStart:"+json.encode(metric))
    return metric
'''

# 列出 prod 命名空间中名称包含 connect 的 Pod
kubectl -n prod get pods | grep -i connect
#       |      |                └── -i connect：忽略大小写,过滤含 connect 的行
#       |      └── get pods：列出 Pod 资源列表
#       └── -n prod：指定目标命名空间
 
# 查看 Pod 状态、重启次数及所在节点
kubectl -n prod get pods -o wide | grep -i connect
#                         └── -o wide：额外显示节点名称、IP 等附加列信息
 
# 实时跟踪指定 Pod 的日志输出（替换为实际 Pod 名称）
kubectl -n prod logs -f <connect-pod-name>
#               |    └── -f / --follow：持续流式输出新日志,Ctrl+C 退出
#               └── logs：查看容器标准输出日志
 
# 限制日志输出行数与时间范围,减少噪音
kubectl -n prod logs --tail=200 --since=1h <connect-pod-name>
#               |    |          └── --since=1h：只输出最近 1 小时内的日志
#               |    └── --tail=200：从末尾截取最多 200 行
#               └── logs：查看容器日志
 
# 无日志或日志异常时,查看 Pod 详情与事件
kubectl -n prod describe pod <connect-pod-name>
#               |        └── pod <name>：要查看的目标 Pod 名称
#               └── describe：输出资源完整描述信息与关联事件列表
 
kubectl -n prod get events --sort-by=.lastTimestamp | grep <connect-pod-name>
#               |               └── --sort-by=.lastTimestamp：按最近触发时间升序排列
#               └── get events：列出命名空间内所有 K8s 事件

# 示例 1:排除设备 10000,仅保留 JuIzTd8MQ0 相关数据
kubectl -n prod logs -f connector-24043-79b89ffc5f-mcz6p | grep -v '10000' | grep 'JuIzTd8MQ0'
#                                                                |              └── 'JuIzTd8MQ0'：保留包含该设备标识的行
#                                                                └── -v '10000'：反向过滤,排除含 10000 的行
 
# 示例 2:仅查看报错日志
kubectl -n prod logs -f connector-24043-79b89ffc5f-mcz6p | grep 'E!'
#                                                                └── 'E!'：Telegraf 错误日志行前缀
 
# 示例 3:查看某设备类标识的采集数据
kubectl -n dev logs -f connector-90-ffc45fcb5-qgl8s | grep '9DQpiyceGi'
#                                                           └── '9DQpiyceGi'：设备类唯一标识

{
  "fields": {
    "0x0001:BOOL": 0,
    "4x0001:INT": 2,
    "4x0005:REAL": 0.00000000000000000000000000000000000000009183689745645554,
    "4x0007:INT": 1
  },
  "name": "9DQpiyceGi",
  "tags": {
    "device_id": "200709",
    "name": "9DQpiyceGi",
    "slave_id": "1"
  },
  "time": 1774329166000000000
}

{
  "fields": {
    "4x0005:REAL": 0.00000000000000000000000000000000000000009183689745645554,
    "4x0007:INT": 1
  },
  "name": "9DQpiyceGi",
  "tags": { "device_id": "200709", "name": "9DQpiyceGi", "slave_id": "1" },
  "time": 1774329166000000000
}

{
  "fields": {
    "0x0001:BOOL": 0,
    "4x0001:INT": 2
  },
  "name": "9DQpiyceGi",
  "tags": { "device_id": "200709", "name": "9DQpiyceGi", "slave_id": "1" },
  "time": 1774329166000000000
}

# 列出 prod 命名空间下名称以 device- 开头的 Pod
kubectl get pods -n prod | grep '^device-'
#                          └── '^device-'：正则表达式,仅匹配以 device- 开头的行
 
# 实时跟踪目标 Pod 日志（替换为实际 Pod 名称）
kubectl -n prod logs -f <device-pod-name>
#               |    └── -f：持续流式输出新日志，Ctrl+C 退出
#               └── logs：查看容器标准输出日志
 
# 按设备唯一标识或关键字过滤日志（示例：123456）
kubectl -n prod logs -f device-service-8f7885b79-2fr9v | grep '123456'
#                                                              └── '123456'：替换为实际设备唯一标识
 
# 无明显输出或错误时,核查 Pod 事件与容器状态
kubectl -n prod describe pod <device-pod-name>
#               |        └── pod <name>：要查看的目标 Pod 名称
#               └── describe：输出资源完整描述信息与关联事件列表
 
# 按上下文行数筛选日志（示例：匹配行前后各 5 行）
kubectl -n prod logs -f device-service-8f7885b79-2fr9v | grep -A 5 '123456'
#                                                              |   └── '123456'：过滤关键字
#                                                              └── -A 5：输出匹配行及其之后 5 行
 
kubectl -n prod logs -f device-service-8f7885b79-2fr9v | grep -B 5 '123456'
#                                                              └── -B 5：输出匹配行及其之前 5 行
 
kubectl -n prod logs -f device-service-8f7885b79-2fr9v | grep -C 5 '123456'
#                                                              └── -C 5：输出匹配行前后各 5 行（等价于 -A 5 -B 5）

# 查看 kafka 命名空间的 Pod,确认 broker 正常运行
kubectl get pods -n kafka
 
# 进入 Kafka broker Pod 的交互式终端（将 kafka-0 替换为实际 Pod 名称）
kubectl exec -n kafka -it kafka-0 -- bash
#            |        |      |     |  └── bash：在容器内启动的 shell 程序
#            |        |      |     └── --：分隔 kubectl 参数与容器内命令
#            |        |      └── kafka-0：目标 Pod 名称
#            |        └── -it：-i 保持标准输入开放，-t 分配伪终端（TTY）
#            └── exec：在运行中的容器内执行命令
 
# 若镜像不带 bash,可改用 sh:
# kubectl exec -n kafka -it kafka-0 -- sh
 
# 进入 Kafka CLI 脚本目录（不同镜像路径可能不同）
cd /opt/bitnami/kafka/bin/   # Bitnami 镜像；通用镜像改用 /opt/kafka/bin/
 
# 实时消费主题最新消息,按设备 ID 过滤
sh kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 \
    --topic ods.1.data | grep '48985'
#   |      |             └── grep '48985'：过滤包含该设备 ID 的消息行
#   |      └── --topic ods.1.data：指定要消费的 Kafka 主题名称
#   └── --bootstrap-server 127.0.0.1:9092：Broker 连接地址（Pod 内使用本地 127.0.0.1）
 
# 从头消费历史消息（数据量大时速度较慢）
sh kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 \
    --topic ods.1.data --from-beginning | grep '48985'
#                      └── --from-beginning：从分区最早 offset 开始消费（而非最新位置）
 
# 列出集群中所有主题,确认目标主题是否存在
sh kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --list
#                  |                                  └── --list：输出所有主题名称列表
#                  └── --bootstrap-server 127.0.0.1:9092：Broker 地址
 
# 查看目标主题的分区、副本与 leader 状态
sh kafka-topics.sh --bootstrap-server 127.0.0.1:9092 \
    --describe --topic ods.1.data
#   |          └── --topic ods.1.data：指定要查看的主题名称
#   └── --describe：输出主题详情（分区数、副本分配、ISR 列表、leader）