2023-06-25

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

无论是在线应用程序还是离线处理任务,对于处理各种任务的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:

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函数代码:

<?php

use GoogleCloudStorageStorageClient;
use GoogleCloudLoggingLoggingClient;

function processTask($data, $context)
{
    $bucket = 'my-bucket';

    $logging = new LoggingClient(['projectId' => '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代码以创建任务,并将其添加到任务队列中。让我们看一下以下示例:

<?php

require_once __DIR__ . '/vendor/autoload.php';

use GoogleCloudTasksV2CloudTasksClient;
use GoogleCloudTasksV2HttpMethod;
use GoogleCloudTasksV2Queue;
use GoogleCloudTasksV2Task;
use GoogleProtobufDuration;

$projectId = 'my-project-id';
$location = 'us-central1';
$queueId = 'my-queue';

$cloudTasksClient = new CloudTasksClient();

$queueName = $cloudTasksClient->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和Google Cloud Tasks实现异步任务和调度的详细内容,更多请关注php中文网其它相关文章!

https://www.php.cn/faq/566881.html

发表回复

Your email address will not be published. Required fields are marked *