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)[source]

Returns a Cloud Datastore client.

apache_beam.io.gcp.datastore.v1new.helper.retry_on_rpc_error(exception)[source]

A retry filter for Cloud Datastore RPCErrors.

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

Creates a list of entities with random keys.

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

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