apache_beam.io.gcp.datastore.v1new.types module

Beam Datastore types.

This module is experimental, no backwards compatibility guarantees.

class apache_beam.io.gcp.datastore.v1new.types.Query(kind=None, project=None, namespace=None, ancestor=None, filters=(), projection=(), order=(), distinct_on=(), limit=None)

Bases: object

Represents a Datastore query.

Parameters:

• kind – (str) The kind to query.
• project – (str) Required. Project associated with query.
• namespace – (str) (Optional) Namespace to restrict results to.
• ancestor – (Key) (Optional) key of the ancestor to which this query’s results are restricted.
• filters – (sequence of tuple[str, str, str]) Property filters applied by this query. The sequence is (property_name, operator, value).
• projection – (sequence of string) fields returned as part of query results.
• order – (sequence of string) field names used to order query results. Prepend - to a field name to sort it in descending order.
• distinct_on – (sequence of string) field names used to group query results.
• limit – (int) Maximum amount of results to return.

clone()

class apache_beam.io.gcp.datastore.v1new.types.Key(path_elements, parent=None, project=None, namespace=None)

Bases: object

Represents a Datastore key.

The partition ID is represented by its components: namespace and project. If key has a parent, project and namespace should either be unset or match the parent’s.

Parameters:

• path_elements – (list of str and int) Key path: an alternating sequence of kind and identifier. The kind must be of type str and identifier may be a str or an int. If the last identifier is omitted this is an incomplete key, which is unsupported in WriteToDatastore and DeleteFromDatastore. See google.cloud.datastore.key.Key for more details.
• parent – (Key) (optional) Parent for this key.
• project – (str) Project ID. Required unless set by parent.
• namespace – (str) (optional) Namespace ID

static from_client_key(client_key)

to_client_key()

Returns a google.cloud.datastore.key.Key instance that represents this key.

class apache_beam.io.gcp.datastore.v1new.types.Entity(key, exclude_from_indexes=())

Bases: object

Represents a Datastore entity.

Does not support the property value “meaning” field.

Parameters:

• key – (Key) A complete Key representing this Entity.
• exclude_from_indexes – (iterable of str) List of property keys whose values should not be indexed for this entity.

set_properties(property_dict)

Sets a dictionary of properties on this entity.

Parameters:property_dict – A map from property name to value. See google.cloud.datastore.entity.Entity documentation for allowed values.

static from_client_entity(client_entity)

to_client_entity()

Returns a google.cloud.datastore.entity.Entity instance that represents this entity.