Funciones de Datastore

Nota: Se recomienda enfáticamente que los desarrolladores que compilan aplicaciones nuevas usen la biblioteca cliente de NDB, ya que ofrece muchos beneficios en comparación con esta biblioteca cliente, como el almacenamiento automático de entidades en caché a través de la API de Memcache. Si actualmente usas la Biblioteca cliente de la base de datos más antigua, lee la Guía de migración de la base de datos a NDB.

Las funciones descritas en esta página se definen en el paquete google.appengine.ext.db.

Funciones

allocate_ids (model, count)

Asigna un lote de ID en Datastore para una combinación de similares y superiores de Datastore.

Los ID asignados de esta manera no serán utilizados por el generador de secuencias de ID automáticos de Datastore y se podrán usar en claves de entidad sin que se generen conflictos.

Argumentos

model
La clave de modelo para la cual se asignará un lote de ID. Esta es una clave normal, pero solo el similar y superior de la clave son necesarios para determinar la secuencia de ID que se utilizará.
count
La cantidad de ID que se asignará.

Muestra una tupla del primer y el último ID que asigna. Por ejemplo, si asigna 10 ID mediante esta función, se los mostrará un valor en el formato (1, 10), pero no se presentará una lista completa de los ID creados.

Ejemplo de la asignación y el uso de ID:

# allocate for MyModel without an instance
handmade_key = db.Key.from_path('MyModel', 1)
first_batch = db.allocate_ids(handmade_key, 10)
first_range = range(first_batch[0], first_batch[1] + 1)

# or allocate using an existing key
model_instance = MyModel.all().get()
second_batch = db.allocate_ids(model_instance.key(), 10)
second_range = range(second_batch[0], second_batch[1] + 1)

# and then use them! woo!
my_id = second_range.pop(0)
new_key = db.Key.from_path('MyModel', my_id)
new_instance = MyModel(key=new_key)
new_instance.put()
assert new_instance.key().id() == my_id

# the Datastore will not assign ids in first_batch or second_batch
another_instance = MyModel()
another_instance.put()
assert another_instance.key().id() not in first_range
assert another_instance.key().id() not in second_range
allocate_ids_async (model, count)

Asigna de forma asíncrona un lote de ID en Datastore para una combinación de similares y superiores de Datastore.

Esta función es idéntica a allocate_ids(), excepto que muestra un objeto asíncrono. Puedes llamar a get_result() en el valor de muestra para realizar el bloqueo en la llamada y mostrar el resultado.

Argumentos

model
Una instancia de db.Model, una clave o una string que se entrega como una plantilla que especifica la secuencia de ID en la cual se asignarán los ID. Los identificadores mostrados solo deben usarse en entidades con el mismo superior (si existe) y del mismo grupo de similares que esta clave.
count
La cantidad de ID que se asignará.

Muestra una tupla del primer y el último ID que asigna. Por ejemplo, si asigna 10 ID mediante esta función, se los mostrará en el formato (1, 10), pero no se presentará una lista completa de los ID creados.

allocate_id_range (model, start, end, **kwargs)

Asigna un rango de ID con extremos específicos. Una vez que se han asignado estos ID, puede vincularlos manualmente a las entidades recién creadas.

El asignador automático de ID de Datastore nunca indica una clave que ya ha sido asignada (ya sea a través de la asignación automática de ID o mediante una llamada explícita a allocate_ids). Como resultado, las entidades escritas en el rango de claves dado nunca se reemplazarán. Sin embargo, la escritura de entidades con claves asignadas manualmente en este rango puede reemplazar las entidades existentes (o las nuevas entidades escritas por una solicitud separada), en función del estado de rango de claves mostrado.

Utiliza esta función solo si tienes un rango de ID numéricos existente que deseas reservar (por ejemplo, entidades de carga masiva que ya tienen ID). Si no te importa qué ID recibes, es mejor que utilices allocate_ids().

Argumentos

model
Una instancia de db.Model, una clave o una string que se entrega como una plantilla que especifica la secuencia de ID en la cual se asignarán los ID. Los identificadores mostrados solo deben usarse en entidades con el mismo superior (si existe) y del mismo grupo de similares que esta clave.
start
El primer ID numérico que se asignará.
end
El último ID numérico que se asignará.

Muestra uno de los valores siguientes: KEY_RANGE_EMPTY, KEY_RANGE_CONTENTION, KEY_RANGE_COLLISION. Si no es KEY_RANGE_EMPTY, esto representa un problema potencial con el uso de un rango de claves asignadas.

