AQL与流UDF的结果不同,具体取决于输出样式(表、json)



我试图用UDF创建聚合(map|reduce),但一开始就出现了问题。在Aerospike中,我有一个带有bin‘u’(二级索引)和bin‘v’的集合,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,"拍卖":89,"v":{}}},{"trans_sum_b…":{"trans":542,"拍卖":30,"v":{}}}….

我更喜欢json输出,浪费了几个小时来找出为什么我没有成功地得到空的"v"字段。所以我的问题是"到底发生了什么";-)如果我的代码是正确的,json输出有什么问题,我看不到结果。如果我的代码是错误的,为什么它是错误的以及为什么表输出的结果是我需要的。

@user1875438您的代码是正确的。aql中似乎有bug
我的结果和你的结果一样,当使用json模式时,v的字段是空的。在运行这两个命令时,我使用tcpdump获取了Aeropike服务器的响应,发现响应是相同的,所以我认为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.@.@.......

我刚刚在这里发布了一期。

答案非常简单。但我是Aerospike/Lua的新手,我不相信自己的知识,所以我到处寻找错误,但在AQL/UDF区域除外。这个问题更为根本,并且会干扰JSON本身的规范。

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

另一个问题是,这是一个bug还是一个功能:-)如果Aerospike的映射类型允许整数键,是否应该自动将整数键转换为字符串键以满足JSON规范?IMHO应该有,但可能有些人不同意声称映射类型不适用于整数键。。。

最新更新