GAE 任务调度：跨服务执行任务的实现方案

dispatch:
  - url: "*/mobile/*"
    service: mobile-frontend

  - url: "*/work/*"
    service: static-backend

import requests
import json

task_data = {"message": "Hello from default service!"}
url = "http://blog.example.com/prep_task_invocation/"
headers = {'Content-type': 'application/json'}
response = requests.post(url, data=json.dumps(task_data), headers=headers)

if response.status_code == 200:
    print("Task submission request sent successfully!")
else:
    print(f"Error sending task submission request: {response.status_code}")

from flask import Flask, request
from google.cloud import tasks_v2
import json

app = Flask(__name__)

@app.route('/prep_task_invocation/', methods=['POST'])
def prep_task_invocation():
    task_data = request.get_json()
    print(f"Received task data: {task_data}")

    # Create a client.
    client = tasks_v2.CloudTasksClient()

    # TODO: Fill in the queue path.
    queue = client.queue_path("[PROJECT_ID]", "[LOCATION_ID]", "[QUEUE_ID]")

    # Construct the request body.
    task = {
            "app_engine_http_request": {  # Specify the type of request.
                "http_method": "POST",
                "relative_uri": "/process_task", # Endpoint to actually process the task
                "body": json.dumps(task_data).encode() # Pass the data
            }
    }

    # Use the client to build and send the task.
    response = client.create_task(request={"parent": queue, "task": task})

    print(f"Created task {response.name}")

    return "Task submitted successfully!", 200

@app.route('/process_task', methods=['POST'])
def process_task():
    task_data = request.get_json()
    print(f"Processing task with data: {task_data}")
    # Your task processing logic here
    return "Task processed successfully!", 200

if __name__ == '__main__':
    app.run(debug=True, host='0.0.0.0', port=8080)