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

王林
發布: 2023-06-25 12:52:02
原創
1389 人瀏覽過

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

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,則可以將它們綁定到該佇列以便於處理任務。

  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中文網其他相關文章!

來源:php.cn
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板
關於我們 免責聲明 Sitemap
PHP中文網:公益線上PHP培訓,幫助PHP學習者快速成長!