Merge pull request GoogleCloudPlatform#116 from GoogleCloudPlatform/squashDatastore

Add a datastore sample.

Author: SurferJeffAtGoogle

appengine/flexible/datastore/README.md

@@ -0,0 +1,48 @@
+# Google Cloud Datastore and Google App Engine Flexible Environment
+
+This sample application demonstrates how to invoke Google Cloud Datastore from
+ Google App Engine Flexible Environment.
+
+## Register your application
+
+- Go to
+  [Google Developers Console](https://console.developers.google.com/project)
+  and create a new project. This will automatically enable an App
+  Engine application with the same ID as the project.
+
+- Enable the "Google Cloud Datastore API" under "APIs & auth > APIs."
+
+- edit `app.yaml` and change `YOUR_GCP_PROJECT_ID` to your App Engine project ID
+
+- For local development also follow the instructions below.
+
+  - Go to "Credentials" and create a new Service Account.
+
+  - Select "Generate new JSON key", then download a new JSON file.
+
+  - Set the following environment variables:
+
+    - `GOOGLE_APPLICATION_CREDENTIALS`: the file path to the downloaded JSON file.
+    - `GCLOUD_DATASET_ID`: Your app engine project ID
+
+## Prerequisites
+
+- Install [`composer`](https://getcomposer.org)
+- Install dependencies by running:
+
+    ```sh
+    $ composer install
+    ```
+
+## Deploy to App Engine
+
+**Prerequisites**
+
+- Install the [Google Cloud SDK](https://developers.google.com/cloud/sdk/).
+
+**Deploy with gcloud**
+
+```
+$ gcloud config set project YOUR_PROJECT_ID
+$ gcloud preview app deploy
+```

appengine/flexible/datastore/app.php

@@ -0,0 +1,109 @@
+
+/**
+ * Copyright 2015 Google Inc.
+ *
+ * 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.
+ */
+
+use Silex\Application;
+use Symfony\Component\HttpFoundation\Request;
+use Symfony\Component\HttpFoundation\Response;
+
+// create the Silex application
+$app = new Application();
+
+$app['datastore'] = function () {
+    // Datastore API has intermittent failures, so we set the
+    // Google Client to retry in the event of a 503 Backend Error
+    $retryConfig = ['retries' => 2 ];
+    $client = new \Google_Client(['retry' => $retryConfig ]);
+    $client->setScopes([
+        Google_Service_Datastore::CLOUD_PLATFORM,
+        Google_Service_Datastore::DATASTORE,
+    ]);
+    $client->useApplicationDefaultCredentials();
+    return new \Google_Service_Datastore($client);
+};
+
+$app->get('/', function (Application $app, Request $request) {
+    /** @var \Google_Service_Datastore $datastore */
+    $datastore = $app['datastore'];
+    $ip = $request->GetClientIp();
+    // Keep only the first two octets of the IP address.
+    $octets = explode($separator = ':', $ip);
+    if (count($octets) < 2) {  // Must be ip4 address
+        $octets = explode($separator = '.', $ip);
+    }
+    if (count($octets) < 2) {
+        $octets = ['bad', 'ip'];
+    }
+    // Replace empty chunks with zeros.
+    $octets = array_map(function ($x) { return $x == '' ? '0' : $x; }, $octets);
+    $user_ip = $octets[0] . $separator . $octets[1];
+    // Create an entity to insert into datastore.
+    $key = new \Google_Service_Datastore_Key(['path' => ['kind' => 'visit']]);
+    $date = new DateTime();
+    $date->setTimezone(new DateTimeZone('UTC'));
+    $properties = [
+        'user_ip' => ['stringValue' => $user_ip],
+        'timestamp' => ['timestampValue' => $date->format("Y-m-d\TH:i:s\Z")]
+    ];
+    $entity = new \Google_Service_Datastore_Entity([
+        'key' => $key,
+        'properties' => $properties
+    ]);
+
+    // Use "NON_TRANSACTIONAL" for simplicity.  However, it means that we may
+    // not see this result in the query below.
+    $request = new \Google_Service_Datastore_CommitRequest([
+        'mode' => 'NON_TRANSACTIONAL',
+        'mutations' => [
+            [
+                'insert' => $entity,
+            ]
+        ]
+    ]);
+    $dataset_id = $app['google.dataset_id'];
+    $datastore->projects->commit($dataset_id, $request);
+
+    $query = new \Google_Service_Datastore_Query([
+        'kind' => [
+            [
+                'name' => 'visit',
+            ],
+        ],
+        'order' => [
+            'property' => [
+                'name' => 'timestamp',
+            ],
+            'direction' => 'DESCENDING',
+        ],
+        'limit' => 10,
+    ]);
+    $request = new \Google_Service_Datastore_RunQueryRequest();
+    $request->setQuery($query);
+    $response = $datastore->projects->runQuery($dataset_id, $request);
+    /** @var \Google_Service_Datastore_QueryResultBatch $batch */
+    $batch = $response->getBatch();
+    $visits = ["Last 10 visits:"];
+    foreach ($batch->getEntityResults() as $entityResult) {
+        $properties = $entityResult->getEntity()->getProperties();
+        array_push($visits, sprintf('Time: %s Addr: %s',
+            $properties['timestamp']['timestampValue'],
+            $properties['user_ip']['stringValue']));
+    }
+    return new Response(implode("\n", $visits), 200,
+        ['Content-Type' => 'text/plain']);
+});
+
+return $app;

appengine/flexible/datastore/app.yaml

@@ -0,0 +1,5 @@
+runtime: php
+vm: true
+
+runtime_config:
+  document_root: web

appengine/flexible/datastore/composer.json

@@ -0,0 +1,10 @@
+{
+    "require": {
+        "silex/silex": "^1.3",
+        "google/apiclient": "~2.0"
+    },
+    "require-dev": {
+        "phpunit/phpunit": "~4",
+        "google/cloud-tools": "^0.1.0"
+    }
+}