Как правильно написать mapReduce для MongoDB?

Question

[Роман]

Добрый день. Помогите пожалуйста разобраться. Есть коллекция bankGuarantee
пишу вот так mapReduce:

var map = function(){
    var key = {
        regNum: this.regNumber,
        bank_name: this.bank.shortName,
        bank_inn: this.bank.INN,
        year: this.guarantee.guaranteeDate.getFullYear(),   //Дата выдачи БГ.Год
        month: this.guarantee.guaranteeDate.getMonth(),     //Дата выдачи БГ.Месяц
        category: getCategory(this.guarantee.guaranteeAmount)
    };
    
    emit(key, {count:1, bg_amount: this.guarantee.guaranteeAmount /*,Сумма контракта*/});
}

var reduce = function(key, values){
    var bg_count = 0;
    var bg_amount = 0;
    
	values.forEach(function(value) {
		bg_count += value['count'];
		bg_amount += value['bg_amount'];
	});
	
	return {count: bg_count, amount: bg_amount};
}

db.bankGuarantee.mapReduce(map, reduce, {out: 'bg_stats'});

не могу понять некоторые моменты:
1. в ключе есть поле regNum: this.regNumber, но оно мне не нужно в ключе, мне нужно, чтобы для всех ключей count считался по среднему, типа avg в sql если в ключе документ с одним и тем же кодом встречается n раз, то count по этим документам должен равняться одному, как это правильно написать?
2. year: this.guarantee.guaranteeDate.getFullYear() поле guaranteeDate в некоторых документах может или отсутствовать или называться по другому, как лучше обработать такую ситуацию?
3. Еще и год в результате возвращается как Double как сделать, чтобы целое число было?

Answer 1

[longclaps]

если в ключе документ с одним и тем же кодом встречается n раз, то count по этим документам должен равняться одному
Что ты имеешь в виду, Роман?

Comments

[Роман]

например:
есть документ с кодом один, потом есть документ новой версии с таким же кодом, но с другой версией и мне нужно, чтобы count по этим документам посчитался как 1

[longclaps]

Роман: Термин "код" что означает? Это regNumber или что-то другое?

[Роман]

да regNumber

[longclaps]

Роман:
Слушай, если тебе нужен ответ, потрудись сформулировать вопрос так, чтобы его можно было понять без кучи уточнений.
Если в ключе есть поле regNum: this.regNumber, но оно мне не нужно в ключе - кто тебя заставил его туда впихнуть?
Выпиши тупо формулу искомого результата любым однозначно понятным способом.
Знаешь ли ты другие варианты названия поля guaranteeDate?
как лучше обработать такую ситуацию? - задай этот вопрос тому, кто дал тебе эту коллекцию.

[Роман]

longclaps: в ключ я его запихиваю потому что по этому коду я определяю count = 1
но в итоговой выборке мне нужно получить ключ без этого поля, чтобы все остальные поля были, а этого не было и посчитать сумму count-ов

[Роман]

т.е. по regNum я получаю кол-во документов, 1 regNum - 1документ, а в итоге мне нужно получить их сумму

[longclaps]

Роман: Выпиши тупо формулу.

[longclaps]

Роман: Роман, у тебя когнитивные затруднения?
Ты чего хочешь: count(distinct(regNum)) или count(distinct(key == {regNum, bank_name,...}))?
Выпиши тупо формулу.

[Роман]

longclaps: key :{ bank_name,...}:sum(count(distinct(regNum)))

[longclaps]

Это, штоле:

db.bankGuarantee.aggregate([
    {
        $group: {
            _id: {
                "regNum": "$regNumber",
                "bank_name": "$shortName",
                "bank_inn": "$bank.INN",
                // дальше сам пиши
            },
            "cnt": {$sum: 1}
        }
    }
]);

[Роман]

longclaps: ну почти, только не sum, а avg и потом еще раз сгрупировать результат по всем ключам кроме regNum и просуммировать cnt.
только сегодня до aggregation добрался

[longclaps]

Ты уже который раз повторяешь avg, но {$avg:1} == 1
Сгруппировать пожалуйста.

[longclaps]

Роман:

db.bankGuarantee.aggregate([
    {
        $group: {
            _id: {
                "regNum": "$regNumber",
                "bank_name": "$shortName",
                "bank_inn": "$bank.INN",
                // дальше сам пиши
            },
            "cnt": {$sum: 1}
        }
    },
    {
        $group: {
            _id: {
                "bank_name": "$_id.bank_name",
                "bank_inn": "$_id.bank_inn",
            },
            "cnt": {$sum: "$cnt"},
            "cnt_regNum": {$sum: 1}
        }
    },
    {
        $project: {
            "avg": {$divide: ["$cnt", "$cnt_regNum"]}
        }
    }
]);

[Роман]

longclaps:

{$avg:1} == 1

именно, т.к. с одним regNum может быть несколько документов, типа разных версий, а мне каждый distinct(regNumber) нужно посчитать как 1

[Роман]

longclaps: спасибо