apache_beam.io.gcp.datastore_write_it_pipeline module

A job that write Entries into Datastore.

The pipelines behave in the steps below.

1. Create and write Entities to Datastore
2. (Optional) If read limit was provided, read it and confirm that the expected Entities were read.
3. Query the written Entities and verify result.
4. Delete Entries.
5. Query the written Entities, verify no results.

apache_beam.io.gcp.datastore_write_it_pipeline.new_pipeline_with_job_name(pipeline_options, job_name, suffix)

Create a pipeline with the given job_name and a suffix.

class apache_beam.io.gcp.datastore_write_it_pipeline.EntityWrapper(kind, namespace, ancestor)

Bases: object

Create a Cloud Datastore entity from the given string.

make_entity(content)

Create entity from given string.

apache_beam.io.gcp.datastore_write_it_pipeline.make_ancestor_query(kind, namespace, ancestor)

Creates a Cloud Datastore ancestor query.

apache_beam.io.gcp.datastore_write_it_pipeline.run(argv=None)

Main entry point.