Как конвертировать тип данных в MongoDB?

Question

[inov8]

Имеется коллекция в базе MongoDB с несколькими миллионами вот таких вот документов:

{
  "block": 3058293,
  "timestamp": {
    "$date": {
      "$numberLong": "1547460009000"
    }
  },
  "trx_id": "4b0ade8dc42ce9c3b4b8886df526b91955d95f67",
  "type": "receive_award",
  "obj": {
    "initiator": "redress",
    "receiver": "redress",
    "custom_sequence": 0,
    "memo": "so beautiful",
    "shares": "21.408084 SHARES"
  },
  "__v": 0
}

Необходимо рассчитать сумму всех значений "shares". Сам я, как говорится, только учусь. Подумал, что, возможно, есть какой-то способ конвертировать тип данных (в нашем случае это string для "21.408084 SHARES") в float. Очень желательно обойтись без внесения изменений в саму БД.

П. С. Работаю через pymongo.

Answer 1

[Александр Романов]

Что то вроде этого может сработать:

db.test.aggregate([
    {
        "$addFields":{
            "sharesFloat": {
                "$function": {
                    "body": "function (shares) { if (!shares) {return 0}; return parseFloat(shares.split(' ')[0])}",
                    "args": ["$obj.shares"],
                    "lang": "js"
                }
            }
        }
    },
    {
        "$group": {
            "_id": None,
            "sum": {
                "$sum": "$sharesFloat"
            }
        }
    }
])

Comments

[inov8]

В `pymongo` в ответ выдало `[{'_id':None, 'sum':nan}]`.

[Александр Романов]

inov8, вам надо изменить эту функцию под ваши данные

function (shares) { if (!shares) {return 0}; return parseFloat(shares.split(' ')[0])}

сейчас она работает только если там все данные такого вида: "21.408084 SHARES"