dbtransfer.py 文件源码

def exportItems( module, target, importKey, startCursor, endCursor):
    Skel = skeletonByKind( module )
    query = Skel().all().cursor( startCursor, endCursor )

    for item in query.run(250):
        flatItem = DbTransfer.genDict( item )
        formFields = {
            "e": pickle.dumps(flatItem).encode("HEX"),
            "key": importKey
        }
        result = urlfetch.fetch(        url=target,
                                        payload=urllib.urlencode(formFields),
                                        method=urlfetch.POST,
                                        headers={'Content-Type': 'application/x-www-form-urlencoded'})

    if startCursor == endCursor:
        try:
            utils.sendEMailToAdmins("Export of kind %s finished" % module,
                                    "ViUR finished to export kind %s to %s.\n" % (module, target))
        except: #OverQuota, whatever
            pass


# --- import ---