apache_beam.io.gcp.datastore.v1new.datastore_write_it_pipeline module¶
A job that write Entries into Datastore.
The pipelines behave in the steps below.
- Create and write Entities to Datastore
- (Optional) If read limit was provided, read it and confirm that the expected Entities were read.
- Query the written Entities and verify result.
- Delete Entries.
- Query the written Entities, verify no results.
-
apache_beam.io.gcp.datastore.v1new.datastore_write_it_pipeline.
new_pipeline_with_job_name
(pipeline_options, job_name, suffix)[source]¶ Create a pipeline with the given job_name and a suffix.