1

我正在尝试使用 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，“拍卖”：89，“v”：{}}}，{“trans_sum_b ...”：{“trans”：542，“拍卖”：30 , "v": {} } } .....

我更喜欢 json 输出并浪费了几个小时来找出为什么我得到空的 'v' 字段而没有成功。所以我的问题是“到底发生了什么”;-) 如果我的代码是正确的，那么 json 输出有什么问题，我看不到结果。如果我的代码错了，为什么错了，为什么表格输出结果符合我的需要。

4

2 回答 2

0

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

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

另一个问题是它是错误还是功能:-) 如果 Aerospike 的映射类型允许整数键，是否应该有从整数到字符串的自动键转换以满足 JSON 规范？恕我直言，应该有但可能有些人不同意声称地图类型不适用于整数键......

于 2016-05-13T19:16:16.007 回答
0

@user1875438 你的代码是正确的。好像aql有bug。
我的结果和你的一样，使用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-07T18:22:16.773 回答