使用PHP和Google Cloud Tasks實現非同步任務和調度

無論是線上應用程式還是離線處理任務，對於處理各種任務的網路應用程序，非同步任務處理和調度都是非常重要的。為了更好地管理任務，保持網路應用程式的可擴展性並提高應用程式的效能，我們必須依賴非同步任務處理和調度。

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個關鍵要素構成：任務佇列，任務，執行程式。

任務佇列是具有特定名稱的資源，可讓您放置新的任務。任務隊列名稱是全域唯一的。

任務是由您建立並將其新增至任務佇列中的描述性物件。

執行程式是任務執行時期呼叫的實際程式碼，通常位於您的網路應用程式中。

在本教學中，我們將使用以下值：

• 專案ID：my-project-id
• 任務佇列ID：my-queue
• Cloud函數網址：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，則可以將它們綁定到該佇列以便於處理任務。

3. 建立執行程式。在本教程中，我們將使用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函數已準備好使用任務共享程式碼。

4. 建立任務。我們現在可以為任務隊列建立任務。我們將使用以下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中文網其他相關文章！