create_transaction_options (**kwargs)

Crea un objeto de opciones de transacción (clase TransactionOptions) para controlar la ejecución de la transacción. Debes pasar el objeto resultante como primer argumento a la función run_in_transaction_options().

Argumentos

propagation
Qué hacer si esta función transaccional se llama desde otra transacción:
ALLOWED
Si ya está en una transacción, continúa usándola; caso contrario, inicia una.

Nota: Si una función que utiliza esta política genera una excepción, probablemente no sea seguro detectar la excepción y confirmar la transacción externa; la función puede haber dejado la transacción externa en un estado incorrecto.

MANDATORY
Continúa en la transacción existente, si la hubiere; caso contrario, genera una excepción BadRequestError.

Nota: Si una función que utiliza esta política genera una excepción, probablemente no sea seguro detectar la excepción y confirmar la transacción externa; la función puede haber dejado la transacción externa en un estado incorrecto.

INDEPENDENT
Crea una nueva transacción, pausando cualquier transacción existente.

Nota: Una función que usa esta política no debe mostrar ninguna entidad leída en la nueva transacción, ya que las entidades no son consistentemente transaccionales con la transacción externa.

NESTED
(Aún no se admite) Crea una transacción anidada dentro de una existente.
xg
Si el valor es True, permite transacciones entre grupos (XG). Si se establece un valor no booleano, se genera una excepción BadArgumentError.
retries
Número de reintentos que se realizan en caso de falla de confirmación de la transacción.
deadline
El tiempo máximo en segundos que se esperará que el almacén de datos muestre un resultado antes de anular con un error. Acepta un valor de número entero o punto flotante. No es posible configurar un valor más alto que el predeterminado (60 segundos), pero sí puedes establecer un tiempo menor para asegurarte de que una operación específica falle rápido (por ejemplo, con el objetivo de mostrar una respuesta más rápida al usuario, reintentar la operación, probar con otra o agregarla a la lista de tareas en cola).

El siguiente ejemplo crea las opciones para una transacción de grupo cruzado (XG):

from google.appengine.ext import db

xg_on = db.create_transaction_options(xg=True)

def my_txn():
  x = MyModel(a=3)
  x.put()
  y = MyModel(a=7)
  y.put()

db.run_in_transaction_options(xg_on, my_txn)
delete (models, deadline=60)

Borra una o más instancias de modelo desde Datastore.

Argumentos

models
Una instancia de modelo, una clave de entidad o una lista (o incluso otro iterable) de instancias de modelo o claves de entidad que se borrarán.
deadline
El tiempo máximo en segundos que se esperará que el almacén de datos muestre un resultado antes de anular con un error. Acepta un valor de número entero o punto flotante. No es posible configurar un valor más alto que el predeterminado (60 segundos), pero sí puedes establecer un tiempo menor para asegurarte de que una operación específica falle rápido (por ejemplo, con el objetivo de mostrar una respuesta más rápida al usuario, reintentar la operación, probar con otra o agregarla a la lista de tareas en cola).

Al igual que con put(), si se dan varias claves, estas pueden estar en más de un grupo de entidades.

Siempre se generará una excepción si se produce algún error durante la operación, incluso si algunas de las entidades realmente se borraron. Si la llamada se muestra sin generar una excepción, entonces todas las entidades fueron borradas correctamente.

Precaución: Borrar varias entidades en una sola operación no garantiza que las eliminaciones se realicen de forma atómica, a menos que la operación se realice dentro de una transacción. Otros procesos que consultan a Datastore pueden presentar resultados incoherentes aun cuando la consulta se realice con una coherencia sólida.

delete_async (models, deadline=60)

Borra de manera asíncrona una o más instancias de modelo desde Datastore.

Esta función es idéntica a delete(), excepto que muestra un objeto asíncrono. Puedes llamar a get_result() en el valor de muestra para realizar el bloqueo en la llamada.

Argumentos

models
Una instancia de modelo, una clave de entidad o una lista (o incluso otro iterable) de instancias de modelo o claves de entidad que se borrarán.
deadline
El tiempo máximo en segundos que se esperará que el almacén de datos muestre un resultado antes de anular con un error. Acepta un valor de número entero o punto flotante. No es posible configurar un valor más alto que el predeterminado (60 segundos), pero sí puedes establecer un tiempo menor para asegurarte de que una operación específica falle rápido (por ejemplo, con el objetivo de mostrar una respuesta más rápida al usuario, reintentar la operación, probar con otra o agregarla a la lista de tareas en cola).

