Schedule datastore export

datastore/schedule-export/README.md

@@ -0,0 +1,5 @@
+# Scheduling Datastore exports with Cloud Functions and Cloud Scheduler
+
+This sample application demonstrates how to schedule exports of your Datastore entities. To deploy this sample, see:
+
+[Scheduling exports](https://cloud.google.com/datastore/docs/schedule-export)

datastore/schedule-export/main.py

@@ -0,0 +1,42 @@
+import base64
+import json
+import os
+
+from googleapiclient.discovery import build
+
+datastore = build('datastore', 'v1')
+project_id = os.environ.get('GCP_PROJECT')
+
+
+def datastore_export(event, context):
+    '''Trigger a Datastore export from a Cloud Scheduler job.
+    Args:
+         event (dict): event[data] must contain a json object encoded in
+         base-64. Cloud Scheduler encodes payloads in base-64 by default.
+         Object must include a 'bucket' value and can include 'kinds'
+         and 'namespaceIds' values.
+         context (google.cloud.functions.Context): The Cloud Functions event
+         metadata.
+    '''
+
+    json_data = json.loads(base64.b64decode(event['data']).decode('utf-8'))
+    bucket = json_data['bucket']
+    entity_filter = {}
+
+    if 'kinds' in json_data:
+        entity_filter['kinds'] = json_data['kinds']
+
+    if 'namespaceIds' in json_data:
+        entity_filter['namespaceIds'] = json_data['namespaceIds']
+
+    request_body = {
+        'outputUrlPrefix': bucket,
+        'entityFilter': entity_filter
+    }
+
+    export_request = datastore.projects().export(
+        projectId=project_id,
+        body=request_body
+    )
+    response = export_request.execute()
+    print(response)

datastore/schedule-export/requirements-test.txt

@@ -0,0 +1,3 @@
+pytest==5.3.2
+gcp-devrel-py-tools==0.0.15
+flaky==3.6.1

datastore/schedule-export/requirements.txt

@@ -0,0 +1 @@
+google-api-python-client>=1.7.12

datastore/schedule-export/schedule_export_test.py

@@ -0,0 +1,74 @@
+# Copyright 2019 Google LLC All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+import base64
+
+from unittest.mock import Mock
+
+import main
+
+mock_context = Mock()
+mock_context.event_id = '617187464135194'
+mock_context.timestamp = '2020-04-15T22:09:03.761Z'
+
+
+def test_datastore_export(capsys):
+    # Test an export without an entity filter
+    bucket = 'gs://my-bucket'
+    json_string = '{{ "bucket": "{bucket}" }}'.format(bucket=bucket)
+
+    # Encode data like Cloud Scheduler
+    data = bytes(json_string, 'utf-8')
+    data_encoded = base64.b64encode(data)
+    event = {"data": data_encoded}
+
+    # Mock the Datastore service
+    mockDatastore = Mock()
+    main.datastore = mockDatastore
+
+    # Call tested function
+    main.datastore_export(event, mock_context)
+    out, err = capsys.readouterr()
+    export_args = mockDatastore.projects().export.call_args[1]
+    req_body = export_args['body']
+    # Assert request includes test values
+    assert req_body['outputUrlPrefix'] == bucket
+
+
+def test_datastore_export_entity_filter(capsys):
+    # Test an export with an entity filter
+    bucket = 'gs://my-bucket'
+    kinds = 'Users,Tasks'
+    namespaceIds = 'Customer831,Customer157'
+    json_string = '{{ "bucket": "{bucket}", "kinds": "{kinds}", "namespaceIds": "{namespaceIds}" }}'.format(
+        bucket=bucket, kinds=kinds, namespaceIds=namespaceIds)
+
+    # Encode data like Cloud Scheduler
+    data = bytes(json_string, 'utf-8')
+    data_encoded = base64.b64encode(data)
+    event = {"data": data_encoded}
+
+    # Mock the Datastore service
+    mockDatastore = Mock()
+    main.datastore = mockDatastore
+
+    # Call tested function
+    main.datastore_export(event, mock_context)
+    out, err = capsys.readouterr()
+    export_args = mockDatastore.projects().export.call_args[1]
+    req_body = export_args['body']
+    # Assert request includes test values
+    assert req_body['outputUrlPrefix'] == bucket
+    assert req_body['entityFilter']['kinds'] == kinds
+    assert req_body['entityFilter']['namespaceIds'] == namespaceIds