Async insert on Google App Engine

gistfile1.py

import os
import logging

from google.appengine.ext import db
from google.appengine.api import datastore
from google.appengine.datastore import datastore_rpc

def async_put(entities, **kwargs):
  config = datastore.CreateConfig(**kwargs)
  entities, _ = datastore.NormalizeAndTypeCheck(entities, db.Model)
  entities = [model._populate_internal_entity() for model in entities]

  conn = datastore_rpc.Connection(adapter=datastore.DatastoreAdapter())
  rpcs = conn.async_put(config, entities)
  if os.environ['SERVER_SOFTWARE'].startswith('Dev'):
    rpcs.wait() # To execute the request in dev.

  return rpcs