Al igual que con put(), si se dan varias claves, estas pueden estar en más de un grupo de entidades.

Esta función muestra un objeto que te permite para realizar el bloqueo en el resultado de la llamada.

Siempre se generará una excepción si se produce algún error durante la operación, incluso si algunas de las entidades realmente se borraron. Si la llamada se muestra sin generar una excepción, entonces todas las entidades fueron borradas correctamente.

Precaución: Borrar varias entidades en una sola operación no garantiza que las eliminaciones se realicen de forma atómica, a menos que la operación se realice dentro de una transacción. Otros procesos que consultan a Datastore pueden presentar resultados incoherentes aun cuando la consulta se realice con una coherencia sólida.

get (keys, read_policy=STRONG_CONSISTENCY, deadline=60)

Recupera las instancias de modelo específicas con las claves dadas desde Datastore.

Argumentos

claves
La clave de la entidad que se recuperará, una representación de string de la clave o una lista de claves o sus representaciones de string.
read_policy
La política de lectura que especifica el nivel deseado de coherencia de datos:
STRONG_CONSISTENCY
Garantiza los resultados más recientes, pero se limita a un solo grupo de entidad.
EVENTUAL_CONSISTENCY
Puede abarcar varios grupos de entidad, pero a veces puede mostrar resultados obsoletos. Por lo general, las consultas de coherencia eventual se ejecutan más rápido que las de coherencia sólida, pero no se garantiza.

Nota: Las consultas globales (no las principales) omiten este argumento.

deadline
El tiempo máximo en segundos que se esperará que el almacén de datos muestre un resultado antes de anular con un error. Acepta un valor de número entero o punto flotante. No es posible configurar un valor más alto que el predeterminado (60 segundos), pero sí puedes establecer un tiempo menor para asegurarte de que una operación específica falle rápido (por ejemplo, con el objetivo de mostrar una respuesta más rápida al usuario, reintentar la operación, probar con otra o agregarla a la lista de tareas en cola).

Si keys consiste en una sola clave (o su representación de string), este método muestra la instancia del modelo asociada con la clave si la clave existe en Datastore; de lo contrario, muestra None. Si keys es una lista, el valor que se muestra es una lista correspondiente de instancias del modelo, con valores None en los que no existe una entidad para una clave determinada.

Consulta también Model.get().

get_async (keys, read_policy=STRONG_CONSISTENCY, deadline=60)

Recupera de forma asíncrona las instancias de modelo especificadas desde Datastore.

Esta función es idéntica a get(), excepto que muestra un objeto asíncrono. Puedes llamar a get_result() en el valor de muestra para realizar el bloqueo en la llamada y mostrar los resultados.

Argumentos

claves
La clave de la entidad que se recuperará, una representación de string de la clave o una lista de claves o sus representaciones de string.
read_policy
La política de lectura que especifica el nivel deseado de coherencia de datos:
STRONG_CONSISTENCY
Garantiza los resultados más recientes, pero se limita a un solo grupo de entidad.
EVENTUAL_CONSISTENCY
Puede abarcar varios grupos de entidad, pero a veces puede mostrar resultados obsoletos. Por lo general, las consultas de coherencia eventual se ejecutan más rápido que las de coherencia sólida, pero no se garantiza.

Nota: Las consultas globales (no las principales) omiten este argumento.

deadline
El tiempo máximo en segundos que se esperará que el almacén de datos muestre un resultado antes de anular con un error. Acepta un valor de número entero o punto flotante. No es posible configurar un valor más alto que el predeterminado (60 segundos), pero sí puedes establecer un tiempo menor para asegurarte de que una operación específica falle rápido (por ejemplo, con el objetivo de mostrar una respuesta más rápida al usuario, reintentar la operación, probar con otra o agregarla a la lista de tareas en cola).

Si keys consiste en una sola clave (o su representación de string), este método muestra la instancia del modelo asociada con la clave si la clave existe en Datastore; de lo contrario, muestra None. Si keys es una lista, el valor que se muestra es una lista correspondiente de instancias del modelo, con valores None en los que no existe una entidad para una clave determinada.

Consulta también Model.get().

get_indexes()

Muestra una lista de índices compuestos que pertenecen a la aplicación que realiza la llamada.

El siguiente ejemplo ilustra cómo obtener y usar los índices:

