[BEAM-7350] Update Python Datastore example to use v1new Datastore IO

• Type: Improvement
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Fix Version/s: 2.21.0
• Component/s: io-py-gcp
• Labels: stale-assigned
• Assignee: niklas Hansson
• Reporter: Valentyn Tymofieiev
• Created: 17/May/19 19:09
• Updated: 05/Jun/20 14:18
• Resolved: 05/Jun/20 14:18

Description

Recently we updated Datastore IO implementation https://github.com/apache/beam/pull/8262, and we need to update the example to use the
new implementation.

Some pointers:

New IO: https://github.com/apache/beam/blob/master/sdks/python/apache_beam/io/gcp/datastore/v1new/datastoreio.py

Old IO:
https://github.com/apache/beam/blob/master/sdks/python/apache_beam/io/gcp/datastore/v1/datastoreio.py

Example using old IO: https://github.com/apache/beam/blob/master/sdks/python/apache_beam/examples/cookbook/datastore_wordcount.py

Integration test using old IO:
https://github.com/apache/beam/blob/master/sdks/python/apache_beam/examples/cookbook/datastore_wordcount_it_test.py

Once the integration test is using the new IO, we can also run it on Python3, currently it is skipped:

https://github.com/apache/beam/blob/15deadff871e55676a5f708fee95b49d0688af83/sdks/python/apache_beam/examples/cookbook/datastore_wordcount_it_test.py#L37

cc: udim