使用Kafka Magic Tool的JavaScript查询JSON消息无结果问题排查

核心错误：未解析JSON字符串 #

你的消息结构里，Details.Value是转义后的JSON字符串（例如"{\"EmailAddress\":\"test@test.com\",\"SystemId\":\"5\"}"），并非可直接访问的JavaScript对象。直接用.EmailAddress访问会返回undefined，自然无法匹配目标值。

次要问题与风险 #

• 循环变量i未用let/const声明，会成为全局变量，批量处理时可能引发逻辑混乱。
• 未做字段存在性检查，若某条消息缺失Event/Details/Value字段，会直接抛出错误中断脚本。
• 未处理JSON解析异常，若Value格式不合法，整个查询会崩溃。

修正后的代码 #

function findItem(items) {
    // 先验证输入是否为有效数组
    if (!items || !Array.isArray(items)) {
        console.log('failed: 输入不是有效消息数组');
        return;
    }
    
    for (let i = 0; i < items.length; i++) {
        const currentMsg = items[i];
        // 用可选链安全访问嵌套字段，避免字段缺失报错
        const valueStr = currentMsg?.Event?.Details?.Value;
        
        if (!valueStr) {
            console.log(`第${i}条消息缺少必要字段，跳过`);
            continue;
        }
        
        try {
            // 将JSON字符串解析为JS对象
            const valueObj = JSON.parse(valueStr);
            if (valueObj.EmailAddress === "test@test.com") {
                console.log('found');
                return; // 找到匹配项后直接终止查询
            }
        } catch (err) {
            console.log(`第${i}条消息解析失败: ${err.message}`);
        }
    } 
    console.log('fail 2');
}

return findItem(Context.Message);

关键修正点说明 #

1. 新增输入有效性校验，确保处理的是合法数组。
2. 用let声明循环变量，避免全局变量污染。
3. 使用可选链?.安全访问嵌套字段，防止字段缺失导致脚本中断。
4. 通过JSON.parse()将Value字符串解析为对象，才能正常访问EmailAddress属性。
5. 加入try-catch捕获JSON解析异常，保证单条消息格式错误不影响整体查询。

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