def get_index_state_as_string(index_state):
  return {db.Index.BUILDING:'BUILDING', db.Index.SERVING:'SERVING',
          db.Index.DELETING:'DELETING', db.Index.ERROR:'ERROR'}[index_state]

def get_sort_direction_as_string(sort_direction):
  return {db.Index.ASCENDING:'ASCENDING',
          db.Index.DESCENDING:'DESCENDING'}[sort_direction]

def dump_indexes():
  for index, state in db.get_indexes():
    print "Kind: %s" % index.kind()
    print "State: %s" % get_index_state_as_string(state)
    print "Is ancestor: %s" % index.has_ancestor()
    for property_name, sort_direction in index.properties():
      print "  %s:%s" % (property_name,
                         get_sort_direction_as_string(sort_direction))
get_indexes_async()

Muestra de manera asíncrona una lista de índices compuestos que pertenecen a la aplicación que realiza la llamada.

is_in_transaction()

Muestra un valor booleano que indica si el alcance actual está en ejecución en una transacción.

model_to_protobuf (model_instance)

Crea la serialización de búfer de protocolo de una instancia de Model. Un búfer de protocolo es el formato de serialización de Google utilizado para las llamadas a procedimientos remotos, y puede ser útil si deseas serializar objetos de Datastore con fines de copia de seguridad y restablecimiento.

Precaución: Esta función no utiliza el formato de búfer de protocolo de código abierto, sino un formato diferente (más antiguo) que no es compatible con la implementación de código abierto.

Argumento

model_instance
La instancia de la clase Model (o una subclase) que se serializará.

Muestra la serialización de búfer de protocolo del objeto, como una string de bytes.

model_from_protobuf (pb)

Crea una instancia de Model basada en una serialización de búfer de protocolo. Consulta model_to_protobuf() para obtener más información.

Argumento

pb
El protocolo de serialización del búfer, como lo muestra model_to_protobuf().

Muestra un objeto de la clase de similares apropiada. Si la clase de similares no existe, genera una excepción de KindError. Si el objeto no es válido según el modelo, se genera una excepción BadValueError.

Puedes guardar el nuevo objeto en Datastore como cualquier otra instancia de Model (por ejemplo, con una llamada a su método put()). El objeto retiene la clave que tenía cuando se creó el búfer de protocolo. Si ya existe un objeto con esa clave en Datastore, cuando guardas el objeto deserializado se reemplaza el objeto existente.

Precaución: Si la clave del objeto utiliza un ID asignado por el sistema y ese ID aún no se ha asignado para la ruta de acceso y el similar dados, la operación de guardado se realizará correctamente, pero no se reservará el ID. A un objeto creado en el futuro se le podrá asignar ese ID y este podría reemplazar el objeto anterior. Por seguridad, restablezca los objetos solo en la misma aplicación en la que existían cuando se serializaron.

model_is_projection (model_instance)

Muestra True si la consulta especificada (model_instance) es una consulta de proyección en lugar de una consulta para una entidad completa.

Argumento

model_instance
La consulta que marca para determinar si es una consulta de proyección.

Muestra True si la consulta es una consulta de proyección, y False si no lo es.

put (models, deadline=60)

Escribe una o más instancias de modelo desde Datastore.

Argumentos

models
Una instancia de modelo o una lista de instancias de modelo que se almacenará.
deadline
El tiempo máximo en segundos que se esperará que el almacén de datos muestre un resultado antes de anular con un error. Acepta un valor de número entero o punto flotante. No es posible configurar un valor más alto que el predeterminado (60 segundos), pero sí puedes establecer un tiempo menor para asegurarte de que una operación específica falle rápido (por ejemplo, con el objetivo de mostrar una respuesta más rápida al usuario, reintentar la operación, probar con otra o agregarla a la lista de tareas en cola).

Si se dan varias instancias de modelo, estas pueden estar en más de un grupo de entidad.

Siempre se generará una excepción si se produce algún error durante la operación, incluso si algunas de las entidades realmente se escribieron. Si la llamada se muestra sin generar una excepción, entonces todas las entidades fueron eliminadas correctamente.

Si models consta de una única instancia de modelo, esta función muestra el objeto de clave. Si models es una lista, el valor de muestra es una lista de los objetos de clave correspondientes.

Precaución: El hecho de escribir varias entidades en una sola operación no garantiza que las eliminaciones se realicen de forma atómica, a menos que la operación se realice dentro de una transacción. Otros procesos que consultan a Datastore pueden presentar resultados incoherentes aun cuando la consulta se realice con una coherencia sólida.

