0

0

使用PHP和Google Cloud Tasks实现异步任务和调度

王林

王林

发布时间:2023-06-25 12:51:11

|

1629人浏览过

|

来源于php中文网

原创

无论是在线应用程序还是离线处理任务,对于处理各种任务的web应用程序,异步任务处理和调度都是非常重要的。为了更好地管理任务,保持web应用程序的可扩展性并提高应用程序的性能,我们必须依赖异步任务处理和调度。

Google Cloud Tasks是一个完全托管的服务,可以轻松地通过API调用执行定期任务和异步任务。本文将向您展示如何使用PHP和Google Cloud Tasks实现异步任务和调度。我们将学习如何设置Google Cloud Tasks以及如何使用任务队列。

在开始之前,我们需要安装Google云SDK,设置Google Cloud Tasks,并创建一个Google Cloud Project以使用该服务。

安装Google Cloud SDK

Google云SDK是一个命令行工具,通常用于管理和运行云资源。您可以使用以下命令来安装Google云SDK:

立即学习PHP免费学习笔记(深入)”;

curl https://sdk.cloud.google.com | bash

在安装过程中,您需要遵循屏幕上的提示并输入您的Google帐户信息。

设置Google Cloud Tasks

接下来,我们需要设置Google Cloud Tasks。在Cloud Tasks中,任务由3个关键要素构成:任务队列,任务,执行程序。

任务队列是具有特定名称的资源,允许您放置新的任务。任务队列名称是全局唯一的。

任务是由您创建并将其添加到任务队列中的描述性对象。

执行程序是任务运行时调用的实际代码,通常位于您的Web应用程序中。

在本教程中,我们将使用以下值:

  • 项目ID:my-project-id
  • 任务队列ID:my-queue
  • Cloud函数URL:https://us-central1-my-project-id.cloudfunctions.net/processTask

现在,让我们快速设置Cloud Tasks。

  1. 首先,我们需要为Cloud Tasks启用任务API。在Cloud Console中,选择要从中配置Cloud Tasks的项目,然后转到API和服务>库。在搜索框中键入“Cloud Tasks API”,然后单击Cloud Tasks API以启用它。
  2. 接下来,我们需要创建任务队列。我们可以使用以下gcloud命令:
gcloud tasks queues create my-queue

此命令会创建一个名为my-queue的任务队列。如果您使用其他服务,例如App Engine或Cloud Functions,则可以将它们绑定到该队列以便于处理任务。

  1. 创建执行程序。在本教程中,我们将使用Cloud Functions作为执行程序。因此,我们需要创建一个Cloud函数。

在Cloud Console中,选择要从中配置Cloud Functions的项目,然后转到Cloud Functions。单击“创建函数”,并为新函数输入名称“processTask”。

我们将使用以下Cloud函数代码:

MusicLM
MusicLM

谷歌平台的AI作曲工具,用文字生成音乐

下载
 'my-project-id']);
    $logger = $logging->psrLogger('my-logger');

    $logger->info('Starting task', ['data' => $data]);

    $storage = new StorageClient(['projectId' => 'my-project-id']);
    $bucket = $storage->bucket('my-bucket');

    // TODO: Process the task

    $logger->info('Task completed successfully.');
}

该函数需要访问Google Cloud Storage,因此,我们还需要授予它访问权限。在Cloud Console中,转到存储>浏览。接下来,单击“创建存储桶”,为新桶选择标准存储并键入名称“my-bucket”。

在桶选项卡中,单击“权限”。 选择“添加实体”,为服务添加程序“cloud-tasks@cloudtasks.googleapis.com”权限。在“选择角色”下的“角色”下拉列表中,选择“Cloud Tasks任务执行者”。

现在,Cloud函数已准备好使用任务共享代码。

  1. 创建任务。我们现在可以为任务队列创建任务。我们将使用以下gcloud命令:
gcloud tasks create-http-task 
    --queue=my-queue 
    --url=https://us-central1-my-project-id.cloudfunctions.net/processTask 
    --http-method=POST 
    --body='{"message":"hello world"}'

使用以上gcloud命令,我们将创建一个POST请求,采用JSON格式,“message”属性设置为“hello world”。此任务将被添加到my-queue队列中。

这就是获取Cloud Tasks的完整设置。

使用PHP加载Cloud Tasks

现在,我们已经为Cloud Tasks进行了设置,让我们使用PHP加载Cloud Tasks。Google提供了一个名为google/cloud-tasks的官方PHP包。您可以使用Composer安装它:

