feat: 【产品功能】补充cmdb元数据 --story=121426827

bklog/apps/log_databus/constants.py

@@ -46,6 +46,32 @@
 
 DEFAULT_RETENTION = 14
 
+# 节点管理支持的cmdb变量
+CC_HOST_FIELDS = [
+    "bk_host_id",
+    "bk_agent_id",
+    "bk_cloud_id",
+    "bk_addressing",
+    "bk_host_innerip",
+    "bk_host_outerip",
+    "bk_host_innerip_v6",
+    "bk_host_outerip_v6",
+    "bk_host_name",
+    "bk_os_type",
+    "bk_os_name",
+    "bk_os_bit",
+    "bk_os_version",
+    "bk_cpu_module",
+    "operator",
+    "bk_bak_operator",
+    "bk_isp_name",
+    "bk_biz_id",
+    "bk_province_name",
+    "bk_state",
+    "bk_state_name",
+    "bk_supplier_account",
+    "bk_cpu_architecture",
+]
 
 class VisibleEnum(ChoicesEnum):
     # 当前业务可见

bklog/apps/log_databus/handlers/collector.py

@@ -83,6 +83,7 @@
     TargetNodeTypeEnum,
     TopoType,
     WorkLoadType,
+    CC_HOST_FIELDS,
 )
 from apps.log_databus.exceptions import (
     AllNamespaceNotAllowedException,
@@ -841,6 +842,14 @@ def update_or_create(self, params: dict) -> dict:
         is_display = params.get("is_display", True)
         params["params"]["encoding"] = data_encoding
         params["params"]["run_task"] = params.get("run_task", True)
+
+        # cmdb元数据补充
+        extra_labels = params["params"].get("extra_labels")
+        if extra_labels:
+            for item in extra_labels:
+                if item["key"] in CC_HOST_FIELDS:
+                    item["value"] = "{{cmdb_instance.host." + item["key"] + "}}"
+
         # 1. 创建CollectorConfig记录
         model_fields = {
             "collector_config_name": collector_config_name,