apache_beam.io.gcp.datastore.v1new.helper module

Cloud Datastore client and test functions.

For internal use only; no backwards-compatibility guarantees.

apache_beam.io.gcp.datastore.v1new.helper.get_client(*args, **kwargs)

Returns a Cloud Datastore client.

apache_beam.io.gcp.datastore.v1new.helper.retry_on_rpc_error(exception)

A retry filter for Cloud Datastore RPCErrors.

apache_beam.io.gcp.datastore.v1new.helper.create_entities(count, id_or_name=False)

Creates a list of entities with random keys.

apache_beam.io.gcp.datastore.v1new.helper.create_client_entities(count, id_or_name=False)

Creates a list of client-style entities with random keys.