本文旨在解决Google App Engine (GAE) 中，如何从一个服务（例如Python）提交任务，并让另一个服务（例如Node.js）执行该任务的问题。我们将探讨通过 dispatch.yaml 文件进行路由配置，以及通过HTTP调用间接提交任务这两种方案，帮助开发者实现跨服务任务调度的需求。
在Google App Engine (GAE) 中，任务队列是一个强大的工具，允许我们将耗时的操作异步化，从而提高应用程序的响应速度和可靠性。 然而，有时我们需要将任务从一个服务提交到另一个服务进行处理，例如，从Python服务提交任务到Node.js服务。 本文将介绍两种实现此目标的方法。
1. 利用 dispatch.yaml 进行路由
dispatch.yaml 文件用于定义请求如何路由到不同的服务。 如果您的路由规则仅基于路径（不涉及域名或子域名），则可以通过在任务的 relative_uri 中指定目标服务的路径来实现跨服务任务调度。
示例：
立即学习“Python免费学习笔记（深入）”；
假设您的 dispatch.yaml 文件包含以下规则：
dispatch: - url: "*/mobile/*" service: mobile-frontend - url: "*/work/*" service: static-backend
在这种情况下，如果您的 Python 服务（运行在 static-backend 服务上）想要将任务发送到 mobile-frontend 服务，您可以将任务的 relative_uri 设置为 /mobile/mobile_task。
Python代码示例 (使用 google.cloud.tasks_v2 客户端库)：
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)# 任务的 payloadpayload = '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}')
Node.js服务中的处理逻辑 (假设 mobile-frontend 服务使用 Express.js):
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}`);});
注意事项：
确保目标服务（例如 mobile-frontend）监听了 relative_uri 中指定的路径（例如 /mobile/mobile_task）。任务的 payload 可以通过 req.body 在目标服务中访问。
2. 通过 HTTP 调用间接提交任务
如果您的 dispatch.yaml 文件路由规则包含域名或子域名，则可以采用间接的方式提交任务。 首先，从源服务向目标服务发送一个 HTTP 请求，目标服务接收到请求后，再自行提交任务。
示例：
立即学习“Python免费学习笔记（深入）”；
假设您有一个服务运行在 blog.example.com，您希望从默认服务提交任务到该服务。
步骤：
从默认服务向 blog.example.com/prep_task_invocation/ 发送 HTTP 请求。 将任务所需的数据作为请求的 payload 传递。
Python代码示例 (从默认服务发送 HTTP 请求):
import requestsurl = '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}')
blog.example.com/prep_task_invocation/ 接收到请求后，提交任务到自身。
Node.js服务中的处理逻辑 (Express.js 示例):
const express = require('express');const { CloudTasksClient } = require('@google-cloud/tasks');const app = express();app.use(express.json()); // 使用 JSON body parserapp.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}`);});
注意事项：
确保 blog.example.com 服务内部的 /process_task endpoint 能够处理任务逻辑。在提交任务时，确保 relative_uri 不会将任务路由到其他服务。
总结
本文介绍了两种在 Google App Engine 中实现跨服务任务调度的方案：利用 dispatch.yaml 进行路由和通过 HTTP 调用间接提交任务。 选择哪种方案取决于您的 dispatch.yaml 文件配置以及应用程序的具体需求。 通过合理地利用任务队列和路由规则，您可以构建更加灵活和可扩展的 GAE 应用程序。
以上就是GAE跨服务提交任务：Python到Node.js的实现方法的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1364426.html
微信扫一扫 
支付宝扫一扫 
