在我的Python应用程序中,我有一个AppEngine类,为了删除一些不再需要的旧对象,我正在运行一个MapReduce作业。
课程如下:
class UserModel(ndb.Model):
is_backup_object = ndb.BooleanProperty(default=False)
etc.
MapReduce的工作如下:
from mapreduce import operation as op
# Note: userobject is an instantiation of UserModel
def mapreduce_update_userobj