【发布时间】:2021-03-08 01:50:52
【问题描述】:
我在 Javascript 脚本文件中实现了我的 MongoDB 数据库的 MapReduce 作业。我已经从命令行和 Mongo shell (load("MR_stack.js")) 对其进行了测试。现在我在一个更大的应用程序中使用 Pymongo 来访问 Mongo 数据库。如何在 Pymongo 中执行我的 MR_stack.js 脚本?
【问题讨论】:
我在 Javascript 脚本文件中实现了我的 MongoDB 数据库的 MapReduce 作业。我已经从命令行和 Mongo shell (load("MR_stack.js")) 对其进行了测试。现在我在一个更大的应用程序中使用 Pymongo 来访问 Mongo 数据库。如何在 Pymongo 中执行我的 MR_stack.js 脚本?
【问题讨论】:
数据库对象有一个eval方法:
http://api.mongodb.org/python/current/api/pymongo/database.html
【讨论】:
好吧,您最喜欢的选择是阅读现有文档:
【讨论】:
从 bson 导入二进制,代码
你可以使用这个库来运行你的 javascript mapreduce 代码,像这样
map = code("""your mapreduce code""")
reducer = code("""your mapreduce code""")
emp = db.orders.map_reduce(mapper, reducer, "moid_details")
【讨论】: