mongo_mapred.py

import pymongo
from bson.code import Code

myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["mydb"]

mycol = mydb["myColl"]

mylist = [
{ "resource": "oxygen", "city": "Mumbai", "status": "verified"},
{ "resource": "oxygen", "city": "Jaipur", "status": "verified"},
{ "resource": "plasma", "city": "delhi", "status": "not verified"},
{ "resource": "remdesivir", "city": "Jaipur", "status": "verified"},
{ "resource": "plasma", "city": "Banglore", "status": "not verified"},
{ "resource": "ICU Bed", "city": "Mumbai", "status": "verified"},
{ "resource": "oxygen", "city": "Pune", "status": "not verified"}
]
x = mycol.insert_many(mylist)
print(x.inserted_ids)

for x in mycol.find():
    print(x)

map1 = Code("function() { emit(this.resource, 1);}")
reduce1 = Code("function(key, values) {return Array.sum(values)}")
result = mycol.map_reduce(map1, reduce1, "myresult")

newcol = mydb["myresult"]
for y in newcol.find():
    print(y)