put_async (models, deadline=60)

Escribe una o más instancias de modelo desde Datastore.

Esta función es idéntica a put(), excepto que muestra un objeto asíncrono. Puedes llamar a get_result() en el valor de muestra para realizar el bloqueo en la llamada y mostrar los resultados.

Argumentos

models
Una instancia de modelo o una lista de instancias de modelo que se almacenará.
deadline
El tiempo máximo en segundos que se esperará que el almacén de datos muestre un resultado antes de anular con un error. Acepta un valor de número entero o punto flotante. No es posible configurar un valor más alto que el predeterminado (60 segundos), pero sí puedes establecer un tiempo menor para asegurarte de que una operación específica falle rápido (por ejemplo, con el objetivo de mostrar una respuesta más rápida al usuario, reintentar la operación, probar con otra o agregarla a la lista de tareas en cola).

Si se dan varias instancias de modelo, estas pueden estar en más de un grupo de entidad.

Siempre se generará una excepción si se produce algún error durante la operación, incluso si algunas de las entidades realmente se escribieron. Si la llamada se muestra sin generar una excepción, entonces todas las entidades fueron eliminadas correctamente.

Esta función muestra un objeto asíncrono en el que se puede llamar a get_result(). Los resultados que se muestran son los mismos que para put().

Precaución: El hecho de escribir varias entidades en una sola operación no garantiza que las eliminaciones se realicen de forma atómica, a menos que la operación se realice dentro de una transacción. Otros procesos que consultan a Datastore pueden presentar resultados incoherentes aun cuando la consulta se realice con una coherencia sólida.

query_descendants (model_instance)

Muestra una consulta para todos los descendientes de una instancia de modelo.

Argumento

model_instance
La instancia de modelo cuyos descendientes quieres encontrar.
run_in_transaction (function, *args, **kwargs)

Ejecuta una función que contiene actualizaciones de Datastore en una sola transacción. Si algún código genera una excepción durante la transacción, todas las actualizaciones realizadas en la transacción se revierten. Como alternativa, puedes usar el decorador @db.transactional().

Argumentos

function
Función que se ejecutará.
args
Argumentos posicionales para pasar a la función.
kwargs
Argumentos de palabra clave para pasar a la función.

Si la función muestra un valor, run_in_transaction() presenta el valor para el emisor.

Si la función genera una excepción, la transacción se revierte. Si la excepción es Rollback, no se vuelve a producir; cualquier otra excepción se vuelve a generar para el emisor.

Datastore utiliza un bloqueo optimista y vuelve a intentar las transacciones. Si la transacción preparada por la función no se puede confirmar, run_in_transaction() vuelve a llamar a la función y reintenta la transacción tres veces. Si deseas que se realice una cantidad de intentos diferente, utiliza run_in_transaction_custom_retries(). Debido a que la función de transacción puede llamarse más de una vez para una sola transacción, la función no debe tener efectos secundarios, incluidas modificaciones a los argumentos.

Si la transacción no se puede confirmar, por ejemplo, debido a una alta tasa de contención, se genera un TransactionFailedError.

from google.appengine.ext import db

class Counter(db.Model):
  name = db.StringProperty()
  count = db.IntegerProperty(default=0)

def decrement(key, amount=1):
  counter = db.get(key)
  counter.count -= amount
  if counter.count < 0:        # Don't let counter go negative
    raise db.Rollback()
  db.put(counter)

q = db.GqlQuery("SELECT * FROM Counter WHERE name = :1", "foo")
counter = q.get()
db.run_in_transaction(decrement, counter.key(), amount=5)
run_in_transaction_custom_retries (retries, function, *args, **kwargs)

Ejecuta una función que contiene actualizaciones de Datastore en una sola transacción, y reintenta la transacción una cantidad específica de veces en el caso de una contención. Si algún código genera una excepción durante la transacción, todas las actualizaciones realizadas en la transacción se revierten.

Esta función se comporta de manera idéntica a run_in_transaction(), salvo por el hecho de que permite especificar la cantidad de intentos.

Argumentos

retries
Número máximo de veces para llamar a la función en caso de contención dentro del grupo de entidades (más de un usuario intenta modificar el grupo simultáneamente).
function
Función que se ejecutará.
args
Argumentos posicionales para pasar a la función.
kwargs
Argumentos de palabra clave para pasar a la función.
run_in_transaction_options (options, function, *args, **kwargs)

Ejecuta una función que contiene actualizaciones de Datastore en un solo objeto de opciones de transacción. Si algún código genera una excepción durante la transacción, todas las actualizaciones de Datastore realizadas en la transacción se revierten.

Para transacciones de grupo cruzado (XG), el parámetro xg en el objeto de opciones de transacción se debe establecer en True.

Argumentos

options
El objeto de opciones de transacción que contiene la configuración que utiliza esta transacción. Para habilitar las transacciones XG, su parámetro xg debe establecerse en True.
function
Función que se ejecutará.
args
Argumentos posicionales para pasar a la función.
kwargs
Argumentos de palabra clave para pasar a la función.

Si la función muestra un valor, run_in_transaction_options() presenta el valor para el emisor.

Si la función genera una excepción, la transacción se revierte. Si la excepción es Rollback, no se vuelve a producir; cualquier otra excepción se vuelve a generar para el emisor.

Datastore utiliza un bloqueo optimista y vuelve a intentar las transacciones. Si la transacción preparada por la función no se puede confirmar, run_in_transaction_options() vuelve a llamar a la función y reintenta la transacción hasta el número de reintentos especificado en el objeto de opciones de transacción. Debido a que la función de transacción puede llamarse más de una vez para una sola transacción, la función no debe tener efectos secundarios, incluidas modificaciones a los argumentos.

Si la transacción no se puede confirmar, por ejemplo, debido a una alta tasa de contención, se genera un TransactionFailedError.

El siguiente ejemplo muestra cómo utilizar esta función para ejecutar una transacción de grupo cruzado:

from google.appengine.ext import db

xg_options = db.create_transaction_options(xg=True)

def my_txn():
  x = MyModel(a=3)
  x.put()
  y = MyModel(a=7)
  y.put()

db.run_in_transaction_options(xg_options, my_txn)
to_dict (model_instance, dictionary=None)

Crea y muestra una representación de diccionario de una instancia de modelo.

Argumentos

model_instance
Instancia de modelo que se copiará.
dictionary
Si está presente, diccionario en el que se combinan los datos del modelo. Los valores del modelo reemplazan los valores en el diccionario; y se conservan las entradas del diccionario que no corresponden a los campos en la instancia del modelo.

Decoradores

@db.transactional (propagation=ALLOWED, xg=False, retries=3, deadline=60)

Hace que una función se ejecute dentro de una transacción db. Así, en lugar de llamar a run_in_transaction(func), puedes llamar a func().

Argumentos

propagation
Qué hacer si esta función transaccional se llama desde otra transacción:
ALLOWED
Si ya está en una transacción, continúa usándola; caso contrario, inicia una.

Nota: Si una función que utiliza esta política genera una excepción, probablemente no sea seguro detectar la excepción y confirmar la transacción externa; la función puede haber dejado la transacción externa en un estado incorrecto.

MANDATORY
Continúa en la transacción existente, si la hubiere; caso contrario, genera una excepción BadRequestError.

Nota: Si una función que utiliza esta política genera una excepción, probablemente no sea seguro detectar la excepción y confirmar la transacción externa; la función puede haber dejado la transacción externa en un estado incorrecto.

INDEPENDENT
Crea una nueva transacción, pausando cualquier transacción existente.

Nota: Una función que usa esta política no debe mostrar ninguna entidad leída en la nueva transacción, ya que las entidades no son consistentemente transaccionales con la transacción externa.

NESTED
(Aún no se admite) Crea una transacción anidada dentro de una existente.
xg
Si el valor es True, permite transacciones entre grupos (XG). Si se establece un valor no booleano, se genera una excepción BadArgumentError.
retries
Número de reintentos que se realizan en caso de falla de confirmación de la transacción.
deadline
El tiempo máximo en segundos que se esperará que el almacén de datos muestre un resultado antes de anular con un error. Acepta un valor de número entero o punto flotante. No es posible configurar un valor más alto que el predeterminado (60 segundos), pero sí puedes establecer un tiempo menor para asegurarte de que una operación específica falle rápido (por ejemplo, con el objetivo de mostrar una respuesta más rápida al usuario, reintentar la operación, probar con otra o agregarla a la lista de tareas en cola).
@db.non_transactional (allow_existing=True)

Garantiza que una función se ejecute fuera de una transacción db, incluso si se llama desde una transacción.

Argumento

allow_existing
Si el valor es True, se permite que se llame a la función desde una transacción existente; si el valor es False, en su lugar se genera una excepción BadRequestError.