pardeep-tm
diff --git a/‎MAC_SETUP.md
Lines changed: 1 addition & 1 deletion b/‎MAC_SETUP.md
Lines changed: 1 addition & 1 deletion
diff --git a/‎appengine/flexible/tasks/create_app_engine_queue_task.py
Lines changed: 2 additions & 2 deletions b/‎appengine/flexible/tasks/create_app_engine_queue_task.py
Lines changed: 2 additions & 2 deletions
diff --git a/‎appengine/flexible/tasks/requirements.txt
Lines changed: 1 addition & 1 deletion b/‎appengine/flexible/tasks/requirements.txt
Lines changed: 1 addition & 1 deletion
diff --git a/‎appengine/standard_python37/bigquery/main.py
Lines changed: 33 additions & 9 deletions b/‎appengine/standard_python37/bigquery/main.py
Lines changed: 33 additions & 9 deletions
diff --git a/‎appengine/standard_python37/bigquery/main_test.py
Lines changed: 31 additions & 7 deletions b/‎appengine/standard_python37/bigquery/main_test.py
Lines changed: 31 additions & 7 deletions
diff --git a/‎appengine/standard_python37/pubsub/README.md
Lines changed: 79 additions & 0 deletions b/‎appengine/standard_python37/pubsub/README.md
Lines changed: 79 additions & 0 deletions
diff --git a/‎appengine/standard_python37/pubsub/app.yaml
Lines changed: 9 additions & 0 deletions b/‎appengine/standard_python37/pubsub/app.yaml
Lines changed: 9 additions & 0 deletions
diff --git a/‎appengine/standard_python37/pubsub/data/privatekey.pem
Lines changed: 27 additions & 0 deletions b/‎appengine/standard_python37/pubsub/data/privatekey.pem
Lines changed: 27 additions & 0 deletions
diff --git a/‎appengine/standard_python37/pubsub/data/public_cert.pem
Lines changed: 19 additions & 0 deletions b/‎appengine/standard_python37/pubsub/data/public_cert.pem
Lines changed: 19 additions & 0 deletions
@@ -34,7 +34,7 @@ test their code.
 
     ```
     eval "$(pyenv init -)"
-    eval "$(pyenv virtualenv-init -)"`
+    eval "$(pyenv virtualenv-init -)"
     ```
 
     Note that this also works with ZSH.
 
@@ -22,11 +22,11 @@ def create_task(project, queue, location, payload=None, in_seconds=None):
     # [START cloud_tasks_appengine_create_task]
     """Create a task for a given queue with an arbitrary payload."""
 
-    from google.cloud import tasks
+    from google.cloud import tasks_v2
     from google.protobuf import timestamp_pb2
 
     # Create a client.
-    client = tasks.CloudTasksClient()
+    client = tasks_v2.CloudTasksClient()
 
     # TODO(developer): Uncomment these lines and replace with your values.
     # project = 'my-project-id'
 
@@ -1,3 +1,3 @@
 Flask==1.0.2
 gunicorn==19.9.0
-google-cloud-tasks==0.5.0
+google-cloud-tasks==0.6.0
@@ -15,17 +15,18 @@
 # [START gae_python37_bigquery]
 import concurrent.futures
 
-from flask import Flask, render_template
+import flask
 from google.cloud import bigquery
 
 
-app = Flask(__name__)
+app = flask.Flask(__name__)
 bigquery_client = bigquery.Client()
 
 
-@app.route('/')
+@app.route("/")
 def main():
-    query_job = bigquery_client.query("""
+    query_job = bigquery_client.query(
+        """
         SELECT
         CONCAT(
             'https://stackoverflow.com/questions/',
@@ -35,20 +36,43 @@ def main():
         WHERE tags like '%google-bigquery%'
         ORDER BY view_count DESC
         LIMIT 10
-    """)
+    """
+    )
+
+    return flask.redirect(
+        flask.url_for(
+            "results",
+            project_id=query_job.project,
+            job_id=query_job.job_id,
+            location=query_job.location,
+        )
+    )
+
+
+@app.route("/results")
+def results():
+    project_id = flask.request.args.get("project_id")
+    job_id = flask.request.args.get("job_id")
+    location = flask.request.args.get("location")
+
+    query_job = bigquery_client.get_job(
+        job_id,
+        project=project_id,
+        location=location,
+    )
 
     try:
         # Set a timeout because queries could take longer than one minute.
         results = query_job.result(timeout=30)
     except concurrent.futures.TimeoutError:
-        return render_template('timeout.html', job_id=query_job.job_id)
+        return flask.render_template("timeout.html", job_id=query_job.job_id)
 
-    return render_template('query_result.html', results=results)
+    return flask.render_template("query_result.html", results=results)
 
 
-if __name__ == '__main__':
+if __name__ == "__main__":
     # This is used when running locally only. When deploying to Google App
     # Engine, a webserver process such as Gunicorn will serve the app. This
     # can be configured by adding an `entrypoint` to app.yaml.
-    app.run(host='127.0.0.1', port=8080, debug=True)
+    app.run(host="127.0.0.1", port=8080, debug=True)
 # [END gae_python37_bigquery]
@@ -28,22 +28,46 @@ def flask_client():
 
 
 def test_main(flask_client):
-    r = flask_client.get('/')
+    r = flask_client.get("/")
+    assert r.status_code == 302
+    assert "/results" in r.headers.get("location", "")
+
+
+def test_results(flask_client, monkeypatch):
+    import main
+
+    fake_job = mock.create_autospec(bigquery.QueryJob)
+    fake_rows = [("example1.com", "42"), ("example2.com", "38")]
+    fake_job.result.return_value = fake_rows
+
+    def fake_get_job(self, job_id, **kwargs):
+        return fake_job
+
+    monkeypatch.setattr(main.bigquery.Client, "get_job", fake_get_job)
+
+    r = flask_client.get(
+        "/results?project_id=123&job_id=456&location=my_location"
+    )
+    response_body = r.data.decode("utf-8")
+
     assert r.status_code == 200
-    assert 'Query Result' in r.data.decode('utf-8')
+    assert "Query Result" in response_body  # verifies header
+    assert "example2.com" in response_body
+    assert "42" in response_body
 
 
-def test_main_timeout(flask_client, monkeypatch):
+def test_results_timeout(flask_client, monkeypatch):
     import main
 
     fake_job = mock.create_autospec(bigquery.QueryJob)
     fake_job.result.side_effect = concurrent.futures.TimeoutError()
 
-    def fake_query(query):
+    def fake_get_job(self, job_id, **kwargs):
         return fake_job
 
-    monkeypatch.setattr(main.bigquery_client, 'query', fake_query)
+    monkeypatch.setattr(main.bigquery.Client, "get_job", fake_get_job)
+
+    r = flask_client.get("/results", follow_redirects=True)
 
-    r = flask_client.get('/')
     assert r.status_code == 200
-    assert 'Query Timeout' in r.data.decode('utf-8')
+    assert "Query Timeout" in r.data.decode("utf-8")
@@ -0,0 +1,79 @@
+# Python 3 Google Cloud Pub/Sub sample for Google App Engine Standard Environment
+
+[![Open in Cloud Shell][shell_img]][shell_link]
+
+[shell_img]: http://gstatic.com/cloudssh/images/open-btn.png
+[shell_link]: https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/GoogleCloudPlatform/python-docs-samples&page=editor&open_in_editor=appengine/standard/pubsub/README.md
+
+This demonstrates how to send and receive messages using [Google Cloud Pub/Sub](https://cloud.google.com/pubsub) on [Google App Engine Standard Environment](https://cloud.google.com/appengine/docs/standard/).
+
+## Setup
+
+Before you can run or deploy the sample, you will need to do the following:
+
+1. Enable the Cloud Pub/Sub API in the [Google Developers Console](https://console.developers.google.com/project/_/apiui/apiview/pubsub/overview).
+
+2. Create a topic and subscription. The push auth service account must have Service Account Token Creator Role assigned, which can be done in the Cloud Console [IAM & admin](https://console.cloud.google.com/iam-admin/iam) UI. `--push-auth-token-audience` is optional. If set, remember to modify the audience field check in `main.py` (line 88).
+
+        $ gcloud pubsub topics create [your-topic-name]
+        $ gcloud beta pubsub subscriptions create [your-subscription-name] \
+            --topic=[your-topic-name] \
+            --push-endpoint=\
+                https://[your-app-id].appspot.com/_ah/push-handlers/receive_messages/token=[your-token] \
+            --ack-deadline=30 \
+            --push-auth-service-account=[your-service-account-email] \
+            --push-auth-token-audience=example.com
+
+3. Update the environment variables in ``app.yaml``.
+
+## Running locally
+
+When running locally, you can use the [Google Cloud SDK](https://cloud.google.com/sdk) to provide authentication to use Google Cloud APIs:
+
+    $ gcloud init
+
+Install dependencies, preferably with a virtualenv:
+
+    $ virtualenv env
+    $ source env/bin/activate
+    $ pip install -r requirements.txt
+
+Then set environment variables before starting your application:
+
+    $ export GOOGLE_CLOUD_PROJECT=[your-project-name]
+    $ export PUBSUB_VERIFICATION_TOKEN=[your-verification-token]
+    $ export PUBSUB_TOPIC=[your-topic]
+    $ python main.py
+
+### Simulating push notifications
+
+The application can send messages locally, but it is not able to receive push messages locally. You can, however, simulate a push message by making an HTTP request to the local push notification endpoint. There is an included ``sample_message.json``. You can use
+``curl`` or [httpie](https://github.com/jkbrzt/httpie) to POST this:
+
+    $ curl -i --data @sample_message.json "localhost:8080/_ah/push-handlers/receive_messages?token=[your-token]"
+
+Or
+
+    $ http POST ":8080/_ah/push-handlers/receive_messages?token=[your-token]" < sample_message.json
+
+Response:
+
+    HTTP/1.0 400 BAD REQUEST
+    Content-Type: text/html; charset=utf-8
+    Content-Length: 58
+    Server: Werkzeug/0.15.2 Python/3.7.3
+    Date: Sat, 06 Apr 2019 04:56:12 GMT
+
+    Invalid token: 'NoneType' object has no attribute 'split'
+
+The simulated push request fails because it does not have a Cloud Pub/Sub-generated JWT in the "Authorization" header.
+
+## Running on App Engine
+
+Note: Not all the files in the current directory are needed to run your code on App Engine. Specifically, `main_test.py` and the `data` directory, which contains a mocked private key file and a mocked public certs file, are for testing purposes only. They SHOULD NOT be included in when deploying your app. When your app is up and running, Cloud Pub/Sub creates tokens using a private key, then the Google Auth Python library takes care of verifying and decoding the token using Google's public certs, to confirm that the push requests indeed come from Cloud Pub/Sub. 
+
+In the current directory, deploy using `gcloud`:
+
+    $ gcloud app deploy app.yaml
+
+You can now access the application at `https://[your-app-id].appspot.com`. You can use the form to submit messages, but it's non-deterministic which instance of your application will receive the notification. You can send multiple messages and refresh the page to see the received message.
@@ -0,0 +1,9 @@
+runtime: python37
+
+#[START env]
+env_variables:
+    PUBSUB_TOPIC: your-topic
+    # This token is used to verify that requests originate from your
+    # application. It can be any sufficiently random string.
+    PUBSUB_VERIFICATION_TOKEN: 1234abc
+#[END env]
@@ -0,0 +1,27 @@
+-----BEGIN RSA PRIVATE KEY-----
+MIIEpAIBAAKCAQEA4ej0p7bQ7L/r4rVGUz9RN4VQWoej1Bg1mYWIDYslvKrk1gpj
+7wZgkdmM7oVK2OfgrSj/FCTkInKPqaCR0gD7K80q+mLBrN3PUkDrJQZpvRZIff3/
+xmVU1WeruQLFJjnFb2dqu0s/FY/2kWiJtBCakXvXEOb7zfbINuayL+MSsCGSdVYs
+SliS5qQpgyDap+8b5fpXZVJkq92hrcNtbkg7hCYUJczt8n9hcCTJCfUpApvaFQ18
+pe+zpyl4+WzkP66I28hniMQyUlA1hBiskT7qiouq0m8IOodhv2fagSZKjOTTU2xk
+SBc//fy3ZpsL7WqgsZS7Q+0VRK8gKfqkxg5OYQIDAQABAoIBAQDGGHzQxGKX+ANk
+nQi53v/c6632dJKYXVJC+PDAz4+bzU800Y+n/bOYsWf/kCp94XcG4Lgsdd0Gx+Zq
+HD9CI1IcqqBRR2AFscsmmX6YzPLTuEKBGMW8twaYy3utlFxElMwoUEsrSWRcCA1y
+nHSDzTt871c7nxCXHxuZ6Nm/XCL7Bg8uidRTSC1sQrQyKgTPhtQdYrPQ4WZ1A4J9
+IisyDYmZodSNZe5P+LTJ6M1SCgH8KH9ZGIxv3diMwzNNpk3kxJc9yCnja4mjiGE2
+YCNusSycU5IhZwVeCTlhQGcNeV/skfg64xkiJE34c2y2ttFbdwBTPixStGaF09nU
+Z422D40BAoGBAPvVyRRsC3BF+qZdaSMFwI1yiXY7vQw5+JZh01tD28NuYdRFzjcJ
+vzT2n8LFpj5ZfZFvSMLMVEFVMgQvWnN0O6xdXvGov6qlRUSGaH9u+TCPNnIldjMP
+B8+xTwFMqI7uQr54wBB+Poq7dVRP+0oHb0NYAwUBXoEuvYo3c/nDoRcZAoGBAOWl
+aLHjMv4CJbArzT8sPfic/8waSiLV9Ixs3Re5YREUTtnLq7LoymqB57UXJB3BNz/2
+eCueuW71avlWlRtE/wXASj5jx6y5mIrlV4nZbVuyYff0QlcG+fgb6pcJQuO9DxMI
+aqFGrWP3zye+LK87a6iR76dS9vRU+bHZpSVvGMKJAoGAFGt3TIKeQtJJyqeUWNSk
+klORNdcOMymYMIlqG+JatXQD1rR6ThgqOt8sgRyJqFCVT++YFMOAqXOBBLnaObZZ
+CFbh1fJ66BlSjoXff0W+SuOx5HuJJAa5+WtFHrPajwxeuRcNa8jwxUsB7n41wADu
+UqWWSRedVBg4Ijbw3nWwYDECgYB0pLew4z4bVuvdt+HgnJA9n0EuYowVdadpTEJg
+soBjNHV4msLzdNqbjrAqgz6M/n8Ztg8D2PNHMNDNJPVHjJwcR7duSTA6w2p/4k28
+bvvk/45Ta3XmzlxZcZSOct3O31Cw0i2XDVc018IY5be8qendDYM08icNo7vQYkRH
+504kQQKBgQDjx60zpz8ozvm1XAj0wVhi7GwXe+5lTxiLi9Fxq721WDxPMiHDW2XL
+YXfFVy/9/GIMvEiGYdmarK1NW+VhWl1DC5xhDg0kvMfxplt4tynoq1uTsQTY31Mx
+BeF5CT/JuNYk3bEBF0H/Q3VGO1/ggVS+YezdFbLWIRoMnLj6XCFEGg==
+-----END RSA PRIVATE KEY-----
@@ -0,0 +1,19 @@
+-----BEGIN CERTIFICATE-----
+MIIDIzCCAgugAwIBAgIJAMfISuBQ5m+5MA0GCSqGSIb3DQEBBQUAMBUxEzARBgNV
+BAMTCnVuaXQtdGVzdHMwHhcNMTExMjA2MTYyNjAyWhcNMjExMjAzMTYyNjAyWjAV
+MRMwEQYDVQQDEwp1bml0LXRlc3RzMIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIB
+CgKCAQEA4ej0p7bQ7L/r4rVGUz9RN4VQWoej1Bg1mYWIDYslvKrk1gpj7wZgkdmM
+7oVK2OfgrSj/FCTkInKPqaCR0gD7K80q+mLBrN3PUkDrJQZpvRZIff3/xmVU1Wer
+uQLFJjnFb2dqu0s/FY/2kWiJtBCakXvXEOb7zfbINuayL+MSsCGSdVYsSliS5qQp
+gyDap+8b5fpXZVJkq92hrcNtbkg7hCYUJczt8n9hcCTJCfUpApvaFQ18pe+zpyl4
++WzkP66I28hniMQyUlA1hBiskT7qiouq0m8IOodhv2fagSZKjOTTU2xkSBc//fy3
+ZpsL7WqgsZS7Q+0VRK8gKfqkxg5OYQIDAQABo3YwdDAdBgNVHQ4EFgQU2RQ8yO+O
+gN8oVW2SW7RLrfYd9jEwRQYDVR0jBD4wPIAU2RQ8yO+OgN8oVW2SW7RLrfYd9jGh
+GaQXMBUxEzARBgNVBAMTCnVuaXQtdGVzdHOCCQDHyErgUOZvuTAMBgNVHRMEBTAD
+AQH/MA0GCSqGSIb3DQEBBQUAA4IBAQBRv+M/6+FiVu7KXNjFI5pSN17OcW5QUtPr
+odJMlWrJBtynn/TA1oJlYu3yV5clc/71Vr/AxuX5xGP+IXL32YDF9lTUJXG/uUGk
++JETpKmQviPbRsvzYhz4pf6ZIOZMc3/GIcNq92ECbseGO+yAgyWUVKMmZM0HqXC9
+ovNslqe0M8C1sLm1zAR5z/h/litE7/8O2ietija3Q/qtl2TOXJdCA6sgjJX2WUql
+ybrC55ct18NKf3qhpcEkGQvFU40rVYApJpi98DiZPYFdx1oBDp/f4uZ3ojpxRVFT
+cDwcJLfNRCPUhormsY7fDS9xSyThiHsW9mjJYdcaKQkwYZ0F11yB
+-----END CERTIFICATE-----