composer require google/cloud-tasks

现在,我们可以编写PHP代码以创建任务,并将其添加到任务队列中。让我们看一下以下示例:

queueName($projectId, $location, $queueId);
$queue = new Queue();
$queue->setName($queueName);

$taskName = $cloudTasksClient->taskName($projectId, $location, $queueId, uniqid());
$task = new Task();
$task->setName($taskName);

$taskHttpReq = new GoogleCloudTasksV2HttpRequest();
$taskHttpReq->setUrl('https://us-central1-my-project-id.cloudfunctions.net/processTask');
$taskHttpReq->setHttpMethod(HttpMethod::POST);

$taskHttpReq->setBody(json_encode(['message' => 'hello world']));
$task->setHttpRequest($taskHttpReq);

$delay = new Duration();
$delay->setSeconds(10);
$task->setScheduleTime($delay);

$cloudTasksClient->createTask($queue, $task);

$cloudTasksClient->close();

此代码将创建一个名为“my-queue”的任务队列。接下来,它将创建一个任务,并将其添加到队列中。任务包含POST请求的URL,HTTP方法和数据体。

任务还包含计划时间,使任务在10秒后执行。

最后,我们使用“createTask”方法,将任务添加到队列。

总结

本文向您展示了如何使用PHP和Google Cloud Tasks实现任务调度和异步任务处理。Cloud Tasks是一个完全托管的服务,可以轻松地调用执行定期任务和异步任务的API。我们设置了一个Cloud函数,创建了任务队列,并使用PHP将任务添加到队列中。

在实际应用程序中,可能会添加更复杂的功能和服务,并且可以根据需要添加更多的队列和任务。但是,这应该为您提供将Google Cloud Tasks集成到Web应用程序中的良好起点。

相关文章

PHP速学教程(入门到精通)
PHP速学教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
composer是什么插件
composer是什么插件

Composer是一个PHP的依赖管理工具,它可以帮助开发者在PHP项目中管理和安装依赖的库文件。Composer通过一个中央化的存储库来管理所有的依赖库文件,这个存储库包含了各种可用的依赖库的信息和版本信息。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

154

2023.12.25

json数据格式
json数据格式

JSON是一种轻量级的数据交换格式。本专题为大家带来json数据格式相关文章,帮助大家解决问题。

419

2023.08.07

json是什么
json是什么

JSON是一种轻量级的数据交换格式,具有简洁、易读、跨平台和语言的特点,JSON数据是通过键值对的方式进行组织,其中键是字符串,值可以是字符串、数值、布尔值、数组、对象或者null,在Web开发、数据交换和配置文件等方面得到广泛应用。本专题为大家提供json相关的文章、下载、课程内容,供大家免费下载体验。

535

2023.08.23

jquery怎么操作json
jquery怎么操作json

操作的方法有:1、“$.parseJSON(jsonString)”2、“$.getJSON(url, data, success)”;3、“$.each(obj, callback)”;4、“$.ajax()”。更多jquery怎么操作json的详细内容,可以访问本专题下面的文章。

311

2023.10.13

go语言处理json数据方法
go语言处理json数据方法

本专题整合了go语言中处理json数据方法,阅读专题下面的文章了解更多详细内容。

77

2025.09.10

console接口是干嘛的
console接口是干嘛的

console接口是一种用于在计算机命令行或浏览器开发工具中输出信息的工具,提供了一种简单的方式来记录和查看应用程序的输出结果和调试信息。本专题为大家提供console接口相关的各种文章、以及下载和课程。

415

2023.08.08

console.log是什么
console.log是什么

console.log 是 javascript 函数,用于在浏览器控制台中输出信息,便于调试和故障排除。想了解更多console.log的相关内容,可以阅读本专题下面的文章。

510

2024.05.29

http500解决方法
http500解决方法

http500解决方法有检查服务器日志、检查代码错误、检查服务器配置、检查文件和目录权限、检查资源不足、更新软件版本、重启服务器或寻求专业帮助等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

427

2023.11.09

java入门学习合集
java入门学习合集

本专题整合了java入门学习指南、初学者项目实战、入门到精通等等内容,阅读专题下面的文章了解更多详细学习方法。

1

2026.01.29

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
最新Python教程 从入门到精通
最新Python教程 从入门到精通

共4课时 | 22.4万人学习

Rust 教程
Rust 教程

共28课时 | 5万人学习

Kotlin 教程
Kotlin 教程

共23课时 | 3万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号