Go gojq 怎样编译一次查询后处理多个 JSON 对象

同一条 gojq 查询处理多个 JSON 对象时，可以在循环外调用 Parse 和 Compile，保留得到的 Code；循环内对每个对象调用 code.Run，再消费这次返回的迭代器。复用的是编译结果，不是上一次运行的 Iter。

官方地址：https://github.com/itchyny/gojq

把准备工作留在循环外

面对固定规则的批处理，我更愿意把查询准备和数据处理分成两个部分：规则不变就保留编译对象，输入变化只进入运行部分。这个小项目使用内存里的两份 JSON，不涉及服务部署或外部接口，也不声称已经测得加速比例。

项目固定依赖到文档可对照的 v0.12.19。先在新目录初始化模块，将下一节代码保存为 main.go。

# 初始化独立示例，并固定依赖版本。
go mod init example.com/gojq-batch
go get github.com/itchyny/gojq@v0.12.19

每个对象单独取得迭代器

下面查询提取订单标识与数量，每份 JSON 解码到 any 后交给 Run。我的示例采取遇错即停策略，避免错误输入悄悄进入后续流程；生产系统也可以按业务需要记录失败项。

package main

import (
    "encoding/json"
    "fmt"
    "log"
    "github.com/itchyny/gojq"
)

func main() {
    // 相同规则只解析和编译一次。
    query, err := gojq.Parse("{id: .id, quantity: .quantity}")
    if err != nil { log.Fatal(err) }
    code, err := gojq.Compile(query)
    if err != nil { log.Fatal(err) }
    inputs := []string{
        `{"id":"order-a","quantity":2}`,
        `{"id":"order-b","quantity":5}`,
    }
    for index, source := range inputs {
        var input any
        // 使用JSON解码后的通用类型，避免传入自定义结构体。
        if err := json.Unmarshal([]byte(source), &input); err != nil {
            log.Fatalf("输入%d解码失败：%v", index, err)
        }
        iter := code.Run(input)
        for {
            value, ok := iter.Next()
            if !ok { break }
            // 编译成功也可能遇到运行错误，错误以迭代值返回。
            if err, failed := value.(error); failed {
                log.Fatalf("输入%d查询失败：%v", index, err)
            }
            encoded, err := json.Marshal(value)
            if err != nil { log.Fatal(err) }
            fmt.Println(string(encoded))
        }
    }
}

运行示例时看什么

# 编译运行当前目录示例，观察两份输入对应的输出。
go run .

按代码语义，预期得到 order-a 的数量 2 和 order-b 的数量 5；这里没有提供伪装成本机执行的日志。验收时应检查结果字段和值，不把 JSON 对象键的显示顺序当成业务约束。

我会保留完整 Next 循环，即使当前查询每次只返回一项。以后换成数组展开等查询，一次运行可能没有结果或有多个结果，只取一次会漏数据。

接入批处理后的取舍

这是我会优先采用的简单版本：串行处理，及时消费输出，不先引入共享输入与并发。只有规则相同才复用；改了查询或编译选项，就应重新准备 Code。具体性能还受 JSON 解码、查询复杂度和输出写入影响，不能仅凭少一次 Compile 承诺吞吐提升。

能直接传 map[string]string 吗？

库文档要求使用支持的通用 JSON 类型；对象用 map[string]any，数组用 []any。示例通过解码到 any 获得对应类型。

Run 返回值就是最终结果吗？

不是，它是迭代器。应不断调用 Next，区分结束、结果值与 error。

要不要缓存所有输入结果？

取决于业务，不是编译复用的要求。大量数据时可边读边处理边写，分别限制输入大小与输出数量。

参考：gojq 官方库文档：Compile、Code.Run 与输入类型。