Update Cloud Tasks Push Queue Sample (#1698)

* deleted pull queues

* updated samples

* fix dependency versions

Author: averikitsch

appengine/flexible/tasks/README.md

@@ -41,7 +41,7 @@ gcloud beta tasks queues create-app-engine-queue my-appengine-queue
 Note: A newly created queue will route to the default App Engine service and
 version unless configured to do otherwise.
 
-## Deploying the App Engine app
+## Deploying the App Engine App
 
 Deploy the App Engine app with gcloud:
 
@@ -56,14 +56,14 @@ gcloud app browse
 ```
 
 The App Engine app serves as a target for the push requests. It has an
-endpoint `/log_payload` that reads the payload (i.e., the request body) of the
-HTTP POST request and logs it. The log output can be viewed with:
+endpoint `/example_task_handler` that reads the payload (i.e., the request body)
+of the HTTP POST request and logs it. The log output can be viewed with:
 
 ```
 gcloud app logs read
 ```
 
-## Running the Samples
+## Run the Sample Using the Command Line
 
 Set environment variables:
 
@@ -90,7 +90,8 @@ location is "us-central1").
 export LOCATION_ID=us-central1
 ```
 
-Create a task, targeted at the `log_payload` endpoint, with a payload specified:
+Running the sample will create a task, targeted at the 'example_task_handler'
+endpoint, with a payload specified:
 
 ```
 python create_app_engine_queue_task.py --project=$PROJECT_ID --queue=$QUEUE_ID --location=$LOCATION_ID --payload=hello

appengine/flexible/tasks/create_app_engine_queue_task.py

@@ -18,29 +18,38 @@
 import datetime
 
 
-# [START cloud_tasks_appengine_create_task]
 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_v2beta2
+    from google.cloud import tasks_v2beta3
     from google.protobuf import timestamp_pb2
 
     # Create a client.
-    client = tasks_v2beta2.CloudTasksClient()
+    client = tasks_v2beta3.CloudTasksClient()
+
+    # TODO(developer): Uncomment these lines and replace with your values.
+    # project = 'my-project-id'
+    # queue = 'my-appengine-queue'
+    # location = 'us-central1'
+    # payload = 'hello'
+
+    # Construct the fully qualified queue name.
+    parent = client.queue_path(project, location, queue)
 
     # Construct the request body.
     task = {
             'app_engine_http_request': {  # Specify the type of request.
                 'http_method': 'POST',
-                'relative_url': '/example_task_handler'
+                'relative_uri': '/example_task_handler'
             }
     }
     if payload is not None:
         # The API expects a payload of type bytes.
         converted_payload = payload.encode()
 
         # Add the payload to the request.
-        task['app_engine_http_request']['payload'] = converted_payload
+        task['app_engine_http_request']['body'] = converted_payload
 
     if in_seconds is not None:
         # Convert "seconds from now" into an rfc3339 datetime string.
@@ -50,12 +59,9 @@ def create_task(project, queue, location, payload=None, in_seconds=None):
         timestamp = timestamp_pb2.Timestamp()
         timestamp.FromDatetime(d)
 
-        # Add the rfc3339 datetime string to the request.
+        # Add the timestamp to the tasks.
         task['schedule_time'] = timestamp
 
-    # Construct the fully qualified queue name.
-    parent = client.queue_path(project, location, queue)
-
     # Use the client to build and send the task.
     response = client.create_task(parent, task)
 

appengine/flexible/tasks/requirements.txt

@@ -1,3 +1,3 @@
 Flask==1.0.2
 gunicorn==19.9.0
-google-cloud-tasks==0.2.0
+google-cloud-tasks==0.3.0