GAE跨服务提交任务：Python到Node.js的实现方法

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

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

from google.cloud import tasks_v2

# 创建 Cloud Tasks 客户端
client = tasks_v2.CloudTasksClient()

# 项目 ID 和队列名称
project = 'your-project-id'
queue = 'default'
location = 'your-location'  # 例如：'us-central1'
queue_path = client.queue_path(project, location, queue)

# 任务的 payload
payload = 'This is the task payload'.encode()

# 构造任务对象
task = {
    'name': client.task_path(project, location, queue, 'your-task-id'), # 可选，自动生成
    'http_request': {
        'http_method': tasks_v2.HttpMethod.POST,
        'url': '/mobile/mobile_task', # 关键：指定目标服务的路径
        'body': payload,
    }
}

# 提交任务
response = client.create_task(request={'parent': queue_path, 'task': task})

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

const express = require('express');
const app = express();

app.post('/mobile/mobile_task', (req, res) => {
  // 处理任务的逻辑
  console.log('Task received by mobile-frontend service!');
  console.log('Payload:', req.body.toString());
  res.status(200).send('Task processed successfully');
});

const port = process.env.PORT || 8080;
app.listen(port, () => {
  console.log(`mobile-frontend service listening on port ${port}`);
});

import requests

url = 'https://blog.example.com/prep_task_invocation/'
payload = {'data': 'Task data to be processed'}
headers = {'Content-type': 'application/json'}

response = requests.post(url, json=payload, headers=headers)

if response.status_code == 200:
    print('HTTP request to blog.example.com successful')
else:
    print(f'HTTP request failed with status code: {response.status_code}')

const express = require('express');
const { CloudTasksClient } = require('@google-cloud/tasks');
const app = express();

app.use(express.json()); // 使用 JSON body parser

app.post('/prep_task_invocation', async (req, res) => {
  const taskData = req.body.data;

  // 创建 Cloud Tasks 客户端
  const client = new CloudTasksClient();

  // 项目 ID、队列名称和位置
  const project = 'your-project-id';
  const queue = 'default';
  const location = 'your-location';
  const queuePath = client.queuePath(project, location, queue);

  // 构造任务对象
  const task = {
    httpRequest: {
      httpMethod: 'POST',
      url: '/process_task', // 目标服务内部处理任务的 endpoint
      body: Buffer.from(JSON.stringify({data: taskData})),
      headers: {
        'Content-Type': 'application/json',
      },
    },
  };

  // 提交任务
  try {
    const [response] = await client.createTask({
      parent: queuePath,
      task: task,
    });
    console.log(`Created task ${response.name}`);
    res.status(200).send('Task submission initiated');
  } catch (error) {
    console.error('Error creating task:', error);
    res.status(500).send('Task submission failed');
  }
});

app.post('/process_task', (req, res) => {
    const taskData = req.body.data;
    console.log("Processing task with data:", taskData);
    res.status(200).send("Task processed successfully");
});

const port = process.env.PORT || 8080;
app.listen(port, () => {
  console.log(`blog.example.com service listening on port ${port}`);
});