incrementaccountswithtask.py 文件源码

def IncrementAccountsWithTaskExperiment():
    def Go():
        def AddFreeCredit(creditamount):
            @task
            def ProcessOnePage(cursor):
                accounts, cursor, kontinue = Account.query().fetch_page(
                    100, start_cursor = cursor
                )
                for account in accounts:
                    account.balance += creditamount
                ndb.put_multi(accounts)
                if kontinue:
                    ProcessOnePage(cursor)
            ProcessOnePage(None)
        AddFreeCredit(10)
    return "Increment Accounts With Task", Go