塞式集團通過

我塞鑲有以下結構箱：項目，時間戳，數量，價格，折扣塞式集團通過

我試圖實現以下等價的SQL

SELECT item, sum(qty), sum(price), sum(discount) 
FROM items 
WHERE timestamp between 20150101000000 and 201501GROUP BY item

我試圖寫入以下LUA腳本但是在執行腳本我獲得以下錯誤

Error: (1) AEROSPIKE_ERR_SERVER : "UDF: Execution Error 2 : /opt/aerospike /usr/udf/lua/aggregateByItem.lua:21: attempt to index a nil value"

可以解決這個

別人的幫助

local function aggregate_item_stats(itemMap,rec) 
    local item = rec.item 
    local innerMap = itemMap[item] 
    if innerMap == nil then 
     innerMap = {qty = 0, price = 0, discount = 0} 
    end 
    innerMap.qty = innerMap.qty + (tonumber(rec.qty) or 0); 
    innerMap.price = innerMap.price + (tonumber(rec.price) or 0); 
    innerMap.discount = innerMap.discount + (tonumber(rec.discount) or 0); 
    itemMap[item] = innerMap 
    return itemMap 
end 

local function fn_merge(a,b) 
    a.qty = a.qty + b.qty 
    a.price = a.price + b.price 
    a.discount = a.discount + b.discount 
    return a 
end 
local function reduce_values(a, b) 
    return map.merge(a, b, fn_merge) 
end 
function highUsageReport(stream) 
return stream : aggregate(itemMap{}, aggregate_item_stats) : reduce(reduce_values) 
end

來源

2015-02-05 tabreaz

除了上面的錯誤，啓用udf調試後，我得到以下錯誤：錯誤：（1）AEROSPIKE_ERR_SERVER：「UDF：執行錯誤2：/opt/aerospike/sys/udf/lua/stream_ops.lua:175：嘗試調用upvalue'f'（一個零值）「 ' – tabreaz 2015-02-05 17:21:10

工作代碼，主要的變化是在第4行

如果innerMap ==零然後
到
如果innerMap == null，則

local function aggregate_item_stats(itemMap, rec) 
local key = rec.item 
local innerMap = itemMap[key] 
if innerMap == null then 
    innerMap = map {qty = 0, price = 0, discount = 0} 
end 
innerMap.qty = (tonumber(rec.qty) or 0) 
innerMap.price = innerMap.price + tonumber(rec.price or 0) 
innerMap.discount = innerMap.discount + tonumber(rec.discount or 0) 
itemMap[key] = innerMap 
return itemMap 
end 

local function reduce_values(a, b) 
return map.merge(a, b, fn_merge) 
end 

local function fn_merge(a, b) 
a.qty = tonumber(a.qty) + tonumber(b.qty) 
a.price = tonumber(a.price) + tonumber(b.price) 
a.discount = tonumber(a.discount) + tonumber(b.discount) 
return a 
end 

function highUsageReport(stream) 
return stream : aggregate(map(), aggregate_item_stats) 
    : reduce(reduce_values) 
end

來源

2015-02-05 19:25:46 tabreaz

塞式集團通過

回答

相關問題