AQL流UDF在输出方式(表格、JSON)不同的情况下产生不同的结果

我正在尝试创建带有UDF的聚合(map | reduce),但一开始就有些问题。在Aerospike中,我有一个集合,其中包含 bin 'u'(二级索引)和 bin 'v',它是一个对象列表(带有交易列表和其他拍卖数据的拍卖)。我有一个流UDF来聚合'v'的内部结构:

function trans_sum_by_years(s)
    local function transform(rec)

        local l = map()
        local x = map()
        local trans, auctions = 0, 0

        for i in list.iterator(rec['v'] or list()) do
            auctions = auctions + 1
            for t in list.iterator(i['t'] or list()) do
                trans = trans + 1
                date = os.date("*t", t['ts'])

                if l[date['year']] ~= nil then
                    l[date['year']] = l[date['year']] + t['price'] * t['qty']
                else
                    l[date['year']] = t['price'] * t['qty']
                end
            end
        end

        x.auctions = auctions
        x.trans = trans
        x.v = l
        return x
    end

    return s : map(transform)

end

问题是,输出非常不同,取决于将输出设置为表格还是json。在第一种情况下,似乎一切都很好:

{"trans":594, "auctions":15, "v":{2010:1131030}}
{"trans":468, "auctions":68, "v":{2011:1472976, 2012:5188}}
......

在第二个输出中,我从内部记录聚合中得到了一个空对象。 { "trans_sum_b...": { "trans": 389, "auctions": 89, "v": {} } }, { "trans_sum_b...": { "trans": 542, "auctions": 30, "v": {} } } .....

我更喜欢json输出,并浪费了几个小时来弄清楚为什么我得到了空的'v'字段,但没有成功。因此,我的问题是“到底发生了什么”;-) 如果我的代码正确,为什么JSON输出出现了问题?如果我的代码有误,为什么错了,表格输出结果是我需要的。

点赞
用户6171361
用户6171361

@user1875438 你的代码是正确的。似乎 aql 工具中存在错误。

当使用 json 模式时,我的结果与你的结果相同,v 字段为空。 我使用了 tcpdump 抓取运行这两个命令时 aerospike-server 的响应,发现它们的响应是相同的,因此我认为 aql 工具中很可能存在错误。

159   0x0050:  0001 0000 0027 0113 0007 5355 4343 4553  .....'....SUCCES
160   0x0060:  5383 a603 7472 616e 7301 a903 6175 6374  S...trans...auct
161   0x0070:  696f 6e73 01a2 0376 81cd 07ce 01         ions...v.....
162 01:57:38.255065 IP localhost.hbci > localhost.57731: Flags [P.], seq 98:128, ack 144, win 42853, options [nop,nop,TS val 976630236 ecr 976630223], length 30
163   0x0000:  4500 0052 55f8 4000 4006 0000 7f00 0001  E..RU.@.@.......

我在这里发布了一个问题 链接

2016-05-07 18:22:16
用户1875438
用户1875438

答案非常简单。但我是Aerospike/Lua的新手,不太相信我的知识,所以我在AQL/UDF区域内搜索错误。问题更为基本,并且干扰了JSON本身的规范。

JSON中的键值必须是字符串!因此 tostring(date['year']) 解决了这个问题。

另一个问题是这是否是一个 bug 还是一个 feature :-) 如果Aerospike的 map 类型允许使用整数键,则是否应该自动将整数键转换为字符串以满足JSON规范?在我看来应该有,但可能有些人持不同意见,声称 map 类型不适用于整数键...

2016-05-13 